@Internal public class BeamSqlCli extends java.lang.Object
BeamSqlCli
provides methods to execute Beam SQL with an interactive client.Constructor and Description |
---|
BeamSqlCli() |
Modifier and Type | Method and Description |
---|---|
BeamSqlCli |
build(BeamSqlEnv.BeamSqlEnvBuilder builder,
boolean autoLoadUdfUdaf,
PipelineOptions pipelineOptions) |
BeamSqlCli |
catalogManager(CatalogManager catalogManager) |
void |
execute(java.lang.String sqlString)
Executes the given sql.
|
java.lang.String |
explainQuery(java.lang.String sqlString)
Returns a human readable representation of the query execution plan.
|
MetaStore |
getMetaStore() |
BeamSqlCli |
metaStore(MetaStore metaStore) |
public BeamSqlCli catalogManager(CatalogManager catalogManager)
public BeamSqlCli metaStore(MetaStore metaStore)
public BeamSqlCli build(BeamSqlEnv.BeamSqlEnvBuilder builder, boolean autoLoadUdfUdaf, PipelineOptions pipelineOptions)
public MetaStore getMetaStore()
public java.lang.String explainQuery(java.lang.String sqlString) throws ParseException
ParseException
public void execute(java.lang.String sqlString) throws ParseException
ParseException