Package 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
  Description
  `StormSql()`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `static StormSql`
  `construct()`
  `abstract void`
  `explain(Iterable<String> statements)`
  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.

  ### Methods inherited from class java.lang.Object

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

- ## Constructor Details

  - ### StormSql

    public StormSql()

- ## Method Details

  - ### construct

    public static StormSql construct()

  - ### submit

    public abstract void submit(String name, Iterable<String> statements, Map<String,Object> topoConf, 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`