Package org.apache.storm
Class Thrift
java.lang.Object
org.apache.storm.Thrift
- 
Nested Class SummaryNested ClassesModifier and TypeClassDescriptionstatic classstatic class
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic StormTopologybuildTopology(HashMap<String, Thrift.SpoutDetails> spoutMap, HashMap<String, Thrift.BoltDetails> boltMap, HashMap<String, StateSpoutSpec> stateMap) static StormTopologybuildTopology(Map<String, Thrift.SpoutDetails> spoutMap, Map<String, Thrift.BoltDetails> boltMap) static Objectstatic StreamInfodirectOutputFields(List<String> fields) fieldGrouping(Grouping grouping) static intgetParallelismHint(ComponentCommon componentCommon) static StormTopology._Fields[]static StormTopology._Fields[]static Grouping._FieldsgroupingType(Grouping grouping) static Objectstatic booleanisGlobalGrouping(Grouping grouping) static StreamInfooutputFields(List<String> fields) static Groupingstatic Thrift.BoltDetailsprepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt) static Thrift.BoltDetailsprepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint) static Thrift.BoltDetailsprepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint, Map<String, Object> conf) static ComponentCommonprepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint) static ComponentCommonprepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) static Groupingstatic Groupingstatic Groupingstatic GroupingprepareFieldsGrouping(List<String> fields) static Groupingstatic Groupingstatic Groupingstatic BoltprepareSerializedBoltDetails(Map<GlobalStreamId, Grouping> inputs, IBolt bolt, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) static SpoutSpecprepareSerializedSpoutDetails(IRichSpout spout, Map<String, StreamInfo> outputs) static Groupingstatic Thrift.SpoutDetailsprepareSpoutDetails(IRichSpout spout) static Thrift.SpoutDetailsprepareSpoutDetails(IRichSpout spout, Integer parallelismHint) static Thrift.SpoutDetailsprepareSpoutDetails(IRichSpout spout, Integer parallelismHint, Map<String, Object> conf) static ComponentObject
- 
Constructor Details- 
Thriftpublic Thrift()
 
- 
- 
Method Details- 
getTopologyFields
- 
getSpoutFields
- 
directOutputFields
- 
outputFields
- 
prepareShuffleGrouping
- 
prepareLocalOrShuffleGrouping
- 
prepareFieldsGrouping
- 
prepareGlobalGrouping
- 
prepareDirectGrouping
- 
prepareAllGrouping
- 
prepareNoneGrouping
- 
prepareCustomStreamGrouping
- 
prepareCustomJavaObjectGrouping
- 
instantiateJavaObject
- 
groupingType
- 
fieldGrouping
- 
isGlobalGrouping
- 
getParallelismHint
- 
serializeComponentObject
- 
deserializeComponentObject
- 
prepareComponentCommonpublic static ComponentCommon prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint) 
- 
prepareComponentCommonpublic static ComponentCommon prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) 
- 
prepareSerializedSpoutDetailspublic static SpoutSpec prepareSerializedSpoutDetails(IRichSpout spout, Map<String, StreamInfo> outputs) 
- 
prepareSerializedBoltDetails
- 
prepareBoltDetailspublic static Thrift.BoltDetails prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt) 
- 
prepareBoltDetailspublic static Thrift.BoltDetails prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint) 
- 
prepareBoltDetailspublic static Thrift.BoltDetails prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint, Map<String, Object> conf) 
- 
prepareSpoutDetails
- 
prepareSpoutDetails
- 
prepareSpoutDetailspublic static Thrift.SpoutDetails prepareSpoutDetails(IRichSpout spout, Integer parallelismHint, Map<String, Object> conf) 
- 
buildTopologypublic static StormTopology buildTopology(HashMap<String, Thrift.SpoutDetails> spoutMap, HashMap<String, Thrift.BoltDetails> boltMap, HashMap<String, StateSpoutSpec> stateMap) 
- 
buildTopologypublic static StormTopology buildTopology(Map<String, Thrift.SpoutDetails> spoutMap, Map<String, Thrift.BoltDetails> boltMap) 
 
-