Inheritance diagram for com.cloudera.impala.planner.PlanNode:

Collaboration diagram for com.cloudera.impala.planner.PlanNode:

Public Member Functions
PlanNodeId	getId ()

void	setId (PlanNodeId id)

long	getLimit ()

boolean	hasLimit ()

long	getPerHostMemCost ()

long	getCardinality ()

int	getNumNodes ()

float	getAvgRowSize ()

void	setFragment (PlanFragment fragment)

PlanFragment	getFragment ()

List< Expr >	getConjuncts ()

ExprSubstitutionMap	getOutputSmap ()

void	setOutputSmap (ExprSubstitutionMap smap)

Set< ExprId >	getAssignedConjuncts ()

void	setAssignedConjuncts (Set< ExprId > conjuncts)

void	setLimit (long limit)

void	unsetLimit ()

ArrayList< TupleId >	getTupleIds ()

ArrayList< TupleId >	getTblRefIds ()

void	setTblRefIds (ArrayList< TupleId > ids)

Set< TupleId >	getNullableTupleIds ()

void	addConjuncts (List< Expr > conjuncts)

void	transferConjuncts (PlanNode recipient)

String	getExplainString ()

TPlan	treeToThrift ()

void	init (Analyzer analyzer) throws InternalException

boolean	isBlockingNode ()

void	computeCosts (TQueryOptions queryOptions)

long	getInputCardinality ()

Static Public Member Functions
static long	addCardinalities (long a, long b)

static long	multiplyCardinalities (long a, long b)

Protected Member Functions
	PlanNode (PlanNodeId id, ArrayList< TupleId > tupleIds, String displayName)

	PlanNode (String displayName)

	PlanNode (PlanNodeId id, String displayName)

	PlanNode (PlanNodeId id, PlanNode node, String displayName)

void	setDisplayName (String s)

final String	getDisplayLabel ()

String	getDisplayLabelDetail ()

final String	getExplainString (String rootPrefix, String prefix, TExplainLevel detailLevel)

String	getNodeExplainString (String rootPrefix, String detailPrefix, TExplainLevel detailLevel)

String	getOffsetExplainString (String prefix)

void	assignConjuncts (Analyzer analyzer)

ExprSubstitutionMap	getCombinedChildSmap ()

void	createDefaultSmap (Analyzer analyzer)

void	computeStats (Analyzer analyzer)

long	capAtLimit (long cardinality)

void	markSlotsMaterialized (Analyzer analyzer, List< Expr > exprs)

void	computeMemLayout (Analyzer analyzer)

double	computeSelectivity ()

abstract void	toThrift (TPlanNode msg)

String	debugString ()

String	getExplainString (List<?extends Expr > exprs)

boolean	hasValidStats ()

Protected Attributes
String	displayName_

PlanNodeId	id_

long	limit_

ArrayList< TupleId >	tupleIds_

ArrayList< TupleId >	tblRefIds_

Set< TupleId >	nullableTupleIds_ = Sets.newHashSet()

List< Expr >	conjuncts_ = Lists.newArrayList()

PlanFragment	fragment_

ExprSubstitutionMap	outputSmap_

Set< ExprId >	assignedConjuncts_

long	cardinality_

int	numNodes_

float	avgRowSize_

long	perHostMemCost_ = -1

Static Protected Attributes
static final int	DEFAULT_BATCH_SIZE = 1024

Private Member Functions
void	treeToThriftHelper (TPlan container)

Static Private Attributes
static final Logger	LOG = LoggerFactory.getLogger(PlanNode.class)

Detailed Description

Each PlanNode represents a single relational operator and encapsulates the information needed by the planner to make optimization decisions.

finalize(): Computes internal state, such as keys for scan nodes; gets called once on the root of the plan tree before the call to toThrift(). Also finalizes the set of conjuncts, such that each remaining one requires all of its referenced slots to be materialized (ie, can be evaluated by calling GetValue(), rather than being implicitly evaluated as part of a scan key).

conjuncts_: Each node has a list of conjuncts that can be executed in the context of this node, ie, they only reference tuples materialized by this node or one of its children (= are bound by tupleIds_).

Definition at line 59 of file PlanNode.java.

Constructor & Destructor Documentation

com.cloudera.impala.planner.PlanNode.PlanNode	(	PlanNodeId	id,
		ArrayList< TupleId >	tupleIds,
		String	displayName
	)

inlineprotected

Definition at line 116 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.cardinality_, com.cloudera.impala.planner.PlanNode.displayName_, com.cloudera.impala.planner.PlanNode.id_, com.cloudera.impala.planner.PlanNode.limit_, com.cloudera.impala.planner.PlanNode.numNodes_, com.cloudera.impala.planner.PlanNode.tblRefIds_, and com.cloudera.impala.planner.PlanNode.tupleIds_.

com.cloudera.impala.planner.PlanNode.PlanNode ( String displayName )

inlineprotected

Deferred id_ assignment.

Definition at line 130 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.cardinality_, com.cloudera.impala.planner.PlanNode.displayName_, com.cloudera.impala.planner.PlanNode.limit_, com.cloudera.impala.planner.PlanNode.numNodes_, com.cloudera.impala.planner.PlanNode.tblRefIds_, and com.cloudera.impala.planner.PlanNode.tupleIds_.

com.cloudera.impala.planner.PlanNode.PlanNode	(	PlanNodeId	id,
		String	displayName
	)

inlineprotected

Definition at line 139 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.cardinality_, com.cloudera.impala.planner.PlanNode.displayName_, com.cloudera.impala.planner.PlanNode.id_, com.cloudera.impala.planner.PlanNode.limit_, com.cloudera.impala.planner.PlanNode.numNodes_, com.cloudera.impala.planner.PlanNode.tblRefIds_, and com.cloudera.impala.planner.PlanNode.tupleIds_.

com.cloudera.impala.planner.PlanNode.PlanNode	(	PlanNodeId	id,
		PlanNode	node,
		String	displayName
	)

inlineprotected

Copy c'tor. Also passes in new id_.

Definition at line 152 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.cardinality_, com.cloudera.impala.planner.PlanNode.conjuncts_, com.cloudera.impala.planner.PlanNode.displayName_, com.cloudera.impala.planner.PlanNode.id_, com.cloudera.impala.planner.PlanNode.limit_, com.cloudera.impala.planner.PlanNode.nullableTupleIds_, com.cloudera.impala.planner.PlanNode.numNodes_, com.cloudera.impala.planner.PlanNode.tblRefIds_, and com.cloudera.impala.planner.PlanNode.tupleIds_.

Member Function Documentation

static long com.cloudera.impala.planner.PlanNode.addCardinalities	(	long	a,
		long	b
	)

inlinestatic

Computes and returns the sum of two cardinalities. If an overflow occurs, the maximum Long value is returned (Long.MAX_VALUE).

Definition at line 528 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.ExchangeNode.computeStats(), com.cloudera.impala.planner.UnionNode.computeStats(), com.cloudera.impala.planner.HashJoinNode.computeStats(), com.cloudera.impala.planner.HdfsScanNode.computeStats(), and com.cloudera.impala.planner.PlanNode.getInputCardinality().

void com.cloudera.impala.planner.PlanNode.addConjuncts ( List< Expr > conjuncts )

inline

Definition at line 209 of file PlanNode.java.

void com.cloudera.impala.planner.PlanNode.assignConjuncts ( Analyzer analyzer )

inlineprotected

Assign remaining unassigned conjuncts.

Definition at line 401 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.DataSourceScanNode.init(), com.cloudera.impala.planner.SortNode.init(), com.cloudera.impala.planner.AggregationNode.init(), com.cloudera.impala.planner.HBaseScanNode.init(), com.cloudera.impala.planner.HdfsScanNode.init(), com.cloudera.impala.planner.HashJoinNode.init(), and com.cloudera.impala.planner.PlanNode.init().

long com.cloudera.impala.planner.PlanNode.capAtLimit ( long cardinality )

inlineprotected

Definition at line 450 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.hasLimit(), and com.cloudera.impala.planner.PlanNode.limit_.

Referenced by com.cloudera.impala.planner.SortNode.computeStats(), com.cloudera.impala.planner.HBaseScanNode.computeStats(), com.cloudera.impala.planner.DataSourceScanNode.computeStats(), and com.cloudera.impala.planner.HdfsScanNode.computeStats().

void com.cloudera.impala.planner.PlanNode.computeCosts ( TQueryOptions queryOptions )

inline

Estimates the cost of executing this PlanNode. Currently only sets perHostMemCost_. May only be called after this PlanNode has been placed in a PlanFragment because the cost computation is dependent on the enclosing fragment's data partition.

Definition at line 562 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.perHostMemCost_.

void com.cloudera.impala.planner.PlanNode.computeMemLayout ( Analyzer analyzer )

inlineprotected

Call computeMemLayout() for all materialized tuples.

Definition at line 475 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.tupleIds_.

Referenced by com.cloudera.impala.planner.EmptySetNode.init(), com.cloudera.impala.planner.DataSourceScanNode.init(), com.cloudera.impala.planner.SortNode.init(), com.cloudera.impala.planner.AggregationNode.init(), com.cloudera.impala.planner.AnalyticEvalNode.init(), com.cloudera.impala.planner.HBaseScanNode.init(), com.cloudera.impala.planner.HdfsScanNode.init(), and com.cloudera.impala.planner.UnionNode.init().

double com.cloudera.impala.planner.PlanNode.computeSelectivity ( )

inlineprotected

Compute the product of the selectivies of all conjuncts.

Definition at line 484 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.conjuncts_.

Referenced by com.cloudera.impala.planner.SelectNode.computeStats(), com.cloudera.impala.planner.CrossJoinNode.computeStats(), com.cloudera.impala.planner.AggregationNode.computeStats(), com.cloudera.impala.planner.HBaseScanNode.computeStats(), com.cloudera.impala.planner.DataSourceScanNode.computeStats(), and com.cloudera.impala.planner.HdfsScanNode.computeStats().

void com.cloudera.impala.planner.PlanNode.computeStats ( Analyzer analyzer )

inlineprotected

Computes planner statistics: avgRowSize_, numNodes_, cardinality_. Subclasses need to override this. Assumes that it has already been called on all children. and that DescriptorTable.computePhysMemLayout() has been called. This is broken out of init() so that it can be called separately from init() (to facilitate inserting additional nodes during plan partitioning w/o the need to call init() recursively on the whole tree again).

Definition at line 441 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.avgRowSize_, com.cloudera.impala.planner.PlanNode.numNodes_, and com.cloudera.impala.planner.PlanNode.tupleIds_.

Referenced by com.cloudera.impala.planner.PlanNode.init().

void com.cloudera.impala.planner.PlanNode.createDefaultSmap ( Analyzer analyzer )

inlineprotected

Sets outputSmap_ to compose(existing smap, combined child smap). Also substitutes conjuncts_ using the combined child smap.

Definition at line 425 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.conjuncts_, com.cloudera.impala.planner.PlanNode.getCombinedChildSmap(), and com.cloudera.impala.planner.PlanNode.outputSmap_.

Referenced by com.cloudera.impala.planner.SelectNode.init(), com.cloudera.impala.planner.AnalyticEvalNode.init(), com.cloudera.impala.planner.HashJoinNode.init(), and com.cloudera.impala.planner.PlanNode.init().

String com.cloudera.impala.planner.PlanNode.debugString ( )

inlineprotected

Definition at line 497 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.conjuncts_, and com.cloudera.impala.planner.PlanNode.limit_.

Set<ExprId> com.cloudera.impala.planner.PlanNode.getAssignedConjuncts ( )

inline

Definition at line 180 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.assignedConjuncts_.

float com.cloudera.impala.planner.PlanNode.getAvgRowSize ( )

inline

Definition at line 174 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.avgRowSize_.

Referenced by com.cloudera.impala.planner.CrossJoinNode.computeCosts(), com.cloudera.impala.planner.HashJoinNode.computeCosts(), and com.cloudera.impala.planner.SingleNodePlanner.createCheapestJoinPlan().

long com.cloudera.impala.planner.PlanNode.getCardinality ( )

inline

Definition at line 172 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.cardinality_.

Referenced by com.cloudera.impala.planner.CrossJoinNode.computeCosts(), com.cloudera.impala.planner.HashJoinNode.computeCosts(), com.cloudera.impala.planner.AggregationNode.computeStats(), com.cloudera.impala.planner.SingleNodePlanner.createCheapestJoinPlan(), and com.cloudera.impala.planner.SingleNodePlanner.createJoinPlan().

ExprSubstitutionMap com.cloudera.impala.planner.PlanNode.getCombinedChildSmap ( )

inlineprotected

Returns an smap that combines the childrens' smaps.

Definition at line 410 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.createDefaultSmap(), com.cloudera.impala.planner.SortNode.init(), com.cloudera.impala.planner.AggregationNode.init(), com.cloudera.impala.planner.AnalyticEvalNode.init(), and com.cloudera.impala.planner.HashJoinNode.init().

List<Expr> com.cloudera.impala.planner.PlanNode.getConjuncts ( )

inline

Definition at line 177 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.conjuncts_.

Referenced by com.cloudera.impala.planner.ScanNode.getInputCardinality().

final String com.cloudera.impala.planner.PlanNode.getDisplayLabel ( )

inlineprotected

Definition at line 225 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.displayName_.

Referenced by com.cloudera.impala.planner.ExchangeNode.getNodeExplainString(), com.cloudera.impala.planner.AnalyticEvalNode.getNodeExplainString(), com.cloudera.impala.planner.AggregationNode.getNodeExplainString(), com.cloudera.impala.planner.HashJoinNode.getNodeExplainString(), com.cloudera.impala.planner.HdfsScanNode.getNodeExplainString(), and com.cloudera.impala.planner.PlanNode.treeToThriftHelper().

String com.cloudera.impala.planner.PlanNode.getDisplayLabelDetail ( )

inlineprotected

Subclasses can override to provide a node specific detail string that is displayed to the user. e.g. scan can return the table name.

Definition at line 234 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.treeToThriftHelper().

String com.cloudera.impala.planner.PlanNode.getExplainString ( )

inline

Definition at line 219 of file PlanNode.java.

final String com.cloudera.impala.planner.PlanNode.getExplainString	(	String	rootPrefix,
		String	prefix,
		TExplainLevel	detailLevel
	)

inlineprotected

Generate the explain plan tree. The plan will be in the form of:

The root node header line will be prefixed by rootPrefix and the remaining plan output will be prefixed by prefix.

Definition at line 252 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.avgRowSize_, com.cloudera.impala.planner.PlanNode.cardinality_, com.cloudera.impala.planner.PlanNode.getExplainString(), com.cloudera.impala.planner.PlanNode.getNodeExplainString(), com.cloudera.impala.planner.PlanNode.getOffsetExplainString(), com.cloudera.impala.planner.PlanNode.limit_, com.cloudera.impala.planner.PlanNode.numNodes_, com.cloudera.impala.planner.PlanNode.perHostMemCost_, and com.cloudera.impala.planner.PlanNode.tupleIds_.

String com.cloudera.impala.planner.PlanNode.getExplainString ( List<?extends Expr > exprs )

inlineprotected

Definition at line 506 of file PlanNode.java.

PlanFragment com.cloudera.impala.planner.PlanNode.getFragment ( )

inline

Definition at line 176 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.fragment_.

Referenced by com.cloudera.impala.planner.ExchangeNode.addChild(), and com.cloudera.impala.planner.PipelinedPlanNodeSet.computePlanNodeSets().

PlanNodeId com.cloudera.impala.planner.PlanNode.getId ( )

inline

Definition at line 164 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.id_.

Referenced by com.cloudera.impala.planner.DataStreamSink.getExplainString(), com.cloudera.impala.planner.AggregationNode.init(), and com.cloudera.impala.planner.DataStreamSink.toThrift().

long com.cloudera.impala.planner.PlanNode.getInputCardinality ( )

inline

The input cardinality is the sum of output cardinalities of its children. For scan nodes the input cardinality is the expected number of rows scanned.

Definition at line 570 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.addCardinalities().

long com.cloudera.impala.planner.PlanNode.getLimit ( )

inline

Definition at line 169 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.limit_.

Referenced by com.cloudera.impala.planner.ScanNode.getInputCardinality().

String com.cloudera.impala.planner.PlanNode.getNodeExplainString	(	String	rootPrefix,
		String	detailPrefix,
		TExplainLevel	detailLevel
	)

inlineprotected

Return the node-specific details. Subclass should override this function. Each line should be prefix by detailPrefix.

Definition at line 325 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.getExplainString().

Set<TupleId> com.cloudera.impala.planner.PlanNode.getNullableTupleIds ( )

inline

Definition at line 204 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.nullableTupleIds_.

int com.cloudera.impala.planner.PlanNode.getNumNodes ( )

inline

Definition at line 173 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.numNodes_.

Referenced by com.cloudera.impala.planner.PipelinedPlanNodeSet.computeResourceEstimates(), com.cloudera.impala.planner.HBaseScanNode.computeStats(), and com.cloudera.impala.planner.DataSourceScanNode.computeStats().

String com.cloudera.impala.planner.PlanNode.getOffsetExplainString ( String prefix )

inlineprotected

Return the offset_ details, if applicable. This is available separately from 'getNodeExplainString' because we want to output 'limit: ...' (which can be printed from PlanNode) before 'offset: ...', which is only printed from SortNodes right now.

Definition at line 336 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.getExplainString().

ExprSubstitutionMap com.cloudera.impala.planner.PlanNode.getOutputSmap ( )

inline

Definition at line 178 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.outputSmap_.

long com.cloudera.impala.planner.PlanNode.getPerHostMemCost ( )

inline

Definition at line 171 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.perHostMemCost_.

Referenced by com.cloudera.impala.planner.PipelinedPlanNodeSet.computeResourceEstimates().

ArrayList<TupleId> com.cloudera.impala.planner.PlanNode.getTblRefIds ( )

inline

Definition at line 201 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.tblRefIds_.

Referenced by com.cloudera.impala.analysis.Analyzer.canEvalPredicate().

ArrayList<TupleId> com.cloudera.impala.planner.PlanNode.getTupleIds ( )

inline

Definition at line 196 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.tupleIds_.

Referenced by com.cloudera.impala.planner.AnalyticEvalNode.AnalyticEvalNode(), com.cloudera.impala.planner.SingleNodePlanner.createInlineViewPlan(), com.cloudera.impala.planner.AnalyticPlanner.createSortInfo(), and com.cloudera.impala.planner.SelectNode.SelectNode().

boolean com.cloudera.impala.planner.PlanNode.hasLimit ( )

inline

Definition at line 170 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.limit_.

Referenced by com.cloudera.impala.planner.PlanNode.capAtLimit(), com.cloudera.impala.planner.ExchangeNode.computeStats(), com.cloudera.impala.planner.ScanNode.getInputCardinality(), and com.cloudera.impala.planner.SortNode.getNodeExplainDetail().

boolean com.cloudera.impala.planner.PlanNode.hasValidStats ( )

inlineprotected

Returns true if stats-related variables are valid.

Definition at line 519 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.cardinality_, and com.cloudera.impala.planner.PlanNode.numNodes_.

Referenced by com.cloudera.impala.planner.SortNode.computeCosts(), and com.cloudera.impala.planner.HashJoinNode.computeStats().

void com.cloudera.impala.planner.PlanNode.init ( Analyzer analyzer ) throws InternalException

inline

Computes the full internal state, including smap and planner-relevant statistics (calls computeStats()), marks all slots referenced by this node as materialized and computes the mem layout of all materialized tuples (with the assumption that slots that are needed by ancestor PlanNodes have already been marked). Also performs final expr substitution with childrens' smaps and computes internal state required for toThrift(). This is called directly after construction.

Definition at line 392 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.assignConjuncts(), com.cloudera.impala.planner.PlanNode.computeStats(), and com.cloudera.impala.planner.PlanNode.createDefaultSmap().

boolean com.cloudera.impala.planner.PlanNode.isBlockingNode ( )

inline

Returns true if this plan node can output its first row only after consuming all rows of all its children. This method is used to group plan nodes into pipelined units for resource estimation.

Definition at line 555 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PipelinedPlanNodeSet.computePlanNodeSets().

void com.cloudera.impala.planner.PlanNode.markSlotsMaterialized	(	Analyzer	analyzer,
		List< Expr >	exprs
	)

inlineprotected

Marks all slots referenced in exprs as materialized.

Definition at line 464 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.HdfsScanNode.init().

static long com.cloudera.impala.planner.PlanNode.multiplyCardinalities	(	long	a,
		long	b
	)

inlinestatic

Computes and returns the product of two cardinalities. If an overflow occurs, the maximum Long value is returned (Long.MAX_VALUE).

Definition at line 541 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.CrossJoinNode.computeStats(), and com.cloudera.impala.planner.HashJoinNode.getJoinCardinality().

void com.cloudera.impala.planner.PlanNode.setAssignedConjuncts ( Set< ExprId > conjuncts )

inline

Definition at line 181 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.assignedConjuncts_.

void com.cloudera.impala.planner.PlanNode.setDisplayName ( String s )

inlineprotected

Definition at line 223 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.displayName_.

void com.cloudera.impala.planner.PlanNode.setFragment ( PlanFragment fragment )

inline

Definition at line 175 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.fragment_.

void com.cloudera.impala.planner.PlanNode.setId ( PlanNodeId id )

inline

Definition at line 165 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.id_.

void com.cloudera.impala.planner.PlanNode.setLimit ( long limit )

inline

Set the limit_ to the given limit_ only if the limit_ hasn't been set, or the new limit_ is lower.

Parameters

limit_

Definition at line 190 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.limit_.

void com.cloudera.impala.planner.PlanNode.setOutputSmap ( ExprSubstitutionMap smap )

inline

Definition at line 179 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.outputSmap_.

void com.cloudera.impala.planner.PlanNode.setTblRefIds ( ArrayList< TupleId > ids )

inline

Definition at line 202 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.tblRefIds_.

abstract void com.cloudera.impala.planner.PlanNode.toThrift ( TPlanNode msg )

abstractprotected

Referenced by com.cloudera.impala.planner.PlanNode.treeToThriftHelper().

void com.cloudera.impala.planner.PlanNode.transferConjuncts ( PlanNode recipient )

inline

Definition at line 214 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.conjuncts_.

TPlan com.cloudera.impala.planner.PlanNode.treeToThrift ( )

inline

Definition at line 341 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.treeToThriftHelper().

void com.cloudera.impala.planner.PlanNode.treeToThriftHelper ( TPlan container )

inlineprivate

Definition at line 348 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.cardinality_, com.cloudera.impala.planner.PlanNode.conjuncts_, com.cloudera.impala.planner.PlanNode.getDisplayLabel(), com.cloudera.impala.planner.PlanNode.getDisplayLabelDetail(), com.cloudera.impala.planner.PlanNode.limit_, com.cloudera.impala.planner.PlanNode.perHostMemCost_, com.cloudera.impala.planner.PlanNode.toThrift(), and com.cloudera.impala.planner.PlanNode.tupleIds_.

Referenced by com.cloudera.impala.planner.PlanNode.treeToThrift().

void com.cloudera.impala.planner.PlanNode.unsetLimit ( )

inline

Definition at line 194 of file PlanNode.java.

References com.cloudera.impala.planner.PlanNode.limit_.

Member Data Documentation

Set<ExprId> com.cloudera.impala.planner.PlanNode.assignedConjuncts_

protected

Definition at line 99 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.getAssignedConjuncts(), com.cloudera.impala.planner.CrossJoinNode.init(), com.cloudera.impala.planner.HdfsScanNode.init(), com.cloudera.impala.planner.HashJoinNode.init(), and com.cloudera.impala.planner.PlanNode.setAssignedConjuncts().

float com.cloudera.impala.planner.PlanNode.avgRowSize_

protected

Definition at line 110 of file PlanNode.java.

long com.cloudera.impala.planner.PlanNode.cardinality_

protected

Definition at line 103 of file PlanNode.java.

List<Expr> com.cloudera.impala.planner.PlanNode.conjuncts_ = Lists.newArrayList()

protected

Definition at line 86 of file PlanNode.java.

final int com.cloudera.impala.planner.PlanNode.DEFAULT_BATCH_SIZE = 1024

staticprotected

Definition at line 63 of file PlanNode.java.

String com.cloudera.impala.planner.PlanNode.displayName_

protected

Definition at line 66 of file PlanNode.java.

PlanFragment com.cloudera.impala.planner.PlanNode.fragment_

protected

Definition at line 90 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.AnalyticEvalNode.computeCosts(), com.cloudera.impala.planner.AggregationNode.computeCosts(), com.cloudera.impala.planner.ExchangeNode.getDisplayLabelDetail(), com.cloudera.impala.planner.PlanNode.getFragment(), com.cloudera.impala.planner.HdfsScanNode.getNodeExplainString(), com.cloudera.impala.planner.UnionNode.reorderOperands(), and com.cloudera.impala.planner.PlanNode.setFragment().

PlanNodeId com.cloudera.impala.planner.PlanNode.id_

protected

Definition at line 69 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.getId(), com.cloudera.impala.planner.PlanNode.PlanNode(), and com.cloudera.impala.planner.PlanNode.setId().

long com.cloudera.impala.planner.PlanNode.limit_

protected

Definition at line 71 of file PlanNode.java.

final Logger com.cloudera.impala.planner.PlanNode.LOG = LoggerFactory.getLogger(PlanNode.class)

staticprivate

Definition at line 60 of file PlanNode.java.

Set<TupleId> com.cloudera.impala.planner.PlanNode.nullableTupleIds_ = Sets.newHashSet()

protected

Definition at line 84 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.ExchangeNode.addChild(), com.cloudera.impala.planner.PlanNode.getNullableTupleIds(), and com.cloudera.impala.planner.PlanNode.PlanNode().

int com.cloudera.impala.planner.PlanNode.numNodes_

protected

Definition at line 107 of file PlanNode.java.

ExprSubstitutionMap com.cloudera.impala.planner.PlanNode.outputSmap_

protected

Definition at line 93 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.createDefaultSmap(), com.cloudera.impala.planner.PlanNode.getOutputSmap(), com.cloudera.impala.planner.SortNode.init(), com.cloudera.impala.planner.AggregationNode.init(), com.cloudera.impala.planner.AnalyticEvalNode.init(), and com.cloudera.impala.planner.PlanNode.setOutputSmap().

long com.cloudera.impala.planner.PlanNode.perHostMemCost_ = -1

protected

Definition at line 114 of file PlanNode.java.

ArrayList<TupleId> com.cloudera.impala.planner.PlanNode.tblRefIds_

protected

Definition at line 79 of file PlanNode.java.

Referenced by com.cloudera.impala.planner.PlanNode.getTblRefIds(), com.cloudera.impala.planner.PlanNode.PlanNode(), and com.cloudera.impala.planner.PlanNode.setTblRefIds().

ArrayList<TupleId> com.cloudera.impala.planner.PlanNode.tupleIds_

protected

Definition at line 74 of file PlanNode.java.

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

fe/src/main/java/com/cloudera/impala/planner/PlanNode.java

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Static Protected Attributes

Private Member Functions

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation