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

Class BeamSqlCli

java.lang.Object

org.apache.beam.sdk.extensions.sql.BeamSqlCli

@Internal
public class BeamSqlCli
extends Object

BeamSqlCli provides methods to execute Beam SQL with an interactive client.

Constructor Summary

Constructors

Constructor	Description
BeamSqlCli()

Method Summary

Modifier and Type	Method	Description
BeamSqlCli	build(BeamSqlEnv.BeamSqlEnvBuilder builder, boolean autoLoadUdfUdaf, PipelineOptions pipelineOptions)
BeamSqlCli	catalogManager(CatalogManager catalogManager)
void	execute(String sqlString)	Executes the given sql.
String	explainQuery(String sqlString)	Returns a human readable representation of the query execution plan.
MetaStore	getMetaStore()
BeamSqlCli	metaStore(MetaStore metaStore)

Methods inherited from class java.lang.Object

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

Constructor Details

BeamSqlCli

public BeamSqlCli()

Method Details

catalogManager

public BeamSqlCli catalogManager(CatalogManager catalogManager)

metaStore

public BeamSqlCli metaStore(MetaStore metaStore)

build

public BeamSqlCli build(BeamSqlEnv.BeamSqlEnvBuilder builder,
 boolean autoLoadUdfUdaf,
 PipelineOptions pipelineOptions)

getMetaStore

public MetaStore getMetaStore()

explainQuery

public String explainQuery(String sqlString)
                    throws ParseException

Returns a human readable representation of the query execution plan.

Throws:

ParseException

execute

public void execute(String sqlString)
             throws ParseException

Executes the given sql.

Throws:

ParseException