org.apache.storm.sql

Class StormSql

java.lang.Object

org.apache.storm.sql.StormSql

public abstract class StormSql
extends Object

The StormSql class provides standalone, interactive interfaces to execute SQL statements over streaming data.

The StormSql class is stateless. The user needs to submit the data definition language (DDL) statements and the query statements in the same batch.

Constructor Summary

Constructors

Constructor and Description
StormSql()

Method Summary

Modifier and Type	Method and Description
static StormSql	construct()
abstract void	execute(Iterable<String> statements, ChannelHandler handler) Execute the SQL statements in stand-alone mode.
abstract void	explain(Iterable<String> statements) Print out query plan for each query.
abstract void	submit(String name, Iterable<String> statements, Map<String,?> stormConf, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submit the SQL statements to Nimbus and run it as a topology.

Methods inherited from class java.lang.Object

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

Constructor Detail

StormSql

public StormSql()

Method Detail

execute

public abstract void execute(Iterable<String> statements,
                             ChannelHandler handler)
                      throws Exception

Execute the SQL statements in stand-alone mode. The user can retrieve the result by passing in an instance of ChannelHandler.

Throws:

Exception

submit

public abstract void submit(String name,
                            Iterable<String> statements,
                            Map<String,?> stormConf,
                            SubmitOptions opts,
                            StormSubmitter.ProgressListener progressListener,
                            String asUser)
                     throws Exception

Submit the SQL statements to Nimbus and run it as a topology.

Throws:

Exception

explain

public abstract void explain(Iterable<String> statements)
                      throws Exception

Print out query plan for each query.

Throws:

Exception

construct

public static StormSql construct()