@Internal @Experimental public class BeamSqlEnv extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
BeamSqlEnv.BeamSqlEnvBuilder
BeamSqlEnv's Builder.
|
Modifier and Type | Method and Description |
---|---|
static BeamSqlEnv.BeamSqlEnvBuilder |
builder(TableProvider tableProvider)
Creates a builder with the default schema backed by the table provider.
|
void |
executeDdl(java.lang.String sqlStatement) |
java.lang.String |
explain(java.lang.String sqlString) |
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalcitePrepare.Context |
getContext() |
java.util.Map<java.lang.String,java.lang.String> |
getPipelineOptions() |
static BeamSqlEnv |
inMemory(TableProvider... tableProviders)
This method creates
BeamSqlEnv using empty *
Pipeline Options. |
boolean |
isDdl(java.lang.String sqlStatement) |
BeamRelNode |
parseQuery(java.lang.String query) |
BeamRelNode |
parseQuery(java.lang.String query,
QueryPlanner.QueryParameters queryParameters) |
static BeamSqlEnv |
readOnly(java.lang.String tableType,
java.util.Map<java.lang.String,BeamSqlTable> tables)
This method creates
BeamSqlEnv using empty
Pipeline Options. |
static BeamSqlEnv |
withTableProvider(TableProvider tableProvider)
This method creates
BeamSqlEnv using empty
Pipeline Options. |
public static BeamSqlEnv.BeamSqlEnvBuilder builder(TableProvider tableProvider)
public static BeamSqlEnv readOnly(java.lang.String tableType, java.util.Map<java.lang.String,BeamSqlTable> tables)
BeamSqlEnv
using empty
Pipeline Options. It should only be used in tests.public static BeamSqlEnv withTableProvider(TableProvider tableProvider)
BeamSqlEnv
using empty
Pipeline Options. It should only be used in tests.public static BeamSqlEnv inMemory(TableProvider... tableProviders)
BeamSqlEnv
using empty *
Pipeline Options. It should only be used in tests.public BeamRelNode parseQuery(java.lang.String query) throws ParseException
ParseException
public BeamRelNode parseQuery(java.lang.String query, QueryPlanner.QueryParameters queryParameters) throws ParseException
ParseException
public boolean isDdl(java.lang.String sqlStatement) throws ParseException
ParseException
public void executeDdl(java.lang.String sqlStatement) throws ParseException
ParseException
public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalcitePrepare.Context getContext()
public java.util.Map<java.lang.String,java.lang.String> getPipelineOptions()
public java.lang.String explain(java.lang.String sqlString) throws ParseException
ParseException