Package org.apache.storm.flux.parser
Class FluxParser
java.lang.Object
org.apache.storm.flux.parser.FluxParser
Static utility methods for parsing flux YAML.
- 
Method SummaryModifier and TypeMethodDescriptionstatic TopologyDefparseFile(String inputFile, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) Parse a flux topology definition.static TopologyDefparseInputStream(InputStream inputStream, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) Parse a flux topology definition.static PropertiesparseProperties(String propertiesFile, boolean resource) Parse filter properties file.static TopologyDefparseResource(String resource, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) Parse a flux topology definition from a classpath resource..
- 
Method Details- 
parseFilepublic static TopologyDef parseFile(String inputFile, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) throws IOException Parse a flux topology definition.- Parameters:
- inputFile- source YAML file
- dumpYaml- if true, dump the parsed YAML to stdout
- processIncludes- whether or not to process includes
- properties- properties file for variable substitution
- envSub- whether or not to perform environment variable substitution
- Returns:
- resulting topologuy definition
- Throws:
- IOException- if there is a problem reading file(s)
 
- 
parseResourcepublic static TopologyDef parseResource(String resource, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) throws IOException Parse a flux topology definition from a classpath resource..- Parameters:
- resource- YAML resource
- dumpYaml- if true, dump the parsed YAML to stdout
- processIncludes- whether or not to process includes
- properties- properties file for variable substitution
- envSub- whether or not to perform environment variable substitution
- Returns:
- resulting topologuy definition
- Throws:
- IOException- if there is a problem reading file(s)
 
- 
parseInputStreampublic static TopologyDef parseInputStream(InputStream inputStream, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) throws IOException Parse a flux topology definition.- Parameters:
- inputStream- InputStream representation of YAML file
- dumpYaml- if true, dump the parsed YAML to stdout
- processIncludes- whether or not to process includes
- properties- properties file for variable substitution
- envSub- whether or not to perform environment variable substitution
- Returns:
- resulting topology definition
- Throws:
- IOException- if there is a problem reading file(s)
 
- 
parsePropertiespublic static Properties parseProperties(String propertiesFile, boolean resource) throws IOException Parse filter properties file.- Parameters:
- propertiesFile- properties file for variable substitution
- resource- whether or not to load properties file from classpath
- Returns:
- resulting filter properties
- Throws:
- IOException- if there is a problem reading file
 
 
-