Package org.apache.beam.sdk.extensions.sql.impl

package org.apache.beam.sdk.extensions.sql.impl

Implementation classes of BeamSql.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql	BeamSQL provides a new interface to run a SQL statement with Beam.
org.apache.beam.sdk.extensions.sql.impl.cep	Utilities for Complex Event Processing (CEP).
org.apache.beam.sdk.extensions.sql.impl.nfa	Package of Non-deterministic Finite Automata (NFA) for MATCH_RECOGNIZE.
org.apache.beam.sdk.extensions.sql.impl.parser	Beam SQL parsing additions to Calcite SQL.
org.apache.beam.sdk.extensions.sql.impl.planner	BeamQueryPlanner is the main interface.
org.apache.beam.sdk.extensions.sql.impl.rel	BeamSQL specified nodes, to replace RelNode.
org.apache.beam.sdk.extensions.sql.impl.rule	RelOptRule to generate BeamRelNode.
org.apache.beam.sdk.extensions.sql.impl.schema	define table schema, to map with Beam IO components.
org.apache.beam.sdk.extensions.sql.impl.transform	PTransform used in a BeamSql pipeline.
org.apache.beam.sdk.extensions.sql.impl.udaf	UDAF classes.
org.apache.beam.sdk.extensions.sql.impl.udf	UDF classes.
org.apache.beam.sdk.extensions.sql.impl.utils	Utility classes.

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.
BeamSqlPipelineOptions	Options used to configure BeamSQL.
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
JavaUdfLoader	Loads UdfProvider implementations from user-provided jars.
JdbcConnection	Beam JDBC Connection.
JdbcDriver	Calcite JDBC driver with Beam defaults.
LazyAggregateCombineFn<InputT,AccumT,OutputT>	Combine.CombineFn that wraps an AggregateFn.
ParseException	Exception thrown when Beam SQL is unable to parse the statement.
QueryPlanner	An interface that planners should implement to convert sql statement to BeamRelNode or SqlNode.
QueryPlanner.Factory
QueryPlanner.QueryParameters
QueryPlanner.QueryParameters.Kind
ScalarFnReflector	Reflection-based implementation logic for ScalarFn.
ScalarFunctionImpl	Beam-customized version from ScalarFunctionImpl , to address BEAM-5921.
SqlConversionException	Exception thrown when BeamSQL cannot convert sql to BeamRelNode.
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.
ZetaSqlUserDefinedSQLNativeTableValuedFunction	This is a class to indicate that a TVF is a ZetaSQL SQL native UDTVF.