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

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

Public Member Functions
	ValuesStmt (List< UnionOperand > operands, ArrayList< OrderByElement > orderByElements, LimitElement limitElement)

String	toSql ()

QueryStmt	clone ()

List< UnionOperand >	getOperands ()

List< UnionOperand >	getDistinctOperands ()

boolean	hasDistinctOps ()

List< UnionOperand >	getAllOperands ()

boolean	hasAllOps ()

AggregateInfo	getDistinctAggInfo ()

boolean	hasAnalyticExprs ()

void	removeAllOperands ()

void	analyze (Analyzer analyzer) throws AnalysisException

void	materializeRequiredSlots (Analyzer analyzer) throws InternalException

TupleId	getTupleId ()

void	getMaterializedTupleIds (ArrayList< TupleId > tupleIdList)

ArrayList< String >	getColLabels ()

Analyzer	getAnalyzer ()

void	setWithClause (WithClause withClause)

boolean	hasWithClause ()

WithClause	getWithClause ()

boolean	hasOrderByClause ()

boolean	hasLimit ()

long	getLimit ()

boolean	hasOffset ()

long	getOffset ()

SortInfo	getSortInfo ()

boolean	evaluateOrderBy ()

ArrayList< Expr >	getResultExprs ()

ArrayList< Expr >	getBaseTblResultExprs ()

void	setLimit (long limit) throws AnalysisException

ArrayList< OrderByElement >	cloneOrderByElements ()

WithClause	cloneWithClause ()

void	setIsExplain ()

boolean	isExplain ()

Protected Member Functions
String	queryStmtToSql (QueryStmt queryStmt)

void	createSortInfo (Analyzer analyzer) throws AnalysisException

void	createSortTupleInfo (Analyzer analyzer)

Expr	getFirstAmbiguousAlias (List< Expr > exprs)

void	substituteOrdinals (List< Expr > exprs, String errorPrefix, Analyzer analyzer) throws AnalysisException

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

Protected Attributes
final List< UnionOperand >	operands_

final List< UnionOperand >	distinctOperands_ = Lists.newArrayList()

final List< UnionOperand >	allOperands_ = Lists.newArrayList()

AggregateInfo	distinctAggInfo_

TupleId	tupleId_

String	toSqlString_ = null

WithClause	withClause_

ArrayList< OrderByElement >	orderByElements_

LimitElement	limitElement_

ArrayList< Expr >	resultExprs_ = Lists.newArrayList()

ArrayList< Expr >	baseTblResultExprs_ = Lists.newArrayList()

final ExprSubstitutionMap	aliasSmap_ = new ExprSubstitutionMap()

final ArrayList< Expr >	ambiguousAliasList_ = Lists.newArrayList()

SortInfo	sortInfo_

boolean	evaluateOrderBy_

Analyzer	analyzer_

boolean	isExplain_ = false

Private Member Functions
void	appendSelectList (SelectStmt select, StringBuilder strBuilder)

Detailed Description

Representation of a values() statement with a list of constant-expression lists. ValuesStmt is a special case of a UnionStmt with the following restrictions:

Operands are only constant selects
Operands are connected by UNION ALL
No nesting of ValuesStmts

Definition at line 30 of file ValuesStmt.java.

Constructor & Destructor Documentation

com.cloudera.impala.analysis.ValuesStmt.ValuesStmt	(	List< UnionOperand >	operands,
		ArrayList< OrderByElement >	orderByElements,
		LimitElement	limitElement
	)

inline

Definition at line 32 of file ValuesStmt.java.

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

Member Function Documentation

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

inlineinherited

Propagates DISTINCT from left to right, and checks that all union operands are union compatible, adding implicit casts if necessary.

Implements com.cloudera.impala.analysis.ParseNode.

Definition at line 149 of file UnionStmt.java.

void com.cloudera.impala.analysis.ValuesStmt.appendSelectList	(	SelectStmt	select,
		StringBuilder	strBuilder
	)

inlineprivate

Definition at line 67 of file ValuesStmt.java.

Referenced by com.cloudera.impala.analysis.ValuesStmt.queryStmtToSql(), and com.cloudera.impala.analysis.ValuesStmt.toSql().

QueryStmt com.cloudera.impala.analysis.ValuesStmt.clone ( )

inline

Definition at line 76 of file ValuesStmt.java.

References com.cloudera.impala.analysis.LimitElement.clone(), com.cloudera.impala.analysis.QueryStmt.cloneOrderByElements(), com.cloudera.impala.analysis.QueryStmt.cloneWithClause(), com.cloudera.impala.analysis.QueryStmt.limitElement_, com.cloudera.impala.analysis.UnionStmt.operands_, and com.cloudera.impala.analysis.ValuesStmt.ValuesStmt().

ArrayList<OrderByElement> com.cloudera.impala.analysis.QueryStmt.cloneOrderByElements ( )

inlineinherited

Definition at line 311 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.orderByElements_.

Referenced by com.cloudera.impala.analysis.ValuesStmt.clone(), com.cloudera.impala.analysis.UnionStmt.clone(), and com.cloudera.impala.analysis.SelectStmt.clone().

WithClause com.cloudera.impala.analysis.QueryStmt.cloneWithClause ( )

inlineinherited

Definition at line 315 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.withClause_.

Referenced by com.cloudera.impala.analysis.ValuesStmt.clone(), com.cloudera.impala.analysis.UnionStmt.clone(), and com.cloudera.impala.analysis.SelectStmt.clone().

void com.cloudera.impala.analysis.QueryStmt.createSortInfo ( Analyzer analyzer ) throws AnalysisException

inlineprotectedinherited

Creates sortInfo by resolving aliases and ordinals in the orderingExprs. If the query stmt is an inline view/union operand, then order-by with no limit with offset is not allowed, since that requires a sort and merging-exchange, and subsequent query execution would occur on a single machine. Sets evaluateOrderBy_ to false for ignored order-by w/o limit/offset in nested queries.

Definition at line 115 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.SelectStmt.analyze(), and com.cloudera.impala.analysis.UnionStmt.analyze().

void com.cloudera.impala.analysis.QueryStmt.createSortTupleInfo ( Analyzer analyzer )

inlineprotectedinherited

Create a tuple descriptor for the single tuple that is materialized, sorted and output by the exec node implementing the sort. Done by materializing slot refs in the order-by and result expressions. Those SlotRefs in the ordering and result exprs are substituted with SlotRefs into the new tuple. This simplifies sorting logic for total (no limit) sorts. Done after analyzeAggregation() since ordering and result exprs may refer to the outputs of aggregation. Invoked for UnionStmt as well since TODO: We could do something more sophisticated than simply copying input slotrefs - e.g. compute some order-by expressions.

Definition at line 185 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.evaluateOrderBy_, and com.cloudera.impala.analysis.QueryStmt.resultExprs_.

Referenced by com.cloudera.impala.analysis.SelectStmt.analyze(), and com.cloudera.impala.analysis.UnionStmt.analyze().

boolean com.cloudera.impala.analysis.QueryStmt.evaluateOrderBy ( )

inlineinherited

Definition at line 278 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.evaluateOrderBy_.

List<UnionOperand> com.cloudera.impala.analysis.UnionStmt.getAllOperands ( )

inlineinherited

Definition at line 134 of file UnionStmt.java.

References com.cloudera.impala.analysis.UnionStmt.allOperands_.

Analyzer com.cloudera.impala.analysis.QueryStmt.getAnalyzer ( )

inlineinherited

Definition at line 83 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.analyzer_.

Referenced by com.cloudera.impala.planner.SingleNodePlanner.createInlineViewPlan(), and com.cloudera.impala.analysis.StmtRewriter.rewrite().

ArrayList<Expr> com.cloudera.impala.analysis.QueryStmt.getBaseTblResultExprs ( )

inlineinherited

Definition at line 280 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.baseTblResultExprs_.

Referenced by com.cloudera.impala.analysis.CreateOrAlterViewStmtBase.createColumnAndViewDefs(), com.cloudera.impala.analysis.UnionStmt.createMetadata(), com.cloudera.impala.planner.SingleNodePlanner.createSingleNodePlan(), and com.cloudera.impala.analysis.UnionStmt.materializeRequiredSlots().

ArrayList<String> com.cloudera.impala.analysis.UnionStmt.getColLabels ( )

inlineinherited

Definition at line 523 of file UnionStmt.java.

Referenced by com.cloudera.impala.analysis.UnionStmt.createMetadata().

AggregateInfo com.cloudera.impala.analysis.UnionStmt.getDistinctAggInfo ( )

inlineinherited

Definition at line 136 of file UnionStmt.java.

References com.cloudera.impala.analysis.UnionStmt.distinctAggInfo_.

List<UnionOperand> com.cloudera.impala.analysis.UnionStmt.getDistinctOperands ( )

inlineinherited

Definition at line 132 of file UnionStmt.java.

References com.cloudera.impala.analysis.UnionStmt.distinctOperands_.

Expr com.cloudera.impala.analysis.QueryStmt.getFirstAmbiguousAlias ( List< Expr > exprs )

inlineprotectedinherited

Return the first expr in exprs that is a non-unique alias. Return null if none of exprs is an ambiguous alias.

Definition at line 219 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.ambiguousAliasList_.

Referenced by com.cloudera.impala.analysis.SelectStmt.analyzeAggregation(), and com.cloudera.impala.analysis.QueryStmt.createSortInfo().

long com.cloudera.impala.analysis.QueryStmt.getLimit ( )

inlineinherited

Definition at line 274 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.QueryStmt.setLimit().

void com.cloudera.impala.analysis.UnionStmt.getMaterializedTupleIds ( ArrayList< TupleId > tupleIdList )

inlineinherited

Definition at line 462 of file UnionStmt.java.

References com.cloudera.impala.analysis.QueryStmt.evaluateOrderBy_, and com.cloudera.impala.analysis.UnionStmt.tupleId_.

long com.cloudera.impala.analysis.QueryStmt.getOffset ( )

inlineinherited

Definition at line 276 of file QueryStmt.java.

List<UnionOperand> com.cloudera.impala.analysis.UnionStmt.getOperands ( )

inlineinherited

Definition at line 131 of file UnionStmt.java.

References com.cloudera.impala.analysis.UnionStmt.operands_.

ArrayList<Expr> com.cloudera.impala.analysis.QueryStmt.getResultExprs ( )

inlineinherited

Definition at line 279 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.resultExprs_.

Referenced by com.cloudera.impala.analysis.UnionStmt.setOperandSmap(), com.cloudera.impala.analysis.AnalyzeStmtsTest.testSlotRefPath(), and com.cloudera.impala.analysis.AnalyzeStmtsTest.TestStar().

SortInfo com.cloudera.impala.analysis.QueryStmt.getSortInfo ( )

inlineinherited

Definition at line 277 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.sortInfo_.

TupleId com.cloudera.impala.analysis.UnionStmt.getTupleId ( )

inlineinherited

Definition at line 459 of file UnionStmt.java.

References com.cloudera.impala.analysis.UnionStmt.tupleId_.

WithClause com.cloudera.impala.analysis.QueryStmt.getWithClause ( )

inlineinherited

Definition at line 271 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.withClause_.

boolean com.cloudera.impala.analysis.UnionStmt.hasAllOps ( )

inlineinherited

Definition at line 135 of file UnionStmt.java.

boolean com.cloudera.impala.analysis.UnionStmt.hasAnalyticExprs ( )

inlineinherited

Definition at line 137 of file UnionStmt.java.

References com.cloudera.impala.analysis.UnionStmt.hasAnalyticExprs_.

boolean com.cloudera.impala.analysis.UnionStmt.hasDistinctOps ( )

inlineinherited

Definition at line 133 of file UnionStmt.java.

boolean com.cloudera.impala.analysis.QueryStmt.hasLimit ( )

inlineinherited

Definition at line 273 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.SelectStmt.analyze(), com.cloudera.impala.analysis.StmtRewriter.canRewriteCorrelatedSubquery(), com.cloudera.impala.analysis.QueryStmt.createSortInfo(), com.cloudera.impala.analysis.QueryStmt.setLimit(), and com.cloudera.impala.analysis.UnionStmt.toSql().

boolean com.cloudera.impala.analysis.QueryStmt.hasOffset ( )

inlineinherited

Definition at line 275 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.QueryStmt.createSortInfo(), and com.cloudera.impala.analysis.UnionStmt.toSql().

boolean com.cloudera.impala.analysis.QueryStmt.hasOrderByClause ( )

inlineinherited

Definition at line 272 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.orderByElements_.

Referenced by com.cloudera.impala.analysis.QueryStmt.analyzeLimit(), and com.cloudera.impala.analysis.UnionStmt.toSql().

boolean com.cloudera.impala.analysis.QueryStmt.hasWithClause ( )

inlineinherited

Definition at line 270 of file QueryStmt.java.

References com.cloudera.impala.analysis.QueryStmt.withClause_.

Referenced by com.cloudera.impala.analysis.QueryStmt.analyze().

boolean com.cloudera.impala.analysis.StatementBase.isExplain ( )

inlineinherited

Definition at line 43 of file StatementBase.java.

References com.cloudera.impala.analysis.StatementBase.isExplain_.

void com.cloudera.impala.analysis.UnionStmt.materializeRequiredSlots ( Analyzer analyzer ) throws InternalException

inlineinherited

Marks the baseTblResultExprs of its operands as materialized, based on which of the output slots have been marked. Calls materializeRequiredSlots() on the operands themselves.

Definition at line 221 of file UnionStmt.java.

void com.cloudera.impala.analysis.QueryStmt.materializeSlots	(	Analyzer	analyzer,
		List< Expr >	exprs
	)

inlineprotectedinherited

Mark slots referenced in exprs as materialized.

Definition at line 303 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.UnionStmt.materializeRequiredSlots(), and com.cloudera.impala.analysis.SelectStmt.materializeRequiredSlots().

String com.cloudera.impala.analysis.ValuesStmt.queryStmtToSql ( QueryStmt queryStmt )

inlineprotected

Definition at line 38 of file ValuesStmt.java.

References com.cloudera.impala.analysis.ValuesStmt.appendSelectList().

void com.cloudera.impala.analysis.UnionStmt.removeAllOperands ( )

inlineinherited

Definition at line 139 of file UnionStmt.java.

References com.cloudera.impala.analysis.UnionStmt.allOperands_.

void com.cloudera.impala.analysis.StatementBase.setIsExplain ( )

inlineinherited

Definition at line 42 of file StatementBase.java.

References com.cloudera.impala.analysis.StatementBase.isExplain_.

void com.cloudera.impala.analysis.QueryStmt.setLimit ( long limit ) throws AnalysisException

inlineinherited

Definition at line 281 of file QueryStmt.java.

References com.cloudera.impala.catalog.Type.BIGINT, com.cloudera.impala.analysis.QueryStmt.getLimit(), com.cloudera.impala.analysis.QueryStmt.hasLimit(), and com.cloudera.impala.analysis.QueryStmt.limitElement_.

Referenced by com.cloudera.impala.analysis.StmtRewriter.mergeExpr().

void com.cloudera.impala.analysis.QueryStmt.setWithClause ( WithClause withClause )

inlineinherited

Definition at line 269 of file QueryStmt.java.

void com.cloudera.impala.analysis.QueryStmt.substituteOrdinals	(	List< Expr >	exprs,
		String	errorPrefix,
		Analyzer	analyzer
	)		throws AnalysisException

inlineprotectedinherited

Substitute exprs of the form "<number>" with the corresponding expressions.

Definition at line 230 of file QueryStmt.java.

References com.cloudera.impala.analysis.Expr.getType(), com.cloudera.impala.analysis.QueryStmt.resultExprs_, and com.cloudera.impala.analysis.Expr.toSql().

Referenced by com.cloudera.impala.analysis.SelectStmt.analyzeAggregation(), and com.cloudera.impala.analysis.QueryStmt.createSortInfo().

String com.cloudera.impala.analysis.ValuesStmt.toSql ( )

inline

Returns: SQL syntax corresponding to this node.

Implements com.cloudera.impala.analysis.ParseNode.

Definition at line 47 of file ValuesStmt.java.

References com.cloudera.impala.analysis.ValuesStmt.appendSelectList(), com.cloudera.impala.analysis.UnionStmt.operands_, and com.cloudera.impala.analysis.QueryStmt.withClause_.

Member Data Documentation

final ExprSubstitutionMap com.cloudera.impala.analysis.QueryStmt.aliasSmap_ = new ExprSubstitutionMap()

protectedinherited

Map of expression substitutions for replacing aliases in "order by" or "group by" clauses with their corresponding result expr.

Definition at line 62 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.SelectStmt.analyzeAggregation(), com.cloudera.impala.analysis.UnionStmt.createMetadata(), and com.cloudera.impala.analysis.QueryStmt.createSortInfo().

final List<UnionOperand> com.cloudera.impala.analysis.UnionStmt.allOperands_ = Lists.newArrayList()

protectedinherited

Definition at line 112 of file UnionStmt.java.

Referenced by com.cloudera.impala.analysis.UnionStmt.getAllOperands(), com.cloudera.impala.analysis.UnionStmt.removeAllOperands(), and com.cloudera.impala.analysis.UnionStmt.unnestOperands().

final ArrayList<Expr> com.cloudera.impala.analysis.QueryStmt.ambiguousAliasList_ = Lists.newArrayList()

protectedinherited

Select list item alias does not have to be unique. This list contains all the non-unique aliases. For example, select int_col a, string_col a from alltypessmall; Both columns are using the same alias "a".

Definition at line 70 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.QueryStmt.getFirstAmbiguousAlias().

Analyzer com.cloudera.impala.analysis.QueryStmt.analyzer_

protectedinherited

Definition at line 81 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.QueryStmt.getAnalyzer(), and com.cloudera.impala.analysis.SelectStmt.getTableAliasGenerator().

ArrayList<Expr> com.cloudera.impala.analysis.QueryStmt.baseTblResultExprs_ = Lists.newArrayList()

protectedinherited

Definition at line 56 of file QueryStmt.java.

Referenced by com.cloudera.impala.analysis.UnionStmt.analyze(), com.cloudera.impala.analysis.UnionStmt.createMetadata(), com.cloudera.impala.analysis.QueryStmt.getBaseTblResultExprs(), and com.cloudera.impala.analysis.SelectStmt.resolveInlineViewRefs().