Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Public Attributes | List of all members
impala::FragmentExecParams Struct Reference

#include <query-schedule.h>

Collaboration diagram for impala::FragmentExecParams:

Public Attributes

std::vector< TNetworkAddress > hosts
 
std::vector< TUniqueId > instance_ids
 
std::vector
< TPlanFragmentDestination > 		destinations
 
std::map< PlanNodeId, int > per_exch_num_senders
 
FragmentScanRangeAssignment scan_range_assignment
 
int sender_id_base
 

Detailed Description

execution parameters for a single fragment; used to assemble the per-fragment instance TPlanFragmentExecParams; hosts.size() == instance_ids.size()

Definition at line 47 of file query-schedule.h.

Member Data Documentation

std::vector<TPlanFragmentDestination> impala::FragmentExecParams::destinations

Definition at line 50 of file query-schedule.h.

Referenced by impala::SimpleScheduler::ComputeFragmentExecParams().

std::vector<TNetworkAddress> impala::FragmentExecParams::hosts

Definition at line 48 of file query-schedule.h.

Referenced by impala::SimpleScheduler::ComputeFragmentExecParams(), impala::SimpleScheduler::ComputeFragmentHosts(), and impala::QuerySchedule::ValidateReservation().

std::vector<TUniqueId> impala::FragmentExecParams::instance_ids

Definition at line 49 of file query-schedule.h.

Referenced by impala::SimpleScheduler::ComputeFragmentExecParams().

std::map<PlanNodeId, int> impala::FragmentExecParams::per_exch_num_senders

Definition at line 51 of file query-schedule.h.

FragmentScanRangeAssignment impala::FragmentExecParams::scan_range_assignment

Definition at line 52 of file query-schedule.h.

Referenced by impala::SimpleScheduler::GetScanHosts().

int impala::FragmentExecParams::sender_id_base

In its role as a data sender, a fragment instance is assigned a "sender id" to uniquely identify it to a receiver. The id that a particular fragment instance is assigned ranges from [sender_id_base, sender_id_base + N - 1], where N = hosts.size (i.e. N = number of fragment instances)

Definition at line 57 of file query-schedule.h.

Referenced by impala::SimpleScheduler::ComputeFragmentExecParams().

The documentation for this struct was generated from the following file: