public static class SQLHandler.SQLTupleStreamParser extends Object
| Constructor and Description |
|---|
SQLTupleStreamParser() |
| Modifier and Type | Method and Description |
|---|---|
static TupleStream |
parse(String sql,
int numWorkers,
String workerCollection,
String workerZkhost,
SQLHandler.AggregationMode aggregationMode,
boolean includeMetadata,
StreamContext context) |
public static TupleStream parse(String sql, int numWorkers, String workerCollection, String workerZkhost, SQLHandler.AggregationMode aggregationMode, boolean includeMetadata, StreamContext context) throws IOException
IOExceptionCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.