| 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.
|
| CalciteConnectionWrapper |
Abstract wrapper for
CalciteConnection to simplify extension. |
| JdbcConnection |
Beam JDBC Connection.
|
| JdbcDriver |
Calcite JDBC driver with Beam defaults.
|
| ScalarFunctionImpl |
Beam-customized version from
ScalarFunctionImpl, to
address BEAM-5921. |
| 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. |
| Exception | Description |
|---|---|
| ParseException |
Exception thrown when Beam SQL is unable to parse the statement.
|