| Package | Description | 
|---|---|
| org.apache.storm.flux | |
| org.apache.storm.flux.model | |
| org.apache.storm.flux.parser | 
| Modifier and Type | Method and Description | 
|---|---|
static Config | 
FluxBuilder.buildConfig(TopologyDef topologyDef)
Given a topology definition, return a populated  
org.apache.storm.Config instance. | 
| Modifier and Type | Method and Description | 
|---|---|
TopologyDef | 
ExecutionContext.getTopologyDef()  | 
| Constructor and Description | 
|---|
ExecutionContext(TopologyDef topologyDef,
                Config config)  | 
| Modifier and Type | Method and Description | 
|---|---|
static TopologyDef | 
FluxParser.parseFile(String inputFile,
         boolean dumpYaml,
         boolean processIncludes,
         Properties properties,
         boolean envSub)
Parse a flux topology definition. 
 | 
static TopologyDef | 
FluxParser.parseInputStream(InputStream inputStream,
                boolean dumpYaml,
                boolean processIncludes,
                Properties properties,
                boolean envSub)
Parse a flux topology definition. 
 | 
static TopologyDef | 
FluxParser.parseResource(String resource,
             boolean dumpYaml,
             boolean processIncludes,
             Properties properties,
             boolean envSub)
Parse a flux topology definition from a classpath resource.. 
 | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.