Package org.apache.storm.sql
Class StormSql
java.lang.Object
org.apache.storm.sql.StormSql
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
-
Method Summary
Modifier and TypeMethodDescriptionstatic StormSql
abstract void
Print out query plan for each query.abstract void
submit
(String name, Iterable<String> statements, Map<String, Object> topoConf, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submit the SQL statements to Nimbus and run it as a topology.
-
Constructor Details
-
StormSql
public StormSql()
-
-
Method Details
-
construct
-
submit
public abstract void submit(String name, Iterable<String> statements, Map<String, Object> topoConf, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) throws ExceptionSubmit the SQL statements to Nimbus and run it as a topology.- Throws:
Exception
-
explain
Print out query plan for each query.- Throws:
Exception
-