Uses of Class
org.apache.storm.generated.GlobalStreamId

Packages that use GlobalStreamId

Package	Description
org.apache.storm.cassandra
org.apache.storm.coordination
org.apache.storm.generated
org.apache.storm.grouping
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.trident.partition
org.apache.storm.trident.topology
org.apache.storm.tuple
org.apache.storm.utils
org.apache.storm.windowing

Uses of GlobalStreamId in org.apache.storm.cassandra

Methods in org.apache.storm.cassandra with parameters of type GlobalStreamId

Modifier and Type	Method and Description
void	Murmur3StreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) Tells the stream grouping at runtime the tasks in the target bolt.

Uses of GlobalStreamId in org.apache.storm.coordination

Methods in org.apache.storm.coordination that return GlobalStreamId

Modifier and Type	Method and Description
GlobalStreamId	CoordinatedBolt.IdStreamSpec.getGlobalStreamId()

Uses of GlobalStreamId in org.apache.storm.generated

Methods in org.apache.storm.generated that return GlobalStreamId

Modifier and Type	Method and Description
GlobalStreamId	GlobalStreamId.deepCopy()

Methods in org.apache.storm.generated that return types with arguments of type GlobalStreamId

Modifier and Type	Method and Description
Map<String,Map<GlobalStreamId,Long>>	BoltStats.get_acked()
Map<String,Map<GlobalStreamId,Double>>	BoltStats.get_execute_ms_avg()
Map<String,Map<GlobalStreamId,Long>>	BoltStats.get_executed()
Map<String,Map<GlobalStreamId,Long>>	BoltStats.get_failed()
Map<GlobalStreamId,ComponentAggregateStats>	ComponentPageInfo.get_gsid_to_input_stats()
Map<GlobalStreamId,Grouping>	ComponentCommon.get_inputs()
Map<String,Map<GlobalStreamId,Double>>	BoltStats.get_process_ms_avg()

Methods in org.apache.storm.generated with parameters of type GlobalStreamId

Modifier and Type	Method and Description
int	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)

Method parameters in org.apache.storm.generated with type arguments of type GlobalStreamId

Modifier and Type	Method and Description
void	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	BoltStats.set_acked(Map<String,Map<GlobalStreamId,Long>> acked)
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)

Constructors in org.apache.storm.generated with parameters of type GlobalStreamId

Constructor and Description
GlobalStreamId(GlobalStreamId other) Performs a deep copy on other.

Constructor parameters in org.apache.storm.generated with type arguments of type GlobalStreamId

Constructor and Description
BoltStats(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)
BoltStats(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)
BoltStats(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)
BoltStats(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)
BoltStats(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

Methods in org.apache.storm.grouping with parameters of type GlobalStreamId

Modifier and Type	Method and Description
void	ShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	PartialKeyGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	LoadAwareShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	CustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) Tells the stream grouping at runtime the tasks in the target bolt.

Uses of GlobalStreamId in org.apache.storm.task

Methods in org.apache.storm.task that return types with arguments of type GlobalStreamId

Modifier and Type	Method and Description
Map<GlobalStreamId,Grouping>	GeneralTopologyContext.getSources(String componentId) Gets the declared inputs to the specified component.
Map<GlobalStreamId,Grouping>	TopologyContext.getThisSources() Gets the declared inputs to this component.

Methods in org.apache.storm.task with parameters of type GlobalStreamId

Modifier and Type	Method and Description
Fields	GeneralTopologyContext.getComponentOutputFields(GlobalStreamId id) Gets the declared output fields for the specified global stream id.

Uses of GlobalStreamId in org.apache.storm.testing

Methods in org.apache.storm.testing with parameters of type GlobalStreamId

Modifier and Type	Method and Description
void	NGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)

Uses of GlobalStreamId in org.apache.storm.topology

Methods in org.apache.storm.topology with parameters of type GlobalStreamId

Modifier and Type	Method and Description
BoltDeclarer	TopologyBuilder.BoltGetter.grouping(GlobalStreamId id, Grouping grouping)
T	InputDeclarer.grouping(GlobalStreamId id, Grouping grouping)

Uses of GlobalStreamId in org.apache.storm.trident.partition

Methods in org.apache.storm.trident.partition with parameters of type GlobalStreamId

Modifier and Type	Method and Description
void	IndexHashGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
void	IdentityGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> tasks)
void	GlobalGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets)

Uses of GlobalStreamId in org.apache.storm.trident.topology

Fields in org.apache.storm.trident.topology declared as GlobalStreamId

Modifier and Type	Field and Description
GlobalStreamId	TridentBoltExecutor.CoordSpec.commitStream
GlobalStreamId	TridentBoltExecutor.CoordCondition.commitStream

Constructor parameters in org.apache.storm.trident.topology with type arguments of type GlobalStreamId

Constructor and Description
TridentBoltExecutor(ITridentBatchBolt bolt, Map<GlobalStreamId,String> batchGroupIds, Map<String,TridentBoltExecutor.CoordSpec> coordinationSpecs)

Uses of GlobalStreamId in org.apache.storm.tuple

Methods in org.apache.storm.tuple that return GlobalStreamId

Modifier and Type	Method and Description
GlobalStreamId	TupleImpl.getSourceGlobalStreamid() Deprecated.
GlobalStreamId	Tuple.getSourceGlobalStreamid() Deprecated. replaced by Tuple.getSourceGlobalStreamId() due to broken naming convention
GlobalStreamId	TupleImpl.getSourceGlobalStreamId()
GlobalStreamId	Tuple.getSourceGlobalStreamId() Returns the global stream id (component + stream) of this tuple.

Uses of GlobalStreamId in org.apache.storm.utils

Methods in org.apache.storm.utils that return GlobalStreamId

Modifier and Type	Method and Description
static GlobalStreamId	Utils.getGlobalStreamId(String componentId, String streamId)

Uses of GlobalStreamId in org.apache.storm.windowing

Methods in org.apache.storm.windowing with parameters of type GlobalStreamId

Modifier and Type	Method and Description
boolean	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.

Constructor parameters in org.apache.storm.windowing with type arguments of type GlobalStreamId

Constructor and Description
WaterMarkEventGenerator(WindowManager<T> windowManager, int intervalMs, int eventTsLagMs, Set<GlobalStreamId> inputStreams) Creates a new WatermarkEventGenerator.