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

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

Public Member Functions
	TableRef (List< String > path, String alias)

void	analyze (Analyzer analyzer) throws AnalysisException

TupleDescriptor	createTupleDescriptor (Analyzer analyzer) throws AnalysisException

JoinOperator	getJoinOp ()

boolean	isChildRef ()

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 ()

TableRef	clone ()

Protected Member Functions
	TableRef (TableRef other)

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 Member Functions
void	analyzeJoinHints (Analyzer analyzer) throws AnalysisException

Private Attributes
boolean	isBroadcastJoin_

boolean	isPartitionedJoin_

Detailed Description

Superclass of all table references, including references to views, base tables (Hdfs, HBase or DataSource tables), and nested collections. Contains the join specification. An instance of a TableRef (and not a subclass thereof) represents an unresolved table reference that must be resolved during analysis. All resolved table references are subclasses of TableRef. TODO: Rename this class to CollectionRef and re-consider the naming of all subclasses.

Definition at line 45 of file TableRef.java.

Constructor & Destructor Documentation

com.cloudera.impala.analysis.TableRef.TableRef	(	List< String >	path,
		String	alias
	)

inline

Definition at line 85 of file TableRef.java.

References com.cloudera.impala.analysis.TableRef.aliases_, com.cloudera.impala.analysis.TableRef.hasExplicitAlias_, com.cloudera.impala.analysis.TableRef.isAnalyzed_, path(), and com.cloudera.impala.analysis.TableRef.rawPath_.

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

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

inlineprotected

C'tor for cloning.

Definition at line 100 of file TableRef.java.

References com.cloudera.impala.analysis.Expr.clone(), com.cloudera.impala.analysis.TableRef.joinHints_, com.cloudera.impala.analysis.TableRef.onClause_, and com.cloudera.impala.analysis.TableRef.usingColNames_.

Member Function Documentation

void com.cloudera.impala.analysis.TableRef.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 117 of file TableRef.java.

References com.cloudera.impala.catalog.Table.getFullName(), com.cloudera.impala.analysis.TableRef.getPrivilegeRequirement(), com.cloudera.impala.analysis.Path.getRootTable(), com.cloudera.impala.analysis.TableName.getTbl(), com.cloudera.impala.catalog.View.isLocalView(), com.cloudera.impala.analysis.TableRef.rawPath_, com.cloudera.impala.analysis.TableRef.resolvedPath_, and com.cloudera.impala.analysis.Path.PathType.TABLE_REF.

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

inline

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().

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

inlineprivate

Definition at line 303 of file TableRef.java.

References com.cloudera.impala.analysis.JoinOperator.CROSS_JOIN, com.cloudera.impala.analysis.JoinOperator.FULL_OUTER_JOIN, com.cloudera.impala.analysis.TableRef.isBroadcastJoin_, com.cloudera.impala.analysis.TableRef.isPartitionedJoin_, com.cloudera.impala.analysis.TableRef.joinHints_, com.cloudera.impala.analysis.TableRef.joinOp_, com.cloudera.impala.analysis.JoinOperator.RIGHT_ANTI_JOIN, com.cloudera.impala.analysis.JoinOperator.RIGHT_OUTER_JOIN, com.cloudera.impala.analysis.JoinOperator.RIGHT_SEMI_JOIN, and com.cloudera.impala.analysis.JoinOperator.toString().

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

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

inline

Definition at line 502 of file TableRef.java.

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

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

inline

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 ( )

inline

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 ( )

inline

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 ( )

inline

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().

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

inline

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 ( )

inline

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 ( )

inline

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 ( )

inline

Definition at line 233 of file TableRef.java.

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

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

inline

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 ( )

inline

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 ( )

inline

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 ( )

inline

Definition at line 234 of file TableRef.java.

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

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

inline

Definition at line 244 of file TableRef.java.

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

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

inline

Definition at line 199 of file TableRef.java.

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

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

inline

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 ( )

inline

Definition at line 200 of file TableRef.java.

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

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

inline

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 ( )

inline

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 ( )

inline

Definition at line 235 of file TableRef.java.

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

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

inline

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
	)

inline

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_.