Uses of Class
org.apache.storm.generated.GlobalStreamId
Package
Description
-
Uses of GlobalStreamId in org.apache.storm
Modifier and TypeMethodDescriptionstatic 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) static ComponentCommon
Thrift.prepareComponentCommon
(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint) static ComponentCommon
Thrift.prepareComponentCommon
(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) static Bolt
Thrift.prepareSerializedBoltDetails
(Map<GlobalStreamId, Grouping> inputs, IBolt bolt, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) -
Uses of GlobalStreamId in org.apache.storm.coordination
-
Uses of GlobalStreamId in org.apache.storm.daemon
Modifier and TypeMethodDescriptionstatic Map<GlobalStreamId,
Grouping> StormCommon.ackerInputs
(StormTopology topology) static Map<GlobalStreamId,
Grouping> StormCommon.eventLoggerInputs
(StormTopology topology) Modifier and TypeMethodDescriptionvoid
GrouperFactory.AllGrouper.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) void
GrouperFactory.BasicLoadAwareCustomStreamGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) void
GrouperFactory.FieldsGrouper.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) void
GrouperFactory.GlobalGrouper.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) void
GrouperFactory.NoneGrouper.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) -
Uses of GlobalStreamId in org.apache.storm.daemon.ui
Modifier and TypeMethodDescriptionUIHelpers.getInputMap
(Map.Entry<GlobalStreamId, Grouping> entryInput) getInputMap. -
Uses of GlobalStreamId in org.apache.storm.generated
Modifier and TypeMethodDescriptionBoltStats.get_acked()
BoltStats.get_execute_ms_avg()
BoltStats.get_executed()
BoltStats.get_failed()
ComponentPageInfo.get_gsid_to_input_stats()
ComponentCommon.get_inputs()
BoltStats.get_process_ms_avg()
Modifier and TypeMethodDescriptionint
GlobalStreamId.compareTo
(GlobalStreamId other) boolean
GlobalStreamId.equals
(GlobalStreamId that) void
ComponentPageInfo.put_to_gsid_to_input_stats
(GlobalStreamId key, ComponentAggregateStats val) void
ComponentCommon.put_to_inputs
(GlobalStreamId key, Grouping val) Modifier and TypeMethodDescriptionvoid
BoltStats.put_to_acked
(String key, Map<GlobalStreamId, Long> val) void
BoltStats.put_to_execute_ms_avg
(String key, Map<GlobalStreamId, Double> val) void
BoltStats.put_to_executed
(String key, Map<GlobalStreamId, Long> val) void
BoltStats.put_to_failed
(String key, Map<GlobalStreamId, Long> val) void
BoltStats.put_to_process_ms_avg
(String key, Map<GlobalStreamId, Double> val) void
void
BoltStats.set_execute_ms_avg
(Map<String, Map<GlobalStreamId, Double>> execute_ms_avg) void
BoltStats.set_executed
(Map<String, Map<GlobalStreamId, Long>> executed) void
BoltStats.set_failed
(Map<String, Map<GlobalStreamId, Long>> failed) void
ComponentPageInfo.set_gsid_to_input_stats
(Map<GlobalStreamId, ComponentAggregateStats> gsid_to_input_stats) void
ComponentCommon.set_inputs
(Map<GlobalStreamId, Grouping> inputs) void
BoltStats.set_process_ms_avg
(Map<String, Map<GlobalStreamId, Double>> process_ms_avg) ModifierConstructorDescriptionGlobalStreamId
(GlobalStreamId other) Performs a deep copy on other.ModifierConstructorDescriptionBoltStats
(Map<String, Map<GlobalStreamId, Long>> acked, Map<String, Map<GlobalStreamId, Long>> failed, Map<String, Map<GlobalStreamId, Double>> process_ms_avg, Map<String, Map<GlobalStreamId, Long>> executed, Map<String, Map<GlobalStreamId, Double>> execute_ms_avg) ComponentCommon
(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> streams) -
Uses of GlobalStreamId in org.apache.storm.grouping
Modifier and TypeMethodDescriptionvoid
CustomStreamGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) Tells the stream grouping at runtime the tasks in the target bolt.void
LoadAwareShuffleGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) void
PartialKeyGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) void
ShuffleGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) -
Uses of GlobalStreamId in org.apache.storm.loadgen
Modifier and TypeMethodDescriptionInputStream.gsid()
Get the global stream id for this input stream.Modifier and TypeMethodDescriptionOutputStream.remap
(String origId, Map<GlobalStreamId, GlobalStreamId> remappedStreams) OutputStream.remap
(String origId, Map<GlobalStreamId, GlobalStreamId> remappedStreams) -
Uses of GlobalStreamId in org.apache.storm.scheduler
ModifierConstructorDescriptionComponent
(ComponentType type, String compId, List<ExecutorDetails> execs, Map<GlobalStreamId, Grouping> inputs) Create a new component. -
Uses of GlobalStreamId in org.apache.storm.task
Modifier and TypeMethodDescriptionGeneralTopologyContext.getSources
(String componentId) Gets the declared inputs to the specified component.TopologyContext.getThisSources()
Gets the declared inputs to this component.Modifier and TypeMethodDescriptionGeneralTopologyContext.getComponentOutputFields
(GlobalStreamId id) Gets the declared output fields for the specified global stream id. -
Uses of GlobalStreamId in org.apache.storm.testing
Modifier and TypeMethodDescriptionvoid
NGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) -
Uses of GlobalStreamId in org.apache.storm.topology
Modifier and TypeMethodDescriptionInputDeclarer.grouping
(GlobalStreamId id, Grouping grouping) TopologyBuilder.BoltGetter.grouping
(GlobalStreamId id, Grouping grouping) -
Uses of GlobalStreamId in org.apache.storm.trident.partition
Modifier and TypeMethodDescriptionvoid
GlobalGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets) void
IdentityGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> tasks) void
IndexHashGrouping.prepare
(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) -
Uses of GlobalStreamId in org.apache.storm.trident.topology
Modifier and TypeFieldDescriptionTridentBoltExecutor.CoordCondition.commitStream
TridentBoltExecutor.CoordSpec.commitStream
ModifierConstructorDescriptionTridentBoltExecutor
(ITridentBatchBolt bolt, Map<GlobalStreamId, String> batchGroupIds, Map<String, TridentBoltExecutor.CoordSpec> coordinationSpecs) -
Uses of GlobalStreamId in org.apache.storm.tuple
Modifier and TypeMethodDescriptionTuple.getSourceGlobalStreamId()
Returns the global stream id (component + stream) of this tuple.TupleImpl.getSourceGlobalStreamId()
-
Uses of GlobalStreamId in org.apache.storm.utils
Modifier and TypeMethodDescriptionstatic GlobalStreamId
Utils.getGlobalStreamId
(String componentId, String streamId) -
Uses of GlobalStreamId in org.apache.storm.windowing
Modifier and TypeMethodDescriptionboolean
WaterMarkEventGenerator.track
(GlobalStreamId stream, long ts) Tracks the timestamp of the event in the stream, returns true if the event can be considered for processing or false if its a late event.ModifierConstructorDescriptionWaterMarkEventGenerator
(WindowManager<T> windowManager, int intervalMs, int eventTsLagMs, Set<GlobalStreamId> inputStreams) Creates a new WatermarkEventGenerator.