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 SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic StormSqlabstract voidPrint out query plan for each query.abstract voidsubmit(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- 
StormSqlpublic StormSql()
 
- 
- 
Method Details- 
construct
- 
submitpublic 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
 
- 
explainPrint out query plan for each query.- Throws:
- Exception
 
 
-