Inheritance diagram for com.cloudera.impala.analysis.CollectionTableRef:

Collaboration diagram for com.cloudera.impala.analysis.CollectionTableRef:

Public Member Functions
	CollectionTableRef (TableRef tableRef, Path resolvedPath)

	CollectionTableRef (CollectionTableRef other)

void	analyze (Analyzer analyzer) throws AnalysisException

boolean	isChildRef ()

Expr	getCollectionExpr ()

TableRef	clone ()

TupleDescriptor	createTupleDescriptor (Analyzer analyzer) throws AnalysisException

JoinOperator	getJoinOp ()

List< String >	getPath ()

Path	getResolvedPath ()

String[]	getAliases ()

String	getUniqueAlias ()

boolean	hasExplicitAlias ()

String	getExplicitAlias ()

Table	getTable ()

ArrayList< String >	getJoinHints ()

Expr	getOnClause ()

List< String >	getUsingClause ()

void	setJoinOp (JoinOperator op)

void	setOnClause (Expr e)

void	setUsingClause (List< String > colNames)

TableRef	getLeftTblRef ()

void	setLeftTblRef (TableRef leftTblRef)

void	setJoinHints (ArrayList< String > hints)

boolean	isBroadcastJoin ()

boolean	isPartitionedJoin ()

List< TupleId >	getOnClauseTupleIds ()

boolean	isResolved ()

TupleDescriptor	getDesc ()

TupleId	getId ()

List< TupleId >	getMaterializedTupleIds ()

List< TupleId >	getAllMaterializedTupleIds ()

List< TupleId >	getAllTupleIds ()

void	analyzeJoin (Analyzer analyzer) throws AnalysisException

void	invertJoin (List< Pair< TableRef, PlanNode >> refPlans, Analyzer analyzer)

String	toSql ()

Privilege	getPrivilegeRequirement ()

Protected Member Functions
void	setJoinAttrs (TableRef other)

String	tableRefToSql ()

Protected Attributes
List< String >	rawPath_

Path	resolvedPath_

String[]	aliases_

boolean	hasExplicitAlias_

JoinOperator	joinOp_

ArrayList< String >	joinHints_

Expr	onClause_

List< String >	usingColNames_

TableRef	leftTblRef_

boolean	isAnalyzed_

List< TupleId >	onClauseTupleIds_ = Lists.newArrayList()

TupleDescriptor	desc_

Private Attributes
Expr	collectionExpr_

Detailed Description

Reference to a MAP or ARRAY collection type that implies its flattening during execution.

Definition at line 24 of file CollectionTableRef.java.

Constructor & Destructor Documentation

com.cloudera.impala.analysis.CollectionTableRef.CollectionTableRef	(	TableRef	tableRef,
		Path	resolvedPath
	)

inline

Create a CollectionTableRef for the given collection type from the original unresolved table ref. Sets the explicit alias and the join-related attributes of the new collection table ref from the unresolved table ref.

Definition at line 34 of file CollectionTableRef.java.

References com.cloudera.impala.analysis.TableRef.aliases_, com.cloudera.impala.analysis.TableRef.hasExplicitAlias(), and com.cloudera.impala.analysis.TableRef.resolvedPath_.

Referenced by com.cloudera.impala.analysis.CollectionTableRef.clone().

com.cloudera.impala.analysis.CollectionTableRef.CollectionTableRef ( CollectionTableRef other )

inline

C'tor for cloning.

Definition at line 46 of file CollectionTableRef.java.

References com.cloudera.impala.analysis.Expr.clone(), and com.cloudera.impala.analysis.CollectionTableRef.collectionExpr_.

Member Function Documentation

void com.cloudera.impala.analysis.CollectionTableRef.analyze ( Analyzer analyzer ) throws AnalysisException

inline

Perform semantic analysis of node and all of its children. Throws exception if any errors found.

Parameters

analyzer

Exceptions

AnalysisException

Implements com.cloudera.impala.analysis.ParseNode.

Definition at line 53 of file CollectionTableRef.java.

References com.cloudera.impala.analysis.TableRef.analyzeJoin(), com.cloudera.impala.analysis.CollectionTableRef.collectionExpr_, com.cloudera.impala.analysis.TableRef.desc_, com.cloudera.impala.analysis.TableRef.getPrivilegeRequirement(), com.cloudera.impala.analysis.Path.getRootDesc(), com.cloudera.impala.analysis.TableRef.isAnalyzed_, and com.cloudera.impala.analysis.TableRef.resolvedPath_.

void com.cloudera.impala.analysis.TableRef.analyzeJoin ( Analyzer analyzer ) throws AnalysisException

inlineinherited

Analyze the join clause. The join clause can only be analyzed after the left table has been analyzed and the TupleDescriptor (desc) of this table has been created.

Definition at line 339 of file TableRef.java.

Referenced by com.cloudera.impala.analysis.BaseTableRef.analyze(), com.cloudera.impala.analysis.CollectionTableRef.analyze(), and com.cloudera.impala.analysis.InlineViewRef.analyze().

TableRef com.cloudera.impala.analysis.CollectionTableRef.clone ( )

inline

Definition at line 75 of file CollectionTableRef.java.

References com.cloudera.impala.analysis.CollectionTableRef.CollectionTableRef().

TupleDescriptor com.cloudera.impala.analysis.TableRef.createTupleDescriptor ( Analyzer analyzer ) throws AnalysisException

inlineinherited

Creates and returns a empty TupleDescriptor registered with the analyzer based on the resolvedPath_. This method is called from the analyzer when registering this table reference.

Definition at line 169 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.getUniqueAlias(), and com.cloudera.impala.analysis.TableRef.resolvedPath_.

String [] com.cloudera.impala.analysis.TableRef.getAliases ( )

inlineinherited

Returns all legal aliases of this table ref.

Definition at line 205 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.aliases_.

List<TupleId> com.cloudera.impala.analysis.TableRef.getAllMaterializedTupleIds ( )

inlineinherited

Return the list of tuple ids materialized by the full sequence of table refs up to this one.

Definition at line 278 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.getMaterializedTupleIds(), and com.cloudera.impala.analysis.TableRef.leftTblRef_.

List<TupleId> com.cloudera.impala.analysis.TableRef.getAllTupleIds ( )

inlineinherited

Return the list of tuple ids of the full sequence of table refs up to this one.

Definition at line 292 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.isAnalyzed_, and com.cloudera.impala.analysis.TableRef.leftTblRef_.

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

Expr com.cloudera.impala.analysis.CollectionTableRef.getCollectionExpr ( )

inline

Definition at line 72 of file CollectionTableRef.java.

References com.cloudera.impala.analysis.CollectionTableRef.collectionExpr_.

TupleDescriptor com.cloudera.impala.analysis.TableRef.getDesc ( )

inlineinherited

This method should only be called after the TableRef has been analyzed.

Definition at line 250 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.desc_, and com.cloudera.impala.analysis.TableRef.isAnalyzed_.

Referenced by com.cloudera.impala.analysis.TableRef.analyzeJoin(), com.cloudera.impala.planner.SingleNodePlanner.getHashLookupJoinConjuncts(), and com.cloudera.impala.analysis.StmtRewriter.mergeExpr().

String com.cloudera.impala.analysis.TableRef.getExplicitAlias ( )

inlineinherited

Returns the explicit alias if this table ref has one, null otherwise.

Definition at line 224 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.getUniqueAlias(), and com.cloudera.impala.analysis.TableRef.hasExplicitAlias().

Referenced by com.cloudera.impala.analysis.InlineViewRef.InlineViewRef(), com.cloudera.impala.analysis.BaseTableRef.tableRefToSql(), com.cloudera.impala.analysis.InlineViewRef.tableRefToSql(), and com.cloudera.impala.analysis.TableRef.tableRefToSql().

TupleId com.cloudera.impala.analysis.TableRef.getId ( )

inlineinherited

This method should only be called after the TableRef has been analyzed.

Definition at line 260 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.desc_, and com.cloudera.impala.analysis.TableRef.isAnalyzed_.

Referenced by com.cloudera.impala.analysis.TableRef.analyzeJoin(), com.cloudera.impala.planner.SingleNodePlanner.migrateConjunctsToInlineView(), and com.cloudera.impala.analysis.Analyzer.ValueTransferGraph.partitionValueTransfers().

ArrayList<String> com.cloudera.impala.analysis.TableRef.getJoinHints ( )

inlineinherited

Definition at line 233 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.joinHints_.

JoinOperator com.cloudera.impala.analysis.TableRef.getJoinOp ( )

inlineinherited

Definition at line 188 of file TableRef.java.

References com.cloudera.impala.analysis.JoinOperator.INNER_JOIN, and com.cloudera.impala.analysis.TableRef.joinOp_.

TableRef com.cloudera.impala.analysis.TableRef.getLeftTblRef ( )

inlineinherited

Definition at line 239 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.leftTblRef_.

Referenced by com.cloudera.impala.planner.SingleNodePlanner.createJoinPlan().

List<TupleId> com.cloudera.impala.analysis.TableRef.getMaterializedTupleIds ( )

inlineinherited

Definition at line 267 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.desc_, and com.cloudera.impala.analysis.TableRef.isAnalyzed_.

Referenced by com.cloudera.impala.analysis.TableRef.getAllMaterializedTupleIds().

Expr com.cloudera.impala.analysis.TableRef.getOnClause ( )

inlineinherited

Definition at line 234 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.onClause_.

List<TupleId> com.cloudera.impala.analysis.TableRef.getOnClauseTupleIds ( )

inlineinherited

Definition at line 244 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.onClauseTupleIds_.

List<String> com.cloudera.impala.analysis.TableRef.getPath ( )

inlineinherited

Definition at line 199 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.rawPath_.

Privilege com.cloudera.impala.analysis.TableRef.getPrivilegeRequirement ( )

inlineinherited

Gets the privilege requirement. This is always SELECT for TableRefs.

Definition at line 499 of file TableRef.java.

References com.cloudera.impala.authorization.Privilege.SELECT.

Referenced by com.cloudera.impala.analysis.BaseTableRef.analyze(), com.cloudera.impala.analysis.CollectionTableRef.analyze(), and com.cloudera.impala.analysis.TableRef.analyze().

Path com.cloudera.impala.analysis.TableRef.getResolvedPath ( )

inlineinherited

Definition at line 200 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.resolvedPath_.

Table com.cloudera.impala.analysis.TableRef.getTable ( )

inlineinherited

Definition at line 229 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.resolvedPath_.

Referenced by com.cloudera.impala.analysis.BaseTableRef.BaseTableRef(), and com.cloudera.impala.analysis.BaseTableRef.tableRefToSql().

String com.cloudera.impala.analysis.TableRef.getUniqueAlias ( )

inlineinherited

Returns the explicit alias or the fully-qualified implicit alias. The returned alias is guaranteed to be unique (i.e., column/field references against the alias cannot be ambiguous).

Definition at line 212 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.aliases_.

Referenced by com.cloudera.impala.analysis.InlineViewRef.analyze(), com.cloudera.impala.analysis.TableRef.analyzeJoin(), com.cloudera.impala.planner.SingleNodePlanner.createJoinPlan(), com.cloudera.impala.analysis.TableRef.createTupleDescriptor(), com.cloudera.impala.analysis.InlineViewRef.createTupleDescriptor(), and com.cloudera.impala.analysis.TableRef.getExplicitAlias().

List<String> com.cloudera.impala.analysis.TableRef.getUsingClause ( )

inlineinherited

Definition at line 235 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.usingColNames_.

boolean com.cloudera.impala.analysis.TableRef.hasExplicitAlias ( )

inlineinherited

Returns true if this table ref has an explicit alias. Note that getAliases().length() == 1 does not imply an explicit alias because nested collection refs have only a single implicit alias.

Definition at line 219 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.hasExplicitAlias_.

Referenced by com.cloudera.impala.analysis.BaseTableRef.BaseTableRef(), com.cloudera.impala.analysis.CollectionTableRef.CollectionTableRef(), com.cloudera.impala.analysis.TableRef.getExplicitAlias(), and com.cloudera.impala.analysis.InlineViewRef.InlineViewRef().

void com.cloudera.impala.analysis.TableRef.invertJoin	(	List< Pair< TableRef, PlanNode >>	refPlans,
		Analyzer	analyzer
	)

inlineinherited

Inverts the join whose rhs is represented by this table ref. If necessary, this function modifies the registered analysis state associated with this table ref, as well as the chain of left table references in refPlans as appropriate. Requires that this is the very first join in a series of joins.

Definition at line 447 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.getJoinOp(), com.cloudera.impala.analysis.Analyzer.invertOuterJoinState(), com.cloudera.impala.analysis.JoinOperator.isOuterJoin(), com.cloudera.impala.analysis.TableRef.joinOp_, com.cloudera.impala.analysis.TableRef.leftTblRef_, and com.cloudera.impala.analysis.TableRef.onClause_.