public class ProjectionTranslator extends Object
Constructor and Description |
---|
ProjectionTranslator() |
Modifier and Type | Method and Description |
---|---|
static scala.collection.Seq<Expression> |
expandProjectList(scala.collection.Seq<Expression> exprs,
LogicalNode parent,
TableEnvironment tableEnv)
Expands an UnresolvedFieldReference("*") to parent's full project list.
|
static 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.
|
static scala.collection.Seq<NamedExpression> |
extractFieldReferences(scala.collection.Seq<Expression> exprs)
Extract all field references from the given expressions.
|
static Expression |
replaceAggFunctionCall(Expression field,
TableEnvironment tableEnv)
Find and replace UDAGG function Call to AggFunctionCall
|
static 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.
|
static scala.collection.Seq<Expression> |
resolveOverWindows(scala.collection.Seq<Expression> exprs,
OverWindow[] overWindows,
TableEnvironment tEnv) |
public static 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 static 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 static scala.collection.Seq<Expression> expandProjectList(scala.collection.Seq<Expression> exprs, LogicalNode parent, TableEnvironment tableEnv)
exprs
- (undocumented)parent
- (undocumented)tableEnv
- (undocumented)public static scala.collection.Seq<Expression> resolveOverWindows(scala.collection.Seq<Expression> exprs, OverWindow[] overWindows, TableEnvironment tEnv)
public static scala.collection.Seq<NamedExpression> extractFieldReferences(scala.collection.Seq<Expression> exprs)
exprs
- a list of expressions to extractpublic static Expression replaceAggFunctionCall(Expression field, TableEnvironment tableEnv)
field
- the expression to checktableEnv
- the TableEnvironmentCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.