org.apache.beam.sdk.extensions.sql

Class BeamSqlCli

java.lang.Object

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

public class BeamSqlCli
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
BeamSqlCli()

Method Summary

Modifier and Type	Method and Description
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)
BeamSqlCli	metaStore(MetaStore metaStore, boolean autoLoadUdfUdaf, PipelineOptions pipelineOptions)

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamSqlCli

public BeamSqlCli()

Method Detail

metaStore

public BeamSqlCli metaStore(MetaStore metaStore)

metaStore

public BeamSqlCli metaStore(MetaStore metaStore,
                            boolean autoLoadUdfUdaf,
                            PipelineOptions pipelineOptions)

getMetaStore

public MetaStore getMetaStore()

explainQuery

public java.lang.String explainQuery(java.lang.String sqlString)
                              throws ParseException

Returns a human readable representation of the query execution plan.

Throws:

ParseException

execute

public void execute(java.lang.String sqlString)
             throws ParseException

Executes the given sql.

Throws:

ParseException