Class | Description |
---|---|
BatchTableEnvironment |
The abstract base class for batch TableEnvironments.
|
ExpressionParserException$ | |
FlinkCalciteSqlValidator |
This is a copy of Calcite's CalciteSqlValidator to use with
FlinkPlannerImpl . |
FlinkPlannerImpl |
NOTE: this is heavily inspired by Calcite's PlannerImpl.
|
FlinkPlannerImpl$ | |
FlinkRelBuilder |
Flink specific
RelBuilder that changes the default type factory to a FlinkTypeFactory . |
FlinkRelBuilder$ | |
FlinkTypeFactory |
Flink specific type factory that represents the interface between Flink's
TypeInformation
and Calcite's RelDataType . |
FlinkTypeFactory$ | |
FlinkTypeSystem |
Custom type system for Flink.
|
GroupedTable |
A table that has been grouped on a set of grouping keys.
|
Row |
This is used for executing Table API operations.
|
StreamTableEnvironment |
The base class for stream TableEnvironments.
|
Table |
A Table is the core component of the Table API.
|
TableConfig |
A config to define the runtime behavior of the Table API.
|
TableConfig$ | |
TableEnvironment |
The abstract base class for batch and stream TableEnvironments.
|
TableEnvironment$ |
Object to instantiate a
TableEnvironment depending on the batch or stream execution
environment. |
TableException$ | |
Types |
This class enumerates all supported types of the Table API.
|
Types$ |
This class enumerates all supported types of the Table API.
|
UnresolvedException$ | |
ValidationException$ |
Exception | Description |
---|---|
ExpressionParserException |
Exception for all errors occurring during expression parsing.
|
TableException |
General Exception for all errors during table handling.
|
UnresolvedException |
Exception for unwanted method calling on unresolved expression.
|
ValidationException |
Exception for all errors occurring during validation phase.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.