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 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
-
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
-