| Interface | Description |
|---|---|
| BeamSqlPipelineOptions |
Options used to configure BeamSQL.
|
| QueryPlanner |
An interface that planners should implement to convert sql statement to
BeamRelNode or
SqlNode. |
| Class | Description |
|---|---|
| BeamCalciteSchema |
Adapter from
TableProvider to Schema. |
| BeamCalciteTable |
Adapter from
BeamSqlTable to a calcite Table. |
| BeamSqlEnv |
Contains the metadata of tables/UDF functions, and exposes APIs to
query/validate/optimize/translate SQL statements.
|
| BeamSqlEnv.BeamSqlEnvBuilder |
BeamSqlEnv's Builder.
|
| BeamSqlPipelineOptionsRegistrar |
AutoService registrar for BeamSqlPipelineOptions. |
| BeamTableStatistics |
This class stores row count statistics.
|
| CalciteConnectionWrapper |
Abstract wrapper for
CalciteConnection to simplify extension. |
| CalciteFactoryWrapper |
Wrapper for
CalciteFactory. |
| CalciteQueryPlanner |
The core component to handle through a SQL statement, from explain execution plan, to generate a
Beam pipeline.
|
| CalciteQueryPlanner.NonCumulativeCostImpl | |
| JdbcConnection |
Beam JDBC Connection.
|
| JdbcDriver |
Calcite JDBC driver with Beam defaults.
|
| QueryPlanner.QueryParameters | |
| ScalarFunctionImpl |
Beam-customized version from
ScalarFunctionImpl , to
address BEAM-5921. |
| TableName |
Represents a parsed table name that is specified in a FROM clause (and other places).
|
| TVFSlidingWindowFn |
TVFSlidingWindowFn assigns window based on input row's "window_start" and "window_end"
timestamps.
|
| UdafImpl<InputT,AccumT,OutputT> |
Implement
AggregateFunction to take a Combine.CombineFn as UDAF. |
| UdfImplReflectiveFunctionBase |
Beam-customized version from
ReflectiveFunctionBase, to address BEAM-5921. |
| UdfImplReflectiveFunctionBase.ParameterListBuilder |
Helps build lists of
FunctionParameter. |
| Enum | Description |
|---|---|
| QueryPlanner.QueryParameters.Kind |
| Exception | Description |
|---|---|
| ParseException |
Exception thrown when Beam SQL is unable to parse the statement.
|
| SqlConversionException |
Exception thrown when BeamSQL cannot convert sql to BeamRelNode.
|