public class StormUtils
extends java.lang.Object
| Constructor and Description |
|---|
StormUtils() |
| Modifier and Type | Method and Description |
|---|---|
static Query |
getQuery(boolean useHdfs,
java.lang.String hdfsUri,
java.lang.String queryFile)
Method to read in serialized Query object from the given queryFile
|
static void |
initializeSchemas(java.util.Map conf,
java.lang.String id)
Initialize data and query schema.
|
static Query |
prepareQuery(java.util.Map map)
Method to read in and return a serialized Query object from the given file and initialize/load the query.schemas and data.schemas
|
public static Query getQuery(boolean useHdfs, java.lang.String hdfsUri, java.lang.String queryFile)
useHdfs - - true or falsehdfsUri - - HDFS pathqueryFile - -Querypublic static Query prepareQuery(java.util.Map map)
map - Querypublic static void initializeSchemas(java.util.Map conf,
java.lang.String id)
conf -