Modifier and Type | Class and Description |
---|---|
class |
CurrentRange |
class |
CurrentRow |
class |
UnboundedRange |
class |
UnboundedRow |
Modifier and Type | Method and Description |
---|---|
Expression |
Window.alias() |
Expression |
OverWindow.alias() |
Expression |
OverWindow.following() |
Expression |
OverWindowWithPreceding.following() |
Expression |
OverWindow.orderBy() |
Expression |
OverWindow.preceding() |
Expression |
Window.timeField() |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Expression> |
GroupedTable.groupKey() |
scala.collection.Seq<Expression> |
WindowGroupedTable.groupKeys() |
scala.collection.Seq<Expression> |
OverWindow.partitionBy() |
Modifier and Type | Method and Description |
---|---|
SessionWithGapOnTimeWithAlias |
SessionWithGapOnTime.as(Expression alias)
Assigns an alias for this window that the following
groupBy() and select() clause can
refer to. |
OverWindow |
OverWindowWithPreceding.as(Expression alias)
Assigns an alias for this window that the following
select() clause can refer to. |
TumbleWithSizeOnTimeWithAlias |
TumbleWithSizeOnTime.as(Expression alias)
Assigns an alias for this window that the following
groupBy() and select() clause can
refer to. |
SlideWithSizeAndSlideOnTimeWithAlias |
SlideWithSizeAndSlideOnTime.as(Expression alias)
Assigns an alias for this window that the following
groupBy() and select() clause can
refer to. |
static boolean |
UnboundedRow.checkEquals(Expression other) |
static boolean |
CurrentRange.checkEquals(Expression other) |
static boolean |
CurrentRow.checkEquals(Expression other) |
static boolean |
UnboundedRange.checkEquals(Expression other) |
SlideWithSizeAndSlide |
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.
|
OverWindowWithPreceding |
OverWindowWithPreceding.following(Expression following)
Set the following offset (based on time or row-count intervals) for over window.
|
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. |
SlideWithSizeAndSlideOnTime |
SlideWithSizeAndSlide.on(Expression timeField)
Specifies the time attribute on which rows are grouped.
|
SessionWithGapOnTime |
SessionWithGap.on(Expression timeField)
Specifies the time attribute on which rows are grouped.
|
TumbleWithSizeOnTime |
TumbleWithSize.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 |
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.
|
Table |
OverWindowedTable.select(scala.collection.Seq<Expression> fields) |
Table |
WindowGroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a window grouped table.
|
Constructor and Description |
---|
GroupedTable(Table table,
scala.collection.Seq<Expression> groupKey) |
OverWindow(Expression alias,
scala.collection.Seq<Expression> partitionBy,
Expression orderBy,
Expression preceding,
Expression following) |
OverWindowWithPreceding(scala.collection.Seq<Expression> partitionBy,
Expression orderBy,
Expression preceding) |
WindowGroupedTable(Table table,
scala.collection.Seq<Expression> groupKeys,
Window window) |
Constructor and Description |
---|
OverWindowWithOrderBy(Expression[] partitionByExpr,
Expression orderByExpr) |
OverWindowWithOrderBy(Expression[] partitionByExpr,
Expression orderByExpr) |
PartitionedOver(Expression[] partitionByExpr) |
Modifier and Type | Method and Description |
---|---|
static Expression |
currentDate.apply()
Returns the current SQL date in UTC time zone.
|
static Expression |
currentTime.apply()
Returns the current SQL time in UTC time zone.
|
Expression |
localTimestamp$.apply()
Returns the current SQL timestamp in local time zone.
|
Expression |
currentTime$.apply()
Returns the current SQL time in UTC time zone.
|
Expression |
pi$.apply()
Returns a value that is closer than any other value to pi.
|
static Expression |
currentTimestamp.apply()
Returns the current SQL timestamp in UTC time zone.
|
Expression |
currentDate$.apply()
Returns the current SQL date in UTC time zone.
|
Expression |
localTime$.apply()
Returns the current SQL time in local time zone.
|
static Expression |
localTime.apply()
Returns the current SQL time in local time zone.
|
Expression |
currentTimestamp$.apply()
Returns the current SQL timestamp in UTC time zone.
|
static Expression |
pi.apply()
Returns a value that is closer than any other value to pi.
|
static Expression |
localTimestamp.apply()
Returns the current SQL timestamp in local time zone.
|
Expression |
temporalOverlaps$.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
static Expression |
temporalOverlaps.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
Expression |
array$.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
static 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 |
OverWindowWithOrderBy.orderBy() |
Expression[] |
PartitionedOver.partitionBy() |
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 |
---|---|
scala.collection.Seq<Expression> |
OverWindowWithOrderBy.partitionBy() |
Modifier and Type | Method and Description |
---|---|
Expression |
temporalOverlaps$.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
static Expression |
temporalOverlaps.apply(Expression leftTimePoint,
Expression leftTemporal,
Expression rightTimePoint,
Expression rightTemporal)
Determines whether two anchored time intervals overlap.
|
Expression |
array$.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
static 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 OverWindowWithOrderBy |
Over.orderBy(Expression orderBy)
Specifies the time attribute on which rows are grouped.
|
OverWindowWithOrderBy |
Over$.orderBy(Expression orderBy)
Specifies the time attribute on which rows are grouped.
|
OverWindowWithOrderBy |
PartitionedOver.orderBy(Expression orderBy)
Specifies the time attribute on which rows are grouped.
|
UnresolvedOverCall |
ImplicitExpressionOperations.over(Expression alias)
For windowing function to config over window
e.g.:
table
.window(Over partitionBy 'c orderBy 'rowtime preceding 2.rows following CURRENT_ROW as 'w)
.select('c, 'a, 'a.count over 'w, 'a.sum over 'w)
|
static TumbleWithSize |
Tumble.over(Expression size)
Creates a tumbling window.
|
static SlideWithSize |
Slide.over(Expression size)
Creates a sliding window.
|
SlideWithSize |
Slide$.over(Expression size)
Creates a sliding window.
|
TumbleWithSize |
Tumble$.over(Expression size)
Creates a tumbling 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.
|
OverWindowWithPreceding |
OverWindowWithOrderBy.preceding(Expression preceding)
Set the preceding offset (based on time or row-count intervals) for over window.
|
Round |
ImplicitExpressionOperations.round(Expression places)
Rounds the given number to integer places right to the decimal point.
|
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 SessionWithGap |
Session.withGap(Expression gap)
Creates a session window.
|
SessionWithGap |
Session$.withGap(Expression gap)
Creates a session window.
|
Modifier and Type | Method and Description |
---|---|
Expression |
array$.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
static Expression |
array.apply(Expression head,
scala.collection.Seq<Expression> tail)
Creates an array of literals.
|
Table |
TableFunctionConversions.apply(scala.collection.Seq<Expression> args,
TypeInformation<T> typeInfo)
Creates a
Table from a TableFunction in Scala Table API. |
<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. |
static PartitionedOver |
Over.partitionBy(scala.collection.Seq<Expression> partitionBy)
Partitions the elements on some partition keys.
|
PartitionedOver |
Over$.partitionBy(scala.collection.Seq<Expression> partitionBy)
Partitions the elements on some partition keys.
|
<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 |
---|
OverWindowWithOrderBy(scala.collection.Seq<Expression> partitionBy,
Expression orderBy) |
PartitionedOver(Expression[] partitionBy) |
WithOperations(Expression e) |
Constructor and Description |
---|
OverWindowWithOrderBy(scala.collection.Seq<Expression> partitionBy,
Expression orderBy) |
Modifier and Type | Class and Description |
---|---|
class |
Abs |
class |
AbstractWindowProperty |
class |
Acos |
class |
AggFunctionCall |
class |
Aggregation |
class |
Alias |
class |
And |
class |
ArrayCardinality |
class |
ArrayConstructor |
class |
ArrayElement |
class |
ArrayElementAt |
class |
Asc |
class |
Asin |
class |
Atan |
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 |
Cos |
class |
Cot |
class |
Count |
class |
CurrentDate |
class |
CurrentTime |
class |
CurrentTimePoint |
class |
CurrentTimestamp |
class |
Degrees |
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 |
OverCall
Over expression for Calcite over transform.
|
class |
Overlay
Replaces a substring of a string with a replacement string.
|
class |
Pi |
class |
Plus |
class |
Position
Returns the position of string needle in string haystack.
|
class |
Power |
class |
ProctimeAttribute |
class |
Quarter
Extracts the quarter of a year from a SQL date.
|
class |
Radians |
class |
ResolvedFieldReference |
class |
Round |
class |
RowtimeAttribute |
class |
ScalarFunctionCall
Expression for calling a user-defined scalar functions.
|
class |
Sign |
class |
Similar
Returns true if
str is similar to pattern . |
class |
Sin |
class |
Sqrt |
class |
StddevPop |
class |
StddevSamp |
class |
Substring
Returns substring of
str from begin (inclusive) for length . |
class |
Sum |
class |
Sum0 |
class |
SymbolExpression
General expression class to represent a symbol.
|
class |
TableFunctionCall
Expression for calling a user-defined table function with actual parameters.
|
class |
Tan |
class |
TemporalCeil |
class |
TemporalCeilFloor |
class |
TemporalFloor |
class |
TemporalOverlaps
Determines whether two anchored time intervals overlap.
|
class |
TimeAttribute |
class |
Trim
Trim
trimString from str according to trimMode . |
class |
UnaryExpression |
class |
UnaryMinus |
class |
UnresolvedAlias |
class |
UnresolvedFieldReference |
class |
UnresolvedOverCall
Over call with unresolved alias for over window.
|
class |
Upper
Returns str with all characters changed to uppercase.
|
class |
VarPop |
class |
VarSamp |
class |
WindowEnd |
class |
WindowReference |
class |
WindowStart |
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() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.aliasMapping() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.aliasMapping() |
scala.collection.Seq<Expression> |
AggFunctionCall.args() |
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() |
static scala.collection.Seq<Expression> |
Lower.children() |
static scala.collection.Seq<Expression> |
Degrees.children() |
static scala.collection.Seq<Expression> |
WindowStart.children() |
scala.collection.Seq<Expression> |
Extract.children() |
static scala.collection.Seq<Expression> |
ProctimeAttribute.children() |
scala.collection.Seq<Expression> |
AggFunctionCall.children() |
scala.collection.Seq<Expression> |
ScalarFunctionCall.children() |
static scala.collection.Seq<Expression> |
Ln.children() |
static scala.collection.Seq<Expression> |
GetCompositeField.children() |
static scala.collection.Seq<Expression> |
Similar.children() |
scala.collection.Seq<Expression> |
Position.children() |
static scala.collection.Seq<Expression> |
And.children() |
static scala.collection.Seq<Expression> |
GreaterThan.children() |
scala.collection.Seq<Expression> |
VarPop.children() |
scala.collection.Seq<Expression> |
Min.children() |
scala.collection.Seq<Expression> |
UnaryExpression.children() |
static scala.collection.Seq<Expression> |
Minus.children() |
static scala.collection.Seq<Expression> |
LessThanOrEqual.children() |
static scala.collection.Seq<Expression> |
Not.children() |
scala.collection.Seq<Expression> |
Overlay.children() |
static scala.collection.Seq<Expression> |
Like.children() |
static scala.collection.Seq<Expression> |
Or.children() |
static scala.collection.Seq<Expression> |
Cot.children() |
static scala.collection.Seq<Expression> |
IsNotNull.children() |
static scala.collection.Seq<Expression> |
Div.children() |
static scala.collection.Seq<Expression> |
Upper.children() |
static scala.collection.Seq<Expression> |
Radians.children() |
static scala.collection.Seq<Expression> |
Floor.children() |
static scala.collection.Seq<Expression> |
IsNotFalse.children() |
static scala.collection.Seq<Expression> |
Tan.children() |
static scala.collection.Seq<Expression> |
NotEqualTo.children() |
static scala.collection.Seq<Expression> |
Acos.children() |
static scala.collection.Seq<Expression> |
Exp.children() |
static scala.collection.Seq<Expression> |
Cos.children() |
static scala.collection.Seq<Expression> |
InitCap.children() |
static scala.collection.Seq<Expression> |
Desc.children() |
scala.collection.Seq<Expression> |
Sum.children() |
scala.collection.Seq<Expression> |
ArrayCardinality.children() |
static scala.collection.Seq<Expression> |
EqualTo.children() |
scala.collection.Seq<Expression> |
StddevPop.children() |
static scala.collection.Seq<Expression> |
IsNotTrue.children() |
static scala.collection.Seq<Expression> |
UnaryMinus.children() |
static scala.collection.Seq<Expression> |
Power.children() |
static scala.collection.Seq<Expression> |
Abs.children() |
scala.collection.Seq<Expression> |
TableFunctionCall.children() |
static scala.collection.Seq<Expression> |
Plus.children() |
static scala.collection.Seq<Expression> |
CharLength.children() |
scala.collection.Seq<Expression> |
ArrayElementAt.children() |
static scala.collection.Seq<Expression> |
Quarter.children() |
static scala.collection.Seq<Expression> |
Sin.children() |
static scala.collection.Seq<Expression> |
Atan.children() |
static scala.collection.Seq<Expression> |
Sign.children() |
static scala.collection.Seq<Expression> |
Ceil.children() |
scala.collection.Seq<Expression> |
Avg.children() |
static scala.collection.Seq<Expression> |
TemporalCeil.children() |
static scala.collection.Seq<Expression> |
Asin.children() |
static scala.collection.Seq<Expression> |
Mod.children() |
scala.collection.Seq<Expression> |
Count.children() |
static scala.collection.Seq<Expression> |
LessThan.children() |
scala.collection.Seq<Expression> |
Call.children() |
scala.collection.Seq<Expression> |
OverCall.children() |
static scala.collection.Seq<Expression> |
Cast.children() |
scala.collection.Seq<Expression> |
Trim.children() |
scala.collection.Seq<Expression> |
ArrayElement.children() |
scala.collection.Seq<Expression> |
StddevSamp.children() |
static scala.collection.Seq<Expression> |
TemporalFloor.children() |
static scala.collection.Seq<Expression> |
Asc.children() |
static scala.collection.Seq<Expression> |
IsNull.children() |
scala.collection.Seq<Expression> |
TemporalCeilFloor.children() |
static scala.collection.Seq<Expression> |
Sqrt.children() |
static scala.collection.Seq<Expression> |
Round.children() |
static scala.collection.Seq<Expression> |
WindowEnd.children() |
scala.collection.Seq<Expression> |
VarSamp.children() |
static scala.collection.Seq<Expression> |
Mul.children() |
scala.collection.Seq<Expression> |
BinaryExpression.children() |
static scala.collection.Seq<Expression> |
IsTrue.children() |
static scala.collection.Seq<Expression> |
Alias.children() |
static scala.collection.Seq<Expression> |
RowtimeAttribute.children() |
scala.collection.Seq<Expression> |
Max.children() |
static scala.collection.Seq<Expression> |
GreaterThanOrEqual.children() |
static scala.collection.Seq<Expression> |
UnresolvedAlias.children() |
scala.collection.Seq<Expression> |
Sum0.children() |
static scala.collection.Seq<Expression> |
IsFalse.children() |
static scala.collection.Seq<Expression> |
Flattening.children() |
scala.collection.Seq<Expression> |
ArrayConstructor.children() |
static scala.collection.Seq<Expression> |
Log10.children() |
scala.collection.Seq<Expression> |
TemporalOverlaps.children() |
scala.collection.Seq<Expression> |
Substring.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.currentRange() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.currentRange() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.currentRow() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.currentRow() |
scala.collection.Seq<Expression> |
ArrayConstructor.elements() |
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.PackratParsers.PackratParser<Expression> |
ExpressionParser.logic() |
scala.util.parsing.combinator.PackratParsers.PackratParser<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.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.over() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.over() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.overConstant() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.overConstant() |
scala.collection.Seq<Expression> |
ScalarFunctionCall.parameters() |
scala.collection.Seq<Expression> |
TableFunctionCall.parameters() |
static scala.collection.immutable.List<Expression> |
ExpressionParser.parseExpressionList(String expression) |
scala.collection.immutable.List<Expression> |
ExpressionParser$.parseExpressionList(String expression) |
scala.collection.Seq<Expression> |
OverCall.partitionBy() |
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.prefixCast() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixCast() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixCeil() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixCeil() |
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.prefixExtract() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixExtract() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixFlattening() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixFlattening() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixFloor() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixFloor() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixFunctionCall() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixFunctionCall() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixFunctionCallOneArg() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixFunctionCallOneArg() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixGet() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixGet() |
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.prefixToDate() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixToDate() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixToTime() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixToTime() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixToTimestamp() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixToTimestamp() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixTrim() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixTrim() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.prefixTrimWithoutArgs() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.prefixTrimWithoutArgs() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.proctime() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.proctime() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.product() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.product() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.rowtime() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.rowtime() |
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.suffixCast() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixCast() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixCeil() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixCeil() |
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.suffixExtract() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixExtract() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixFlattening() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixFlattening() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixFloor() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixFloor() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixFunctionCall() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixFunctionCall() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixFunctionCallOneArg() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixFunctionCallOneArg() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixGet() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixGet() |
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.suffixRowInterval() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixRowInterval() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixTimeInterval() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixTimeInterval() |
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.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixTrim() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixTrim() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.suffixTrimWithoutArgs() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.suffixTrimWithoutArgs() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.term() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.term() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.timeIndicator() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.timeIndicator() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.timeIntervalUnit() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.timeIntervalUnit() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.timePointUnit() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.timePointUnit() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.trimMode() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.trimMode() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unary() |
scala.util.parsing.combinator.PackratParsers.PackratParser<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() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryPlus() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryPlus() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unboundedRange() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unboundedRange() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unboundedRow() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unboundedRow() |
Modifier and Type | Method and Description |
---|---|
static boolean |
UnresolvedFieldReference.checkEquals(Expression other) |
static boolean |
If.checkEquals(Expression other) |
static boolean |
Lower.checkEquals(Expression other) |
static boolean |
Degrees.checkEquals(Expression other) |
static boolean |
WindowStart.checkEquals(Expression other) |
static boolean |
Extract.checkEquals(Expression other) |
static boolean |
ProctimeAttribute.checkEquals(Expression other) |
static boolean |
CurrentDate.checkEquals(Expression other) |
static boolean |
AggFunctionCall.checkEquals(Expression other) |
static boolean |
ScalarFunctionCall.checkEquals(Expression other) |
static boolean |
Ln.checkEquals(Expression other) |
static boolean |
GetCompositeField.checkEquals(Expression other) |
static boolean |
Similar.checkEquals(Expression other) |
static boolean |
Position.checkEquals(Expression other) |
boolean |
Expression.checkEquals(Expression other) |
static boolean |
And.checkEquals(Expression other) |
static boolean |
GreaterThan.checkEquals(Expression other) |
static boolean |
UnresolvedOverCall.checkEquals(Expression other) |
static boolean |
VarPop.checkEquals(Expression other) |
static boolean |
Min.checkEquals(Expression other) |
static boolean |
Minus.checkEquals(Expression other) |
static boolean |
Null.checkEquals(Expression other) |
static boolean |
WindowReference.checkEquals(Expression other) |
static boolean |
LessThanOrEqual.checkEquals(Expression other) |
static boolean |
Not.checkEquals(Expression other) |
static boolean |
CurrentTime.checkEquals(Expression other) |
static boolean |
Overlay.checkEquals(Expression other) |
static boolean |
Like.checkEquals(Expression other) |
static boolean |
Or.checkEquals(Expression other) |
static boolean |
Cot.checkEquals(Expression other) |
static boolean |
IsNotNull.checkEquals(Expression other) |
static boolean |
ResolvedFieldReference.checkEquals(Expression other) |
static boolean |
Div.checkEquals(Expression other) |
static boolean |
Upper.checkEquals(Expression other) |
static boolean |
CurrentTimestamp.checkEquals(Expression other) |
static boolean |
Radians.checkEquals(Expression other) |
static boolean |
Floor.checkEquals(Expression other) |
static boolean |
IsNotFalse.checkEquals(Expression other) |
static boolean |
Tan.checkEquals(Expression other) |
static boolean |
NotEqualTo.checkEquals(Expression other) |
static boolean |
Acos.checkEquals(Expression other) |
static boolean |
Exp.checkEquals(Expression other) |
static boolean |
Cos.checkEquals(Expression other) |
static boolean |
Literal.checkEquals(Expression other) |
static boolean |
InitCap.checkEquals(Expression other) |
static boolean |
Desc.checkEquals(Expression other) |
static boolean |
Sum.checkEquals(Expression other) |
static boolean |
ArrayCardinality.checkEquals(Expression other) |
static boolean |
LocalTimestamp.checkEquals(Expression other) |
static boolean |
EqualTo.checkEquals(Expression other) |
static boolean |
StddevPop.checkEquals(Expression other) |
static boolean |
IsNotTrue.checkEquals(Expression other) |
static boolean |
UnaryMinus.checkEquals(Expression other) |
static boolean |
Power.checkEquals(Expression other) |
static boolean |
Abs.checkEquals(Expression other) |
static boolean |
TableFunctionCall.checkEquals(Expression other) |
static boolean |
Plus.checkEquals(Expression other) |
static boolean |
CharLength.checkEquals(Expression other) |
static boolean |
ArrayElementAt.checkEquals(Expression other) |
static boolean |
Quarter.checkEquals(Expression other) |
static boolean |
Sin.checkEquals(Expression other) |
static boolean |
Atan.checkEquals(Expression other) |
static boolean |
Sign.checkEquals(Expression other) |
static boolean |
Ceil.checkEquals(Expression other) |
static boolean |
Avg.checkEquals(Expression other) |
static boolean |
TemporalCeil.checkEquals(Expression other) |
static boolean |
Asin.checkEquals(Expression other) |
static boolean |
Mod.checkEquals(Expression other) |
static boolean |
Count.checkEquals(Expression other) |
static boolean |
LessThan.checkEquals(Expression other) |
static boolean |
Call.checkEquals(Expression other) |
static boolean |
Pi.checkEquals(Expression other) |
static boolean |
OverCall.checkEquals(Expression other) |
static boolean |
Cast.checkEquals(Expression other) |
static boolean |
Trim.checkEquals(Expression other) |
static boolean |
ArrayElement.checkEquals(Expression other) |
static boolean |
StddevSamp.checkEquals(Expression other) |
static boolean |
TemporalFloor.checkEquals(Expression other) |
static boolean |
Asc.checkEquals(Expression other) |
static boolean |
IsNull.checkEquals(Expression other) |
static boolean |
Sqrt.checkEquals(Expression other) |
static boolean |
Round.checkEquals(Expression other) |
static boolean |
WindowEnd.checkEquals(Expression other) |
static boolean |
VarSamp.checkEquals(Expression other) |
static boolean |
Mul.checkEquals(Expression other) |
static boolean |
IsTrue.checkEquals(Expression other) |
static boolean |
Alias.checkEquals(Expression other) |
static boolean |
RowtimeAttribute.checkEquals(Expression other) |
static boolean |
Max.checkEquals(Expression other) |
static boolean |
GreaterThanOrEqual.checkEquals(Expression other) |
static boolean |
LocalTime.checkEquals(Expression other) |
static boolean |
SymbolExpression.checkEquals(Expression other) |
static boolean |
UnresolvedAlias.checkEquals(Expression other) |
static boolean |
Sum0.checkEquals(Expression other) |
static boolean |
IsFalse.checkEquals(Expression other) |
static boolean |
Flattening.checkEquals(Expression other) |
static boolean |
ArrayConstructor.checkEquals(Expression other) |
static boolean |
Log10.checkEquals(Expression other) |
static boolean |
TemporalOverlaps.checkEquals(Expression other) |
static boolean |
Substring.checkEquals(Expression other) |
boolean |
ExpressionUtils$.isProctimeAttribute(Expression expr) |
static boolean |
ExpressionUtils.isProctimeAttribute(Expression expr) |
boolean |
ExpressionUtils$.isRowCountLiteral(Expression expr) |
static boolean |
ExpressionUtils.isRowCountLiteral(Expression expr) |
boolean |
ExpressionUtils$.isRowtimeAttribute(Expression expr) |
static boolean |
ExpressionUtils.isRowtimeAttribute(Expression expr) |
boolean |
ExpressionUtils$.isTimeAttribute(Expression expr) |
static boolean |
ExpressionUtils.isTimeAttribute(Expression expr) |
boolean |
ExpressionUtils$.isTimeIntervalLiteral(Expression expr) |
static boolean |
ExpressionUtils.isTimeIntervalLiteral(Expression expr) |
long |
ExpressionUtils$.toLong(Expression expr) |
static long |
ExpressionUtils.toLong(Expression expr) |
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) |
Time |
ExpressionUtils$.toTime(Expression expr) |
static Time |
ExpressionUtils.toTime(Expression expr) |
Modifier and Type | Method and Description |
---|---|
AggFunctionCall |
UDAGGExpression.apply(scala.collection.Seq<Expression> params)
Creates a call to an
AggregateFunction . |
Constructor and Description |
---|
AggFunctionCall(AggregateFunction<?,?> aggregateFunction,
scala.collection.Seq<Expression> args) |
ArrayConstructor(scala.collection.Seq<Expression> elements) |
Call(String functionName,
scala.collection.Seq<Expression> args) |
OverCall(Expression agg,
scala.collection.Seq<Expression> partitionBy,
Expression orderBy,
Expression preceding,
Expression following) |
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. |
Modifier and Type | Method and Description |
---|---|
Expression |
ScalarFunction.apply(scala.collection.Seq<Expression> params)
Creates a call to a
ScalarFunction in Scala Table API. |
Modifier and Type | Method and Description |
---|---|
static Expression |
ProjectionTranslator.replaceAggFunctionCall(Expression field,
TableEnvironment tableEnv)
Find and replace UDAGG function Call to AggFunctionCall
|
Expression |
ProjectionTranslator$.replaceAggFunctionCall(Expression field,
TableEnvironment tableEnv)
Find and replace UDAGG function Call to AggFunctionCall
|
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.
|
static scala.collection.Seq<Expression> |
ProjectionTranslator.resolveOverWindows(scala.collection.Seq<Expression> exprs,
OverWindow[] overWindows,
TableEnvironment tEnv) |
scala.collection.Seq<Expression> |
ProjectionTranslator$.resolveOverWindows(scala.collection.Seq<Expression> exprs,
OverWindow[] overWindows,
TableEnvironment tEnv) |
Modifier and Type | Method and Description |
---|---|
static Expression |
ProjectionTranslator.replaceAggFunctionCall(Expression field,
TableEnvironment tableEnv)
Find and replace UDAGG function Call to AggFunctionCall
|
Expression |
ProjectionTranslator$.replaceAggFunctionCall(Expression field,
TableEnvironment tableEnv)
Find and replace UDAGG function Call to AggFunctionCall
|
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.
|
static scala.collection.Seq<Expression> |
ProjectionTranslator.resolveOverWindows(scala.collection.Seq<Expression> exprs,
OverWindow[] overWindows,
TableEnvironment tEnv) |
scala.collection.Seq<Expression> |
ProjectionTranslator$.resolveOverWindows(scala.collection.Seq<Expression> exprs,
OverWindow[] overWindows,
TableEnvironment tEnv) |
Modifier and Type | Method and Description |
---|---|
Expression |
SessionGroupWindow.alias() |
Expression |
SlidingGroupWindow.alias() |
Expression |
TumblingGroupWindow.alias() |
static Expression |
SessionGroupWindow.aliasAttribute() |
Expression |
LogicalWindow.aliasAttribute() |
static Expression |
SlidingGroupWindow.aliasAttribute() |
static Expression |
TumblingGroupWindow.aliasAttribute() |
Expression |
Filter.condition() |
Expression |
SessionGroupWindow.gap() |
Expression |
SlidingGroupWindow.size() |
Expression |
TumblingGroupWindow.size() |
Expression |
SlidingGroupWindow.slide() |
static Expression |
SessionGroupWindow.timeAttribute() |
Expression |
LogicalWindow.timeAttribute() |
static Expression |
SlidingGroupWindow.timeAttribute() |
static Expression |
TumblingGroupWindow.timeAttribute() |
Expression |
SessionGroupWindow.timeField() |
Expression |
SlidingGroupWindow.timeField() |
Expression |
TumblingGroupWindow.timeField() |
Modifier and Type | Method and Description |
---|---|
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 LogicalNode |
Intersect.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Intersect.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
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. |
static LogicalNode |
Union.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Union.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Minus.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Minus.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Sort.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Sort.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
LogicalTableFunctionCall.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
LogicalTableFunctionCall.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Filter.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Filter.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Project.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Project.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Distinct.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Distinct.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Join.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Join.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Limit.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Limit.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
LogicalRelNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
LogicalRelNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
WindowAggregate.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
WindowAggregate.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
CatalogNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
CatalogNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Aggregate.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
Aggregate.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
AliasNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
static LogicalNode |
AliasNode.expressionPostOrderTransform(scala.PartialFunction<Expression,Expression> rule) |
LogicalWindow |
SessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
SessionGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
LogicalWindow.resolveExpressions(scala.Function1<Expression,Expression> resolver) |
LogicalWindow |
LogicalWindow.resolveExpressions(scala.Function1<Expression,Expression> resolver) |
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 |
SlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
SlidingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
TumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
LogicalWindow |
TumblingGroupWindow.resolveExpressions(scala.Function1<Expression,Expression> resolve) |
Constructor and Description |
---|
Filter(Expression condition,
LogicalNode child) |
LogicalWindow(Expression aliasAttribute,
Expression timeAttribute) |
SessionGroupWindow(Expression alias,
Expression timeField,
Expression gap) |
SlidingGroupWindow(Expression alias,
Expression timeField,
Expression size,
Expression slide) |
TumblingGroupWindow(Expression alias,
Expression timeField,
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) |
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) |
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 |
---|---|
scala.Option<Expression> |
RexNodeToExpressionConverter.visitCall(org.apache.calcite.rex.RexCall call) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitCorrelVariable(org.apache.calcite.rex.RexCorrelVariable correlVariable) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitDynamicParam(org.apache.calcite.rex.RexDynamicParam dynamicParam) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitFieldAccess(org.apache.calcite.rex.RexFieldAccess fieldAccess) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitInputRef(org.apache.calcite.rex.RexInputRef inputRef) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitLiteral(org.apache.calcite.rex.RexLiteral literal) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitLocalRef(org.apache.calcite.rex.RexLocalRef localRef) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitOver(org.apache.calcite.rex.RexOver over) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitPatternFieldRef(org.apache.calcite.rex.RexPatternFieldRef fieldRef) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitRangeRef(org.apache.calcite.rex.RexRangeRef rangeRef) |
scala.Option<Expression> |
RexNodeToExpressionConverter.visitSubQuery(org.apache.calcite.rex.RexSubQuery subQuery) |
Modifier and Type | Method and Description |
---|---|
static long |
AggregateUtil.asLong(Expression expr) |
long |
AggregateUtil$.asLong(Expression expr) |
Modifier and Type | Method and Description |
---|---|
TableSource<T> |
FilterableTableSource.applyPredicate(List<Expression> predicates)
Check and pick all predicates this table source can support.
|
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–2018 The Apache Software Foundation. All rights reserved.