| Class | Description |
|---|---|
| BeamCalciteSchema |
Adapter from
TableProvider to Schema. |
| BeamCalciteSchemaFactory |
Factory that creates a
BeamCalciteSchema. |
| BeamSqlEnv |
Contains the metadata of tables/UDF functions, and exposes APIs to
query/validate/optimize/translate SQL statements.
|
| JdbcDriver |
Calcite JDBC driver with Beam defaults.
|
| UdafImpl<InputT,AccumT,OutputT> |
Implement
AggregateFunction to take a Combine.CombineFn as UDAF. |
| UdfImpl |
Beam-customized version from
ScalarFunctionImpl, to address BEAM-5921. |
| 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.
|