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

Packages that use GlobalStreamId

Package	Description
org.apache.storm
org.apache.storm.cassandra
org.apache.storm.coordination
org.apache.storm.daemon
org.apache.storm.daemon.ui
org.apache.storm.generated
org.apache.storm.grouping
org.apache.storm.loadgen
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

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

Modifier and Type	Method and Description
Map<GlobalStreamId,Grouping>	Thrift.BoltDetails.getInputs()

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

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

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

Constructor and Description
BoltDetails(Object bolt, Map<String,Object> conf, Integer parallelism, Map<GlobalStreamId,Grouping> inputs)

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.daemon

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

Modifier and Type	Method and Description
static Map<GlobalStreamId,Grouping>	StormCommon.ackerInputs(StormTopology topology)
static Map<GlobalStreamId,Grouping>	StormCommon.eventLoggerInputs(StormTopology topology)

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

Modifier and Type	Method and Description
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)
void	GrouperFactory.AllGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)

Uses of GlobalStreamId in org.apache.storm.daemon.ui

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

Modifier and Type	Method and Description
static Map<String,Object>	UIHelpers.getInputMap(Map.Entry<GlobalStreamId,Grouping> entryInput) getInputMap.

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.loadgen

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

Modifier and Type	Method and Description
GlobalStreamId	InputStream.gsid() Get the global stream id for this input stream.

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

Modifier and Type	Method and Description
LoadCompConf	LoadCompConf.remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams) Chenge the name of components and streams according to the parameters passed in.
LoadCompConf	LoadCompConf.remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams) Chenge the name of components and streams according to the parameters passed in.
InputStream	InputStream.remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams) Remap the names of components.
InputStream	InputStream.remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams) Remap the names of components.
OutputStream	OutputStream.remap(String origId, Map<GlobalStreamId,GlobalStreamId> remappedStreams)
OutputStream	OutputStream.remap(String origId, Map<GlobalStreamId,GlobalStreamId> remappedStreams)

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()
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 streamId, String componentId)

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.