Package org.apache.storm
Class Thrift
java.lang.Object
org.apache.storm.Thrift
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic class -
Constructor Summary
Constructors -
Method Summary
Modifier 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
-
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)
-