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
IOException
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.