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
- -Query
public static Query prepareQuery(java.util.Map map)
map
- Query
public static void initializeSchemas(java.util.Map conf, java.lang.String id)
conf
-