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> | |
DataStreamTable<T> | |
DefaultDataSetStatistic | |
FlinkTable<T> | |
FlinkTableFunctionImpl<T> |
This is heavily inspired by Calcite's
TableFunctionImpl . |
GenericRelDataType |
Generic type for encapsulating Flink's
TypeInformation . |
RelTable |
A
Table implementation for registering
Table API Tables in the Calcite schema to be used by Flink SQL. |
TableSourceTable<T> |
Table which defines an external table via a
TableSource |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.