Class FluxParser

java.lang.Object
org.apache.storm.flux.parser.FluxParser

public class FluxParser extends Object
Static utility methods for parsing flux YAML.
  • 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 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)
    • 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 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)
    • 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 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)
    • parseProperties

      public 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