public class ProjectionTranslator$ extends Object
Modifier and Type | Field and Description |
---|---|
static ProjectionTranslator$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
ProjectionTranslator$() |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Expression> |
expandProjectList(scala.collection.Seq<Expression> exprs,
LogicalNode parent,
TableEnvironment tableEnv)
Expands an UnresolvedFieldReference("*") to parent's full project list.
|
scala.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> |
extractAggregationsAndProperties(scala.collection.Seq<Expression> exprs,
TableEnvironment tableEnv)
Extracts and deduplicates all aggregation and window property expressions (zero, one, or more)
from the given expressions.
|
scala.collection.Seq<NamedExpression> |
extractFieldReferences(scala.collection.Seq<Expression> exprs)
Extract all field references from the given expressions.
|
scala.collection.Seq<NamedExpression> |
replaceAggregationsAndProperties(scala.collection.Seq<Expression> exprs,
TableEnvironment tableEnv,
scala.collection.immutable.Map<Expression,String> aggNames,
scala.collection.immutable.Map<Expression,String> propNames)
Replaces expressions with deduplicated aggregations and properties.
|
public static final ProjectionTranslator$ MODULE$
public scala.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> extractAggregationsAndProperties(scala.collection.Seq<Expression> exprs, TableEnvironment tableEnv)
exprs
- a list of expressions to extracttableEnv
- the TableEnvironmentpublic scala.collection.Seq<NamedExpression> replaceAggregationsAndProperties(scala.collection.Seq<Expression> exprs, TableEnvironment tableEnv, scala.collection.immutable.Map<Expression,String> aggNames, scala.collection.immutable.Map<Expression,String> propNames)
exprs
- a list of expressions to replacetableEnv
- the TableEnvironmentaggNames
- the deduplicated aggregationspropNames
- the deduplicated propertiespublic scala.collection.Seq<Expression> expandProjectList(scala.collection.Seq<Expression> exprs, LogicalNode parent, TableEnvironment tableEnv)
public scala.collection.Seq<NamedExpression> extractFieldReferences(scala.collection.Seq<Expression> exprs)
exprs
- a list of expressions to extractCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.