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 and Description |
---|
StormSql() |
Modifier and Type | Method and 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.
|
public static StormSql construct()
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.
Exception
Copyright © 2022 The Apache Software Foundation. All rights reserved.