## 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.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 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` | 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.
    `void` | PartialKeyGrouping.`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 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
    --- | ---
    `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.
    `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.
    `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 and Description
    --- | ---
    `Map<GlobalStreamId,Grouping>` | Component.`getInputs()`

    Constructor parameters in org.apache.storm.scheduler with type arguments of type GlobalStreamId
    Constructor and 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 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
    --- | ---
    `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 and Description
    --- | ---
    `void` | GlobalGrouping.`prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets)`
    `void` | IndexHashGrouping.`prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)`
    `void` | IdentityGrouping.`prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> tasks)`

  - ### 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` | 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 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.

Copyright © 2021 The Apache Software Foundation. All rights reserved.