Modifier and Type | Method and Description |
---|---|
Expression |
ImplicitExpressionConversions.boolean2Literal(boolean bool) |
Expression |
ImplicitExpressionConversions.byte2Literal(byte b) |
Expression |
ImplicitExpressionConversions.double2Literal(double d) |
Expression |
ImplicitExpressionConversions.WithOperations.expr() |
Expression |
ImplicitExpressionOperations.expr() |
Expression |
ImplicitExpressionConversions.float2Literal(float d) |
Expression |
ImplicitExpressionConversions.int2Literal(int i) |
Expression |
ImplicitExpressionConversions.javaDec2Literal(BigDecimal javaDec) |
Expression |
ImplicitExpressionConversions.long2Literal(long l) |
Expression |
ImplicitExpressionConversions.scalaDec2Literal(scala.math.BigDecimal scalaDec) |
Expression |
ImplicitExpressionConversions.short2Literal(short s) |
Expression |
ImplicitExpressionConversions.sqlDate2Literal(Date sqlDate) |
Expression |
ImplicitExpressionConversions.sqlTime2Literal(Time sqlTime) |
Expression |
ImplicitExpressionConversions.sqlTimestamp2Literal(Timestamp sqlTimestamp) |
Expression |
ImplicitExpressionConversions.string2Literal(String str) |
Expression |
ImplicitExpressionConversions.symbol2FieldExpression(scala.Symbol sym) |
Expression |
ImplicitExpressionOperations.toExpr()
Enables literals on left side of binary expressions.
|
Expression |
ImplicitExpressionOperations.trim(boolean removeLeading,
boolean removeTrailing,
Expression character)
Removes leading and/or trailing characters from the given string.
|
Modifier and Type | Method and Description |
---|---|
Like |
ImplicitExpressionOperations.like(Expression pattern)
Returns true, if a String matches the specified LIKE pattern.
|
Mod |
ImplicitExpressionOperations.mod(Expression other)
Calculates the remainder of division the given number by another one.
|
Power |
ImplicitExpressionOperations.power(Expression other)
Calculates the given number raised to the power of the other value.
|
Similar |
ImplicitExpressionOperations.similar(Expression pattern)
Returns true, if a String matches the specified SQL regex pattern.
|
SubString |
ImplicitExpressionOperations.substring(Expression beginIndex)
Creates a substring of the given string beginning at the given index to the end.
|
SubString |
ImplicitExpressionOperations.substring(Expression beginIndex,
Expression endIndex)
Creates a substring of the given string between the given indices.
|
Expression |
ImplicitExpressionOperations.trim(boolean removeLeading,
boolean removeTrailing,
Expression character)
Removes leading and/or trailing characters from the given string.
|
Modifier and Type | Method and Description |
---|---|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet,
scala.collection.Seq<Expression> fields)
Converts the given
DataSet into a Table with specified field names. |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream,
scala.collection.Seq<Expression> fields)
Converts the given
DataStream into a Table with specified field names. |
<T> void |
BatchTableEnvironment.registerDataSet(String name,
DataSet<T> dataSet,
scala.collection.Seq<Expression> fields)
Registers the given
DataSet as table with specified field names in the
TableEnvironment 's catalog. |
<T> void |
StreamTableEnvironment.registerDataStream(String name,
DataStream<T> dataStream,
scala.collection.Seq<Expression> fields)
Registers the given
DataStream as table with specified field names in the
TableEnvironment 's catalog. |
Table |
DataSetConversions.toTable(BatchTableEnvironment tableEnv,
scala.collection.Seq<Expression> fields)
Converts the
DataSet into a Table . |
Table |
DataStreamConversions.toTable(StreamTableEnvironment tableEnv,
scala.collection.Seq<Expression> fields)
Converts the
DataStream into a Table . |
Constructor and Description |
---|
WithOperations(Expression e) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Expression> |
GroupedTable.groupKey() |
Modifier and Type | Method and Description |
---|---|
Table |
Table.filter(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.fullOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
protected <A> scala.Tuple2<String[],int[]> |
TableEnvironment.getFieldInfo(TypeInformation<A> inputType,
Expression[] exprs)
Returns field names and field positions for a given
TypeInformation and Array of
Expression . |
Table |
Table.join(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
protected <T> void |
BatchTableEnvironment.registerDataSetInternal(String name,
DataSet<T> dataSet,
Expression[] fields)
Registers a
DataSet as a table under a given name with field names as specified by
field expressions in the TableEnvironment 's catalog. |
protected <T> void |
StreamTableEnvironment.registerDataStreamInternal(String name,
DataStream<T> dataStream,
Expression[] fields,
boolean wrapper)
Registers a
DataStream as a table under a given name with field names as specified by
field expressions in the TableEnvironment 's catalog. |
Table |
Table.rightOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.where(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Modifier and Type | Method and Description |
---|---|
Table |
Table.as(scala.collection.Seq<Expression> fields)
Renames the fields of the expression result.
|
GroupedTable |
Table.groupBy(scala.collection.Seq<Expression> fields)
Groups the elements on some grouping keys.
|
Table |
Table.orderBy(scala.collection.Seq<Expression> fields)
Sorts the given
Table . |
Table |
Table.select(scala.collection.Seq<Expression> fields)
Performs a selection operation.
|
Table |
GroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a grouped table.
|
Constructor and Description |
---|
GroupedTable(Table table,
scala.collection.Seq<Expression> groupKey) |
Modifier and Type | Class and Description |
---|---|
class |
Abs |
class |
Aggregation |
class |
Alias |
class |
And |
class |
Asc |
class |
Attribute |
class |
Avg |
class |
BinaryArithmetic |
class |
BinaryComparison |
class |
BinaryExpression |
class |
BinaryPredicate |
class |
Call
General expression for unresolved function calls.
|
class |
Cast |
class |
Ceil |
class |
CharLength
Returns the length of this
str . |
class |
Count |
class |
Desc |
class |
Div |
class |
EqualTo |
class |
Exp |
class |
Floor |
class |
GreaterThan |
class |
GreaterThanOrEqual |
class |
If |
class |
InitCap
Returns str with the first letter of each word in uppercase.
|
class |
IsNotNull |
class |
IsNull |
class |
LeafExpression |
class |
LessThan |
class |
LessThanOrEqual |
class |
Like
Returns true if
str matches pattern . |
class |
Literal |
class |
Ln |
class |
Log10 |
class |
Lower
Returns str with all characters changed to lowercase.
|
class |
Max |
class |
Min |
class |
Minus |
class |
Mod |
class |
Mul |
class |
Not |
class |
NotEqualTo |
class |
Null |
class |
Or |
class |
Ordering |
class |
Plus |
class |
Power |
class |
ResolvedFieldReference |
class |
Similar
Returns true if
str is similar to pattern . |
class |
SubString
Returns subString of
str from begin (inclusive) to end (not inclusive). |
class |
Sum |
class |
Trim
Trim
trimString from str according to trimFlag :
0 for TRIM_BOTH, 1 for TRIM_LEADING and 2 for TRIM_TRAILING. |
class |
UnaryExpression |
class |
UnaryMinus |
class |
UnresolvedAlias |
class |
UnresolvedFieldReference |
class |
Upper
Returns str with all characters changed to uppercase.
|
Modifier and Type | Method and Description |
---|---|
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.alias() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.alias() |
scala.collection.Seq<Expression> |
Call.args() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.atom() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.atom() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.boolLiteral() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.boolLiteral() |
scala.collection.Seq<Expression> |
If.children() |
scala.collection.Seq<Expression> |
UnaryExpression.children() |
scala.collection.Seq<Expression> |
SubString.children() |
scala.collection.Seq<Expression> |
Call.children() |
scala.collection.Seq<Expression> |
Trim.children() |
scala.collection.Seq<Expression> |
BinaryExpression.children() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.comparison() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.comparison() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.composite() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.composite() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.equalTo() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.equalTo() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.expression() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.expression() |
static scala.util.parsing.combinator.Parsers.Parser<scala.collection.immutable.List<Expression>> |
ExpressionParser.expressionList() |
scala.util.parsing.combinator.Parsers.Parser<scala.collection.immutable.List<Expression>> |
ExpressionParser$.expressionList() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.greaterThan() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.greaterThan() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.greaterThanOrEqual() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.greaterThanOrEqual() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.lessThan() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.lessThan() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.lessThanOrEqual() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.lessThanOrEqual() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.literalExpr() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.literalExpr() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.logic() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.logic() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.notEqualTo() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.notEqualTo() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.nullLiteral() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.nullLiteral() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.numberLiteral() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.numberLiteral() |
static scala.collection.immutable.List<Expression> |
ExpressionParser.parseExpressionList(String expression) |
scala.collection.immutable.List<Expression> |
ExpressionParser$.parseExpressionList(String expression) |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixAs() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixAs() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixAvg() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixAvg() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixCast() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixCast() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixCount() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixCount() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixed() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixed() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixIf() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixIf() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixIsNotNull() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixIsNotNull() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixIsNull() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixIsNull() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixMax() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixMax() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixMin() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixMin() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixSum() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixSum() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.product() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.product() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.singleQuoteStringLiteral() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.singleQuoteStringLiteral() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.stringLiteralFlink() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.stringLiteralFlink() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixAs() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixAs() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixAsc() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixAsc() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixAvg() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixAvg() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixCast() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixCast() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixCount() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixCount() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixDesc() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixDesc() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixed() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixed() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixIf() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixIf() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixIsNotNull() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixIsNotNull() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixIsNull() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixIsNull() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixMax() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixMax() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixMin() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixMin() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixSum() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixSum() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixToDate() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixToDate() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixToTime() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixToTime() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixToTimestamp() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixToTimestamp() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.term() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.term() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.unary() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.unary() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryMinus() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryMinus() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryNot() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryNot() |
Modifier and Type | Method and Description |
---|---|
boolean |
Expression.checkEquals(Expression other) |
Constructor and Description |
---|
Call(String functionName,
scala.collection.Seq<Expression> args) |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple2<Expression,scala.collection.immutable.List<NamedExpression>> |
RexNodeTranslator.extractAggregations(Expression exp,
TableEnvironment tableEnv)
Extracts all aggregation expressions (zero, one, or more) from an expression,
and replaces the original aggregation expressions by field accesses expressions.
|
scala.Tuple2<Expression,scala.collection.immutable.List<NamedExpression>> |
RexNodeTranslator$.extractAggregations(Expression exp,
TableEnvironment tableEnv)
Extracts all aggregation expressions (zero, one, or more) from an expression,
and replaces the original aggregation expressions by field accesses expressions.
|
Modifier and Type | Method and Description |
---|---|
static scala.Tuple2<Expression,scala.collection.immutable.List<NamedExpression>> |
RexNodeTranslator.extractAggregations(Expression exp,
TableEnvironment tableEnv)
Extracts all aggregation expressions (zero, one, or more) from an expression,
and replaces the original aggregation expressions by field accesses expressions.
|
scala.Tuple2<Expression,scala.collection.immutable.List<NamedExpression>> |
RexNodeTranslator$.extractAggregations(Expression exp,
TableEnvironment tableEnv)
Extracts all aggregation expressions (zero, one, or more) from an expression,
and replaces the original aggregation expressions by field accesses expressions.
|
Modifier and Type | Method and Description |
---|---|
Expression |
Filter.condition() |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Expression> |
AliasNode.aliasList() |
scala.Option<Expression> |
Join.condition() |
scala.collection.Seq<Expression> |
Aggregate.groupingExpressions() |
Modifier and Type | Method and Description |
---|---|
LogicalNode |
LogicalNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule)
Runs
postOrderTransform with rule on all expressions present in this logical node. |
LogicalNode |
LogicalNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule)
Runs
postOrderTransform with rule on all expressions present in this logical node. |
Constructor and Description |
---|
Filter(Expression condition,
LogicalNode child) |
Constructor and Description |
---|
Aggregate(scala.collection.Seq<Expression> groupingExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
AliasNode(scala.collection.Seq<Expression> aliasList,
LogicalNode child) |
Join(LogicalNode left,
LogicalNode right,
JoinType joinType,
scala.Option<Expression> condition) |
Modifier and Type | Method and Description |
---|---|
Expression |
FunctionCatalog.lookupFunction(String name,
scala.collection.Seq<Expression> children)
Lookup and create an expression if we find a match.
|
Modifier and Type | Method and Description |
---|---|
Expression |
FunctionCatalog.lookupFunction(String name,
scala.collection.Seq<Expression> children)
Lookup and create an expression if we find a match.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.