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 . |
CalciteConnectionWrapper |
Abstract wrapper for
CalciteConnection to simplify extension. |
CalciteFactoryWrapper |
Wrapper for
CalciteFactory . |
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.
|
SqlConversionException |
Exception thrown when BeamSQL cannot convert sql to BeamRelNode.
|