Modifier and Type | Method and Description |
---|---|
static Config |
FluxBuilder.buildConfig(TopologyDef topologyDef)
Given a topology definition, return a populated
org.apache.storm.Config instance. |
Constructor and Description |
---|
ExecutionContext(TopologyDef topologyDef,
Config config) |
Modifier and Type | Method and Description |
---|---|
static void |
AvroUtils.addAvroKryoSerializations(Config conf)
A helper method to extract avro serialization configurations from the topology configuration and register specific kryo serializers as necessary.
|
Modifier and Type | Method and Description |
---|---|
static Config |
LocalSubmitter.defaultConfig() |
static Config |
LocalSubmitter.defaultConfig(boolean debug) |
Modifier and Type | Method and Description |
---|---|
void |
LocalSubmitter.submit(String name,
Config config,
StormTopology topology) |
Modifier and Type | Method and Description |
---|---|
protected Config |
SolrTopology.getConfig() |
Modifier and Type | Method and Description |
---|---|
protected void |
SolrTopology.submitTopologyLocalCluster(StormTopology topology,
Config config) |
protected void |
SolrTopology.submitTopologyRemoteCluster(String arg,
StormTopology topology,
Config config) |
Modifier and Type | Method and Description |
---|---|
static void |
StormRunner.runTopologyLocally(StormTopology topology,
String topologyName,
Config conf,
int runtimeInSeconds) |
static void |
StormRunner.runTopologyRemotely(StormTopology topology,
String topologyName,
Config conf) |
Modifier and Type | Method and Description |
---|---|
Config |
CompleteTopologyParam.getStormConf() |
Modifier and Type | Method and Description |
---|---|
void |
CompleteTopologyParam.setStormConf(Config stormConf) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.