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.