Package org.apache.storm
Class Thrift
java.lang.Object
org.apache.storm.Thrift
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
static class
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic StormTopology
buildTopology
(HashMap<String, Thrift.SpoutDetails> spoutMap, HashMap<String, Thrift.BoltDetails> boltMap, HashMap<String, StateSpoutSpec> stateMap) static StormTopology
buildTopology
(Map<String, Thrift.SpoutDetails> spoutMap, Map<String, Thrift.BoltDetails> boltMap) static Object
static StreamInfo
directOutputFields
(List<String> fields) fieldGrouping
(Grouping grouping) static int
getParallelismHint
(ComponentCommon componentCommon) static StormTopology._Fields[]
static StormTopology._Fields[]
static Grouping._Fields
groupingType
(Grouping grouping) static Object
static boolean
isGlobalGrouping
(Grouping grouping) static StreamInfo
outputFields
(List<String> fields) static Grouping
static Thrift.BoltDetails
prepareBoltDetails
(Map<GlobalStreamId, Grouping> inputs, Object bolt) static Thrift.BoltDetails
prepareBoltDetails
(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint) static Thrift.BoltDetails
prepareBoltDetails
(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint, Map<String, Object> conf) static ComponentCommon
prepareComponentCommon
(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint) static ComponentCommon
prepareComponentCommon
(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) static Grouping
static Grouping
static Grouping
static Grouping
prepareFieldsGrouping
(List<String> fields) static Grouping
static Grouping
static Grouping
static Bolt
prepareSerializedBoltDetails
(Map<GlobalStreamId, Grouping> inputs, IBolt bolt, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) static SpoutSpec
prepareSerializedSpoutDetails
(IRichSpout spout, Map<String, StreamInfo> outputs) static Grouping
static Thrift.SpoutDetails
prepareSpoutDetails
(IRichSpout spout) static Thrift.SpoutDetails
prepareSpoutDetails
(IRichSpout spout, Integer parallelismHint) static Thrift.SpoutDetails
prepareSpoutDetails
(IRichSpout spout, Integer parallelismHint, Map<String, Object> conf) static ComponentObject
-
Constructor Details
-
Thrift
public Thrift()
-
-
Method Details
-
getTopologyFields
-
getSpoutFields
-
directOutputFields
-
outputFields
-
prepareShuffleGrouping
-
prepareLocalOrShuffleGrouping
-
prepareFieldsGrouping
-
prepareGlobalGrouping
-
prepareDirectGrouping
-
prepareAllGrouping
-
prepareNoneGrouping
-
prepareCustomStreamGrouping
-
prepareCustomJavaObjectGrouping
-
instantiateJavaObject
-
groupingType
-
fieldGrouping
-
isGlobalGrouping
-
getParallelismHint
-
serializeComponentObject
-
deserializeComponentObject
-
prepareComponentCommon
public static ComponentCommon prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint) -
prepareComponentCommon
public static ComponentCommon prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) -
prepareSerializedSpoutDetails
public static SpoutSpec prepareSerializedSpoutDetails(IRichSpout spout, Map<String, StreamInfo> outputs) -
prepareSerializedBoltDetails
-
prepareBoltDetails
public static Thrift.BoltDetails prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt) -
prepareBoltDetails
public static Thrift.BoltDetails prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint) -
prepareBoltDetails
public static Thrift.BoltDetails prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint, Map<String, Object> conf) -
prepareSpoutDetails
-
prepareSpoutDetails
-
prepareSpoutDetails
public static Thrift.SpoutDetails prepareSpoutDetails(IRichSpout spout, Integer parallelismHint, Map<String, Object> conf) -
buildTopology
public static StormTopology buildTopology(HashMap<String, Thrift.SpoutDetails> spoutMap, HashMap<String, Thrift.BoltDetails> boltMap, HashMap<String, StateSpoutSpec> stateMap) -
buildTopology
public static StormTopology buildTopology(Map<String, Thrift.SpoutDetails> spoutMap, Map<String, Thrift.BoltDetails> boltMap)
-