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

Class BeamSqlEnv

java.lang.Object

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

@Internal
public class BeamSqlEnv
extends Object

Contains the metadata of tables/UDF functions, and exposes APIs to query/validate/optimize/translate SQL statements.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BeamSqlEnv.BeamSqlEnvBuilder	BeamSqlEnv's Builder.

Method Summary

Modifier and Type	Method	Description
static BeamSqlEnv.BeamSqlEnvBuilder	builder(CatalogManager catalogManager)	Creates a builder with the default schema backed by the catalog manager.
static BeamSqlEnv.BeamSqlEnvBuilder	builder(TableProvider tableProvider)	Creates a builder with the default schema backed by the table provider.
void	executeDdl(String sqlStatement)
String	explain(String sqlString)
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.jdbc.CalcitePrepare.Context	getContext()
Map<String,String>	getPipelineOptions()
static BeamSqlEnv	inMemory(TableProvider... tableProviders)	This method creates BeamSqlEnv using empty * Pipeline Options.
boolean	isDdl(String sqlStatement)
BeamRelNode	parseQuery(String query)
BeamRelNode	parseQuery(String query, QueryPlanner.QueryParameters queryParameters)
static BeamSqlEnv	readOnly(String tableType, Map<String,BeamSqlTable> tables)	This method creates BeamSqlEnv using empty Pipeline Options.
static BeamSqlEnv	withTableProvider(TableProvider tableProvider)	This method creates BeamSqlEnv using empty Pipeline Options.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static BeamSqlEnv.BeamSqlEnvBuilder builder(TableProvider tableProvider)

Creates a builder with the default schema backed by the table provider.

builder

public static BeamSqlEnv.BeamSqlEnvBuilder builder(CatalogManager catalogManager)

Creates a builder with the default schema backed by the catalog manager.

readOnly

public static BeamSqlEnv readOnly(String tableType,
 Map<String,BeamSqlTable> tables)

This method creates BeamSqlEnv using empty Pipeline Options. It should only be used in tests.

withTableProvider

public static BeamSqlEnv withTableProvider(TableProvider tableProvider)

This method creates BeamSqlEnv using empty Pipeline Options. It should only be used in tests.

inMemory

public static BeamSqlEnv inMemory(TableProvider... tableProviders)

This method creates BeamSqlEnv using empty * Pipeline Options. It should only be used in tests.

parseQuery

public BeamRelNode parseQuery(String query)
                       throws ParseException

Throws:

ParseException

parseQuery

public BeamRelNode parseQuery(String query,
 QueryPlanner.QueryParameters queryParameters)
                       throws ParseException

Throws:

ParseException

isDdl

public boolean isDdl(String sqlStatement)
              throws ParseException

Throws:

ParseException

executeDdl

public void executeDdl(String sqlStatement)
                throws ParseException

Throws:

ParseException

getContext

public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.jdbc.CalcitePrepare.Context getContext()

getPipelineOptions

public Map<String,String> getPipelineOptions()

explain

public String explain(String sqlString)
               throws ParseException

Throws:

ParseException