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

Packages that use GlobalStreamId
Package
Description
org.apache.storm
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.scheduler
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
  Description
  `Map<GlobalStreamId,Grouping>`
  Thrift.BoltDetails.`getInputs()`
  Method parameters in org.apache.storm with type arguments of type GlobalStreamId
  Modifier and Type
  Method
  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)`

- ## Uses of GlobalStreamId in org.apache.storm.coordination

  Methods in org.apache.storm.coordination that return GlobalStreamId
  Modifier and Type
  Method
  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
  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
  Description
  `void`
  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

  Method parameters in org.apache.storm.daemon.ui with type arguments of type GlobalStreamId
  Modifier and Type
  Method
  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
  Description
  `GlobalStreamId`
  GlobalStreamId.`deepCopy()`
  Methods in org.apache.storm.generated that return types with arguments of type GlobalStreamId
  Modifier and Type
  Method
  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
  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
  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
  Modifier
  Constructor
  Description
  ``
  `GlobalStreamId(GlobalStreamId other)`
  Performs a deep copy on other.
  Constructor parameters in org.apache.storm.generated with type arguments of type GlobalStreamId
  Modifier
  Constructor
  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)`
  ``
  `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
  Description
  `void`
  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

  Methods in org.apache.storm.loadgen that return GlobalStreamId
  Modifier and Type
  Method
  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
  Description
  `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.scheduler

  Methods in org.apache.storm.scheduler that return types with arguments of type GlobalStreamId
  Modifier and Type
  Method
  Description
  `Map<GlobalStreamId,Grouping>`
  Component.`getInputs()`
  Constructor parameters in org.apache.storm.scheduler with type arguments of type GlobalStreamId
  Modifier
  Constructor
  Description
  ``
  `Component(ComponentType type, String compId, List<ExecutorDetails> execs, Map<GlobalStreamId,Grouping> inputs)`
  Create a new component.

- ## 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
  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
  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
  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
  Description
  `T`
  InputDeclarer.`grouping(GlobalStreamId id, Grouping grouping)`
  `BoltDeclarer`
  TopologyBuilder.BoltGetter.`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
  Description
  `void`
  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

  Fields in org.apache.storm.trident.topology declared as GlobalStreamId
  Modifier and Type
  Field
  Description
  `GlobalStreamId`
  TridentBoltExecutor.CoordCondition.`commitStream`
  `GlobalStreamId`
  TridentBoltExecutor.CoordSpec.`commitStream`
  Constructor parameters in org.apache.storm.trident.topology with type arguments of type GlobalStreamId
  Modifier
  Constructor
  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
  Description
  `GlobalStreamId`
  Tuple.`getSourceGlobalStreamId()`
  Returns the global stream id (component + stream) of this tuple.
  `GlobalStreamId`
  TupleImpl.`getSourceGlobalStreamId()`

- ## Uses of GlobalStreamId in org.apache.storm.utils

  Methods in org.apache.storm.utils that return GlobalStreamId
  Modifier and Type
  Method
  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
  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
  Modifier
  Constructor
  Description
  ``
  `WaterMarkEventGenerator(WindowManager<T> windowManager, int intervalMs, int eventTsLagMs, Set<GlobalStreamId> inputStreams)`
  Creates a new WatermarkEventGenerator.