Modifier and Type | Method and Description |
---|---|
Expression |
EventTimeWindow.timeField() |
Modifier and Type | Method and Description |
---|---|
scala.Option<Expression> |
Window.alias() |
scala.collection.Seq<Expression> |
GroupedTable.groupKey() |
scala.collection.Seq<Expression> |
WindowGroupedTable.groupKeys() |
Modifier and Type | Method and Description |
---|---|
Window |
Window.as(Expression alias)
Assigns an alias for this window that the following
groupBy() and select() clause can
refer to. |
SlidingWindow |
SlideWithSize.every(Expression slide)
Specifies the window's slide as time or row-count interval.
|
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 . |
protected <A> scala.Tuple2<String[],int[]> |
StreamTableEnvironment.getFieldInfo(TypeInformation<A> inputType,
Expression[] exprs)
Returns field names and field positions for a given
TypeInformation and Array of
Expression . |
Table |
Table.join(Expression udtf)
Joins this
Table to a user-defined TableFunction . |
Table |
Table.join(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Expression udtf)
Joins this
Table to a user-defined TableFunction . |
Table |
Table.leftOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
TumblingEventTimeWindow |
TumblingWindow.on(Expression timeField)
Specifies the time attribute on which rows are grouped.
|
SlidingEventTimeWindow |
SlidingWindow.on(Expression timeField)
Specifies the time attribute on which rows are grouped.
|
SessionEventTimeWindow |
SessionWindow.on(Expression timeField)
Specifies the time attribute on which rows are grouped.
|
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)
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.
|
WindowGroupedTable |
WindowedTable.groupBy(scala.collection.Seq<Expression> fields)
Groups the elements by a mandatory window and one or more optional grouping attributes.
|
Table |
Table.orderBy(scala.collection.Seq<Expression> fields)
Sorts the given
Table . |
Table |
WindowGroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a window grouped table.
|
Table |
GroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a grouped table.
|
Table |
Table.select(scala.collection.Seq<Expression> fields)
Performs a selection operation.
|
Constructor and Description |
---|
EventTimeWindow(Expression timeField) |
SessionEventTimeWindow(Expression timeField,
Expression gap) |
SessionWindow(Expression gap) |
SlideWithSize(Expression size) |
SlidingEventTimeWindow(Expression timeField,
Expression size,
Expression slide) |
SlidingWindow(Expression size,
Expression slide) |
TumblingEventTimeWindow(Expression time,
Expression size) |
TumblingWindow(Expression size) |
Constructor and Description |
---|
GroupedTable(Table table,
scala.collection.Seq<Expression> groupKey) |
WindowGroupedTable(Table table,
scala.collection.Seq<Expression> groupKeys,
Window window) |
Modifier and Type | Method and Description |
---|---|
Expression |
localTimestamp$.apply()
Returns the current SQL timestamp in local time zone.
|
Expression |
localTime$.apply()
Returns the current SQL time in local time zone.
|
static Expression |
currentTimestamp.apply()
Returns the current SQL timestamp in UTC time zone.
|
Expression |
currentTime$.apply()
Returns the current SQL time in UTC time zone.
|
Expression |
currentTimestamp$.apply()
Returns the current SQL timestamp in UTC time zone.
|
Expression |
currentDate$.apply()
Returns the current SQL date in UTC time zone.
|
static Expression |
localTimestamp.apply()
Returns the current SQL timestamp in local time zone.
|
static Expression |
currentDate.apply()
Returns the current SQL date in UTC time zone.
|
static Expression |
localTime.apply()
Returns the current SQL time in local time zone.
|
static Expression |
currentTime.apply()
Returns the current SQL time in UTC time zone.
|
static Expression |
temporalOverlaps.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
Expression |
temporalOverlaps$.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
static Expression |
array.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
Expression |
array$.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
Expression |
ImplicitExpressionConversions.array2ArrayConstructor(Object array) |
Expression |
ImplicitExpressionConversions.boolean2Literal(boolean bool) |
Expression |
ImplicitExpressionConversions.byte2Literal(byte b) |
Expression |
ImplicitExpressionOperations.day()
Creates an interval of the given number of days.
|
Expression |
ImplicitExpressionOperations.days()
Creates an interval of the given number of days.
|
Expression |
ImplicitExpressionConversions.double2Literal(double d) |
Expression |
ImplicitExpressionConversions.WithOperations.expr() |
Expression |
ImplicitExpressionOperations.expr() |
Expression |
ImplicitExpressionConversions.float2Literal(float d) |
Expression |
ImplicitExpressionOperations.hour()
Creates an interval of the given number of hours.
|
Expression |
ImplicitExpressionOperations.hours()
Creates an interval of the given number of hours.
|
Expression |
ImplicitExpressionConversions.int2Literal(int i) |
Expression |
ImplicitExpressionConversions.javaDec2Literal(BigDecimal javaDec) |
Expression |
ImplicitExpressionConversions.long2Literal(long l) |
Expression |
ImplicitExpressionOperations.milli()
Creates an interval of the given number of milliseconds.
|
Expression |
ImplicitExpressionOperations.millis()
Creates an interval of the given number of milliseconds.
|
Expression |
ImplicitExpressionOperations.minute()
Creates an interval of the given number of minutes.
|
Expression |
ImplicitExpressionOperations.minutes()
Creates an interval of the given number of minutes.
|
Expression |
ImplicitExpressionOperations.month()
Creates an interval of the given number of months.
|
Expression |
ImplicitExpressionOperations.months()
Creates an interval of the given number of months.
|
Expression |
ImplicitExpressionOperations.rows()
Creates an interval of rows.
|
Expression |
ImplicitExpressionConversions.scalaDec2Literal(scala.math.BigDecimal scalaDec) |
Expression |
ImplicitExpressionOperations.second()
Creates an interval of the given number of seconds.
|
Expression |
ImplicitExpressionOperations.seconds()
Creates an interval of the given number of seconds.
|
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.
|
Expression |
ImplicitExpressionOperations.year()
Creates an interval of the given number of years.
|
Expression |
ImplicitExpressionOperations.years()
Creates an interval of the given number of years.
|
Modifier and Type | Method and Description |
---|---|
static Expression |
temporalOverlaps.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
Expression |
temporalOverlaps$.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
static Expression |
array.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
Expression |
array$.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
ArrayElementAt |
ImplicitExpressionOperations.at(Expression index)
Accesses the element of an array based on an index (starting at 1).
|
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.
|
static TumblingWindow |
Tumble.over(Expression size)
Creates a tumbling window.
|
static SlideWithSize |
Slide.over(Expression size)
Creates a sliding window.
|
TumblingWindow |
Tumble$.over(Expression size)
Creates a tumbling window.
|
SlideWithSize |
Slide$.over(Expression size)
Creates a sliding window.
|
Overlay |
ImplicitExpressionOperations.overlay(Expression newString,
Expression starting)
Replaces a substring of string with a string starting at a position (starting at 1).
|
Overlay |
ImplicitExpressionOperations.overlay(Expression newString,
Expression starting,
Expression length)
Replaces a substring of string with a string starting at a position (starting at 1).
|
Position |
ImplicitExpressionOperations.position(Expression haystack)
Returns the position of string in an other string starting at 1.
|
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 length)
Creates a substring of the given string at given index for a given length.
|
Expression |
ImplicitExpressionOperations.trim(boolean removeLeading,
boolean removeTrailing,
Expression character)
Removes leading and/or trailing characters from the given string.
|
static SessionWindow |
Session.withGap(Expression gap)
Creates a session window.
|
SessionWindow |
Session$.withGap(Expression gap)
Creates a session window.
|
Modifier and Type | Method and Description |
---|---|
static Expression |
array.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
Expression |
array$.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
<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 | Class and Description |
---|---|
class |
Abs |
class |
Aggregation |
class |
Alias |
class |
And |
class |
ArrayCardinality |
class |
ArrayConstructor |
class |
ArrayElement |
class |
ArrayElementAt |
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 |
CurrentDate |
class |
CurrentTime |
class |
CurrentTimePoint |
class |
CurrentTimestamp |
class |
Desc |
class |
Div |
class |
EqualTo |
class |
Exp |
class |
Extract |
class |
Flattening
Flattening of composite types.
|
class |
Floor |
class |
GetCompositeField |
class |
GreaterThan |
class |
GreaterThanOrEqual |
class |
If |
class |
InitCap
Returns str with the first letter of each word in uppercase.
|
class |
IsFalse |
class |
IsNotFalse |
class |
IsNotNull |
class |
IsNotTrue |
class |
IsNull |
class |
IsTrue |
class |
LeafExpression |
class |
LessThan |
class |
LessThanOrEqual |
class |
Like
Returns true if
str matches pattern . |
class |
Literal |
class |
Ln |
class |
LocalTime |
class |
LocalTimestamp |
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 |
Overlay
Replaces a substring of a string with a replacement string.
|
class |
Plus |
class |
Position
Returns the position of string needle in string haystack.
|
class |
Power |
class |
Quarter
Extracts the quarter of a year from a SQL date.
|
class |
ResolvedFieldReference |
class |
RowtimeAttribute |
class |
ScalarFunctionCall
Expression for calling a user-defined scalar functions.
|
class |
Similar
Returns true if
str is similar to pattern . |
class |
Sqrt |
class |
Substring
Returns substring of
str from begin (inclusive) for length . |
class |
Sum |
class |
SymbolExpression
General expression class to represent a symbol.
|
class |
TableFunctionCall
Expression for calling a user-defined table function with actual parameters.
|
class |
TemporalCeil |
class |
TemporalCeilFloor
Standard conversion of the EXTRACT operator.
|
class |
TemporalFloor |
class |
TemporalOverlaps
Determines whether two anchored time intervals overlap.
|
class |
Trim
Trim
trimString from str according to trimMode . |
class |
UnaryExpression |
class |
UnaryMinus |
class |
UnresolvedAlias |
class |
UnresolvedFieldReference |
class |
Upper
Returns str with all characters changed to uppercase.
|
class |
WindowEnd |
class |
WindowProperty |
class |
WindowReference |
class |
WindowStart |
Modifier and Type | Method and Description |
---|---|
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.alias() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.alias() |
scala.collection.Seq<Expression> |
Call.args() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.atom() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.atom() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.boolLiteral() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.boolLiteral() |
scala.collection.Seq<Expression> |
TemporalOverlaps.children() |
scala.collection.Seq<Expression> |
ArrayElement.children() |
scala.collection.Seq<Expression> |
If.children() |
scala.collection.Seq<Expression> |
TemporalCeilFloor.children() |
scala.collection.Seq<Expression> |
Extract.children() |
scala.collection.Seq<Expression> |
BinaryExpression.children() |
scala.collection.Seq<Expression> |
ArrayConstructor.children() |
scala.collection.Seq<Expression> |
Trim.children() |
scala.collection.Seq<Expression> |
ArrayElementAt.children() |
scala.collection.Seq<Expression> |
Overlay.children() |
scala.collection.Seq<Expression> |
UnaryExpression.children() |
scala.collection.Seq<Expression> |
Substring.children() |
scala.collection.Seq<Expression> |
Call.children() |
scala.collection.Seq<Expression> |
Position.children() |
scala.collection.Seq<Expression> |
TableFunctionCall.children() |
scala.collection.Seq<Expression> |
ArrayCardinality.children() |
scala.collection.Seq<Expression> |
ScalarFunctionCall.children() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.comparison() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.comparison() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.composite() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.composite() |
scala.collection.Seq<Expression> |
ArrayConstructor.elements() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.equalTo() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.equalTo() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.expression() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.expression() |
scala.util.parsing.combinator.Parsers.Parser<scala.collection.immutable.List<Expression>> |
ExpressionParser$.expressionList() |
static scala.util.parsing.combinator.Parsers.Parser<scala.collection.immutable.List<Expression>> |
ExpressionParser.expressionList() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.greaterThan() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.greaterThan() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.greaterThanOrEqual() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.greaterThanOrEqual() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.lessThan() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.lessThan() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.lessThanOrEqual() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.lessThanOrEqual() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.literalExpr() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.literalExpr() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.logic() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.logic() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.notEqualTo() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.notEqualTo() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.nullLiteral() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.nullLiteral() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.numberLiteral() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.numberLiteral() |
scala.collection.Seq<Expression> |
TableFunctionCall.parameters() |
scala.collection.Seq<Expression> |
ScalarFunctionCall.parameters() |
scala.collection.immutable.List<Expression> |
ExpressionParser$.parseExpressionList(String expression) |
static scala.collection.immutable.List<Expression> |
ExpressionParser.parseExpressionList(String expression) |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixArray() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixArray() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixAs() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixAs() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixAvg() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixAvg() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixCast() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixCast() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixCount() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixCount() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixed() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixed() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixEnd() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixEnd() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixFlattening() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixFlattening() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixGet() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixGet() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixIf() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixIf() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixMax() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixMax() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixMin() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixMin() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixStart() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixStart() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixSum() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixSum() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.product() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.product() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.singleQuoteStringLiteral() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.singleQuoteStringLiteral() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.stringLiteralFlink() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.stringLiteralFlink() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixAs() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixAs() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixAsc() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixAsc() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixAvg() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixAvg() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixCast() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixCast() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixCount() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixCount() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixDesc() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixDesc() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixed() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixed() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixEnd() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixEnd() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixFlattening() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixFlattening() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixGet() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixGet() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixIf() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixIf() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixMax() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixMax() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixMin() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixMin() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixRowInterval() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixRowInterval() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixStart() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixStart() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixSum() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixSum() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixTimeInterval() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixTimeInterval() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixToDate() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixToDate() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixToTime() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixToTime() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixToTimestamp() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixToTimestamp() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.term() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.term() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.timeIntervalUnit() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.timeIntervalUnit() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.timePointUnit() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.timePointUnit() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.trimMode() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.trimMode() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.unary() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.unary() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryMinus() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryMinus() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryNot() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryNot() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryPlus() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryPlus() |
Modifier and Type | Method and Description |
---|---|
boolean |
Expression.checkEquals(Expression other) |
Expression |
ExpressionUtils$.toMilliInterval(Expression expr,
long multiplier) |
static Expression |
ExpressionUtils.toMilliInterval(Expression expr,
long multiplier) |
Expression |
ExpressionUtils$.toMonthInterval(Expression expr,
int multiplier) |
static Expression |
ExpressionUtils.toMonthInterval(Expression expr,
int multiplier) |
Expression |
ExpressionUtils$.toRowInterval(Expression expr) |
static Expression |
ExpressionUtils.toRowInterval(Expression expr) |
Constructor and Description |
---|
ArrayConstructor(scala.collection.Seq<Expression> elements) |
Call(String functionName,
scala.collection.Seq<Expression> args) |
ScalarFunctionCall(ScalarFunction scalarFunction,
scala.collection.Seq<Expression> parameters) |
TableFunctionCall(String functionName,
TableFunction<?> tableFunction,
scala.collection.Seq<Expression> parameters,
TypeInformation<?> resultType) |
Modifier and Type | Method and Description |
---|---|
Expression |
ScalarFunction.apply(scala.collection.Seq<Expression> params)
Creates a call to a
ScalarFunction in Scala Table API. |
Expression |
TableFunction.apply(scala.collection.Seq<Expression> params,
TypeInformation<T> typeInfo)
Creates a call to a
TableFunction in Scala Table API. |
Modifier and Type | Method and Description |
---|---|
Expression |
ScalarFunction.apply(scala.collection.Seq<Expression> params)
Creates a call to a
ScalarFunction in Scala Table API. |
Expression |
TableFunction.apply(scala.collection.Seq<Expression> params,
TypeInformation<T> typeInfo)
Creates a call to a
TableFunction in Scala Table API. |
Modifier and Type | Method and Description |
---|---|
static scala.collection.Seq<Expression> |
ProjectionTranslator.expandProjectList(scala.collection.Seq<Expression> exprs,
LogicalNode parent,
TableEnvironment tableEnv)
Expands an UnresolvedFieldReference("*") to parent's full project list.
|
scala.collection.Seq<Expression> |
ProjectionTranslator$.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>> |
ProjectionTranslator.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.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> |
ProjectionTranslator.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.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> |
ProjectionTranslator$.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.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> |
ProjectionTranslator$.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.
|
Modifier and Type | Method and Description |
---|---|
static scala.collection.Seq<Expression> |
ProjectionTranslator.expandProjectList(scala.collection.Seq<Expression> exprs,
LogicalNode parent,
TableEnvironment tableEnv)
Expands an UnresolvedFieldReference("*") to parent's full project list.
|
scala.collection.Seq<Expression> |
ProjectionTranslator$.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>> |
ProjectionTranslator.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.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> |
ProjectionTranslator$.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> |
ProjectionTranslator.extractFieldReferences(scala.collection.Seq<Expression> exprs)
Extract all field references from the given expressions.
|
scala.collection.Seq<NamedExpression> |
ProjectionTranslator$.extractFieldReferences(scala.collection.Seq<Expression> exprs)
Extract all field references from the given expressions.
|
static scala.collection.Seq<NamedExpression> |
ProjectionTranslator.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<NamedExpression> |
ProjectionTranslator.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<NamedExpression> |
ProjectionTranslator.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.
|
scala.collection.Seq<NamedExpression> |
ProjectionTranslator$.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.
|
scala.collection.Seq<NamedExpression> |
ProjectionTranslator$.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.
|
scala.collection.Seq<NamedExpression> |
ProjectionTranslator$.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.
|
Modifier and Type | Method and Description |
---|---|
Expression |
Filter.condition() |
Expression |
ProcessingTimeSessionGroupWindow.gap() |
Expression |
EventTimeSessionGroupWindow.gap() |
Expression |
EventTimeSlidingGroupWindow.size() |
Expression |
ProcessingTimeSlidingGroupWindow.size() |
Expression |
EventTimeTumblingGroupWindow.size() |
Expression |
ProcessingTimeTumblingGroupWindow.size() |
Expression |
EventTimeSlidingGroupWindow.slide() |
Expression |
ProcessingTimeSlidingGroupWindow.slide() |
Expression |
EventTimeSlidingGroupWindow.timeField() |
Expression |
EventTimeTumblingGroupWindow.timeField() |
Expression |
EventTimeSessionGroupWindow.timeField() |
Modifier and Type | Method and Description |
---|---|
scala.Option<Expression> |
EventTimeSlidingGroupWindow.alias() |
scala.Option<Expression> |
ProcessingTimeSessionGroupWindow.alias() |
scala.Option<Expression> |
ProcessingTimeSlidingGroupWindow.alias() |
scala.Option<Expression> |
LogicalWindow.alias() |
scala.Option<Expression> |
EventTimeTumblingGroupWindow.alias() |
scala.Option<Expression> |
EventTimeSessionGroupWindow.alias() |
scala.Option<Expression> |
ProcessingTimeTumblingGroupWindow.alias() |
scala.collection.Seq<Expression> |
AliasNode.aliasList() |
scala.Option<Expression> |
Join.condition() |
scala.collection.Seq<Expression> |
WindowAggregate.groupingExpressions() |
scala.collection.Seq<Expression> |
Aggregate.groupingExpressions() |
scala.collection.Seq<Expression> |
LogicalTableFunctionCall.parameters() |
Modifier and Type | Method and Description |
---|---|
static ValidationResult |
SessionGroupWindow.validate(TableEnvironment tableEnv,
Expression gap) |
static ValidationResult |
TumblingGroupWindow.validate(TableEnvironment tableEnv,
Expression size) |
ValidationResult |
TumblingGroupWindow$.validate(TableEnvironment tableEnv,
Expression size) |
ValidationResult |
SessionGroupWindow$.validate(TableEnvironment tableEnv,
Expression gap) |
ValidationResult |
SlidingGroupWindow$.validate(TableEnvironment tableEnv,
Expression size,
Expression slide) |
static ValidationResult |
SlidingGroupWindow.validate(TableEnvironment tableEnv,
Expression size,
Expression slide) |
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. |
LogicalWindow |
EventTimeSlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
EventTimeSlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeSessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeSessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
T |
Resolvable.resolveExpressions(scala.Function1<Expression,Expression> resolver)
An implementing class can resolve its expressions by applying the given resolver
function on its parameters.
|
T |
Resolvable.resolveExpressions(scala.Function1<Expression,Expression> resolver)
An implementing class can resolve its expressions by applying the given resolver
function on its parameters.
|
LogicalWindow |
ProcessingTimeSlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeSlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
LogicalWindow.resolveExpressions(scala.Function1<Expression,Expression> resolver) |
LogicalWindow |
LogicalWindow.resolveExpressions(scala.Function1<Expression,Expression> resolver) |
LogicalWindow |
EventTimeTumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
EventTimeTumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
EventTimeSessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
EventTimeSessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeTumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
ProcessingTimeTumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
Constructor and Description |
---|
EventTimeGroupWindow(scala.Option<Expression> alias,
Expression time) |
EventTimeSessionGroupWindow(scala.Option<Expression> alias,
Expression timeField,
Expression gap) |
EventTimeSlidingGroupWindow(scala.Option<Expression> alias,
Expression timeField,
Expression size,
Expression slide) |
EventTimeTumblingGroupWindow(scala.Option<Expression> alias,
Expression timeField,
Expression size) |
Filter(Expression condition,
LogicalNode child) |
ProcessingTimeSessionGroupWindow(scala.Option<Expression> alias,
Expression gap) |
ProcessingTimeSlidingGroupWindow(scala.Option<Expression> alias,
Expression size,
Expression slide) |
ProcessingTimeTumblingGroupWindow(scala.Option<Expression> alias,
Expression size) |
Constructor and Description |
---|
Aggregate(scala.collection.Seq<Expression> groupingExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
AliasNode(scala.collection.Seq<Expression> aliasList,
LogicalNode child) |
EventTimeGroupWindow(scala.Option<Expression> alias,
Expression time) |
EventTimeSessionGroupWindow(scala.Option<Expression> alias,
Expression timeField,
Expression gap) |
EventTimeSlidingGroupWindow(scala.Option<Expression> alias,
Expression timeField,
Expression size,
Expression slide) |
EventTimeTumblingGroupWindow(scala.Option<Expression> alias,
Expression timeField,
Expression size) |
Join(LogicalNode left,
LogicalNode right,
JoinType joinType,
scala.Option<Expression> condition,
boolean correlated) |
LogicalTableFunctionCall(String functionName,
TableFunction<?> tableFunction,
scala.collection.Seq<Expression> parameters,
TypeInformation<?> resultType,
String[] fieldNames,
LogicalNode child) |
LogicalWindow(scala.Option<Expression> alias) |
ProcessingTimeGroupWindow(scala.Option<Expression> alias) |
ProcessingTimeSessionGroupWindow(scala.Option<Expression> alias,
Expression gap) |
ProcessingTimeSlidingGroupWindow(scala.Option<Expression> alias,
Expression size,
Expression slide) |
ProcessingTimeTumblingGroupWindow(scala.Option<Expression> alias,
Expression size) |
WindowAggregate(scala.collection.Seq<Expression> groupingExpressions,
LogicalWindow window,
scala.collection.Seq<NamedExpression> propertyExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
Modifier and Type | Method and Description |
---|---|
long |
DataStreamAggregate$.asCount(Expression expr) |
static long |
DataStreamAggregate.asCount(Expression expr) |
Time |
DataStreamAggregate$.asTime(Expression expr) |
static Time |
DataStreamAggregate.asTime(Expression expr) |
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.