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 Summary
Modifier and TypeMethodDescriptionstatic TopologyDef
parseFile
(String inputFile, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) Parse a flux topology definition.static TopologyDef
parseInputStream
(InputStream inputStream, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) Parse a flux topology definition.static Properties
parseProperties
(String propertiesFile, boolean resource) Parse filter properties file.static TopologyDef
parseResource
(String resource, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) Parse a flux topology definition from a classpath resource..
-
Method Details
-
parseFile
public static TopologyDef parseFile(String inputFile, boolean dumpYaml, boolean processIncludes, Properties properties, boolean envSub) throws IOException Parse a flux topology definition.- Parameters:
inputFile
- source YAML filedumpYaml
- if true, dump the parsed YAML to stdoutprocessIncludes
- whether or not to process includesproperties
- properties file for variable substitutionenvSub
- whether or not to perform environment variable substitution- Returns:
- resulting topologuy definition
- Throws:
IOException
- if there is a problem reading file(s)
-
parseResource
public 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 resourcedumpYaml
- if true, dump the parsed YAML to stdoutprocessIncludes
- whether or not to process includesproperties
- properties file for variable substitutionenvSub
- whether or not to perform environment variable substitution- Returns:
- resulting topologuy definition
- Throws:
IOException
- if there is a problem reading file(s)
-
parseInputStream
public 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 filedumpYaml
- if true, dump the parsed YAML to stdoutprocessIncludes
- whether or not to process includesproperties
- properties file for variable substitutionenvSub
- whether or not to perform environment variable substitution- Returns:
- resulting topology definition
- Throws:
IOException
- if there is a problem reading file(s)
-
parseProperties
public static Properties parseProperties(String propertiesFile, boolean resource) throws IOException Parse filter properties file.- Parameters:
propertiesFile
- properties file for variable substitutionresource
- whether or not to load properties file from classpath- Returns:
- resulting filter properties
- Throws:
IOException
- if there is a problem reading file
-