## 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
    Constructor | Description
    --- | ---
    `GlobalStreamId​(GlobalStreamId other)` | Performs a deep copy on other.

    Constructor parameters in org.apache.storm.generated with type arguments of type GlobalStreamId
    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
    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
    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
    Constructor | Description
    --- | ---
    `WaterMarkEventGenerator​(WindowManager<T> windowManager, int intervalMs, int eventTsLagMs, Set<GlobalStreamId> inputStreams)` | Creates a new WatermarkEventGenerator.