Class | Description |
---|---|
ArrayRelDataType |
Flink distinguishes between primitive arrays (int[], double[], ...) and
object arrays (Integer[], MyPojo[], ...).
|
CompositeRelDataType |
Composite type for encapsulating Flink's
CompositeType . |
CompositeRelDataType$ | |
DataSetTable<T> | |
DataSetTable$ | |
DataStreamTable<T> | |
DataStreamTable$ | |
FlinkTable<T> | |
FlinkTableFunctionImpl<T> |
This is heavily inspired by Calcite's
TableFunctionImpl . |
GenericRelDataType |
Generic type for encapsulating Flink's
TypeInformation . |
MapRelDataType | |
RelTable |
A
Table implementation for registering
Table API Tables in the Calcite schema to be used by Flink SQL. |
RowSchema |
Schema that describes both a logical and physical row.
|
StreamTableSourceTable<T> | |
StreamTableSourceTable$ | |
TableSourceTable<T> |
Table which defines an external table via a
TableSource |
TableSourceTable$ | |
TimeIndicatorRelDataType |
Creates a time indicator type for event-time or processing-time, but with similar properties
as a basic SQL type.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.