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

Class BeamSqlCli

java.lang.Object

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

@Experimental
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
static PCollection<BeamRecord>	compilePipeline(java.lang.String sqlStatement, BeamSqlEnv sqlEnv) compile SQL, and return a Pipeline.
static PCollection<BeamRecord>	compilePipeline(java.lang.String sqlStatement, Pipeline basePipeline, BeamSqlEnv sqlEnv) compile SQL, and return a Pipeline.
static java.lang.String	explainQuery(java.lang.String sqlString, BeamSqlEnv sqlEnv) Returns a human readable representation of the query execution plan.

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

explainQuery

public static java.lang.String explainQuery(java.lang.String sqlString,
                                            BeamSqlEnv sqlEnv)
                                     throws java.lang.Exception

Returns a human readable representation of the query execution plan.

Throws:

java.lang.Exception

compilePipeline

public static PCollection<BeamRecord> compilePipeline(java.lang.String sqlStatement,
                                                      BeamSqlEnv sqlEnv)
                                               throws java.lang.Exception

compile SQL, and return a Pipeline.

Throws:

java.lang.Exception

compilePipeline

public static PCollection<BeamRecord> compilePipeline(java.lang.String sqlStatement,
                                                      Pipeline basePipeline,
                                                      BeamSqlEnv sqlEnv)
                                               throws java.lang.Exception

compile SQL, and return a Pipeline.

Throws:

java.lang.Exception