Package | Description |
---|---|
org.apache.storm |
Modifier and Type | Method and Description |
---|---|
static Thrift.BoltDetails |
Thrift.prepareBoltDetails(Map<GlobalStreamId,Grouping> inputs,
Object bolt) |
static Thrift.BoltDetails |
Thrift.prepareBoltDetails(Map<GlobalStreamId,Grouping> inputs,
Object bolt,
Integer parallelismHint) |
static Thrift.BoltDetails |
Thrift.prepareBoltDetails(Map<GlobalStreamId,Grouping> inputs,
Object bolt,
Integer parallelismHint,
Map<String,Object> conf) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
Thrift.buildTopology(HashMap<String,Thrift.SpoutDetails> spoutMap,
HashMap<String,Thrift.BoltDetails> boltMap,
HashMap<String,StateSpoutSpec> stateMap) |
static StormTopology |
Thrift.buildTopology(Map<String,Thrift.SpoutDetails> spoutMap,
Map<String,Thrift.BoltDetails> boltMap) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.