Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.scala |
Class and Description |
---|
BatchTableEnvironment
The
TableEnvironment for a Scala batch DataSet
ExecutionEnvironment . |
StreamTableEnvironment
The
TableEnvironment for a Scala StreamExecutionEnvironment . |
Class and Description |
---|
array$
Creates an array of literals.
|
BatchTableEnvironment
The
TableEnvironment for a Scala batch DataSet
ExecutionEnvironment . |
currentDate$
Returns the current SQL date in UTC time zone.
|
currentTime$
Returns the current SQL time in UTC time zone.
|
currentTimestamp$
Returns the current SQL timestamp in UTC time zone.
|
ImplicitExpressionOperations
These are all the operations that can be used to construct an
Expression AST for expression
operations. |
localTime$
Returns the current SQL time in local time zone.
|
localTimestamp$
Returns the current SQL timestamp in local time zone.
|
Session$
Helper object for creating a session window.
|
Slide$
Helper object for creating a sliding window.
|
StreamTableEnvironment
The
TableEnvironment for a Scala StreamExecutionEnvironment . |
temporalOverlaps$
Determines whether two anchored time intervals overlap.
|
Tumble$
Helper object for creating a tumbling window.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.