Uses of Class
org.apache.storm.generated.GlobalStreamId
Packages that use GlobalStreamId
Package
Description
-
Uses of GlobalStreamId in org.apache.storm
Methods in org.apache.storm that return types with arguments of type GlobalStreamIdMethod parameters in org.apache.storm with type arguments of type GlobalStreamIdModifier and TypeMethodDescriptionstatic Thrift.BoltDetailsThrift.prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt) static Thrift.BoltDetailsThrift.prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint) static Thrift.BoltDetailsThrift.prepareBoltDetails(Map<GlobalStreamId, Grouping> inputs, Object bolt, Integer parallelismHint, Map<String, Object> conf) static ComponentCommonThrift.prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint) static ComponentCommonThrift.prepareComponentCommon(Map<GlobalStreamId, Grouping> inputs, Map<String, StreamInfo> outputs, Integer parallelismHint, Map<String, Object> conf) static BoltThrift.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 -
Uses of GlobalStreamId in org.apache.storm.daemon
Methods in org.apache.storm.daemon that return types with arguments of type GlobalStreamIdModifier and TypeMethodDescriptionstatic 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 GlobalStreamIdModifier and TypeMethodDescriptionvoidGrouperFactory.AllGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.BasicLoadAwareCustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.FieldsGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.GlobalGrouper.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidGrouperFactory.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 GlobalStreamIdModifier and TypeMethodDescriptionUIHelpers.getInputMap(Map.Entry<GlobalStreamId, Grouping> entryInput) getInputMap. -
Uses of GlobalStreamId in org.apache.storm.generated
Methods in org.apache.storm.generated that return GlobalStreamIdMethods in org.apache.storm.generated that return types with arguments of type GlobalStreamIdModifier and TypeMethodDescriptionBoltStats.get_acked()BoltStats.get_execute_ms_avg()BoltStats.get_executed()BoltStats.get_failed()ComponentPageInfo.get_gsid_to_input_stats()ComponentCommon.get_inputs()BoltStats.get_process_ms_avg()Methods in org.apache.storm.generated with parameters of type GlobalStreamIdModifier and TypeMethodDescriptionintGlobalStreamId.compareTo(GlobalStreamId other) booleanGlobalStreamId.equals(GlobalStreamId that) voidComponentPageInfo.put_to_gsid_to_input_stats(GlobalStreamId key, ComponentAggregateStats val) voidComponentCommon.put_to_inputs(GlobalStreamId key, Grouping val) Method parameters in org.apache.storm.generated with type arguments of type GlobalStreamIdModifier and TypeMethodDescriptionvoidBoltStats.put_to_acked(String key, Map<GlobalStreamId, Long> val) voidBoltStats.put_to_execute_ms_avg(String key, Map<GlobalStreamId, Double> val) voidBoltStats.put_to_executed(String key, Map<GlobalStreamId, Long> val) voidBoltStats.put_to_failed(String key, Map<GlobalStreamId, Long> val) voidBoltStats.put_to_process_ms_avg(String key, Map<GlobalStreamId, Double> val) voidvoidBoltStats.set_execute_ms_avg(Map<String, Map<GlobalStreamId, Double>> execute_ms_avg) voidBoltStats.set_executed(Map<String, Map<GlobalStreamId, Long>> executed) voidBoltStats.set_failed(Map<String, Map<GlobalStreamId, Long>> failed) voidComponentPageInfo.set_gsid_to_input_stats(Map<GlobalStreamId, ComponentAggregateStats> gsid_to_input_stats) voidComponentCommon.set_inputs(Map<GlobalStreamId, Grouping> inputs) voidBoltStats.set_process_ms_avg(Map<String, Map<GlobalStreamId, Double>> process_ms_avg) Constructors in org.apache.storm.generated with parameters of type GlobalStreamIdModifierConstructorDescriptionGlobalStreamId(GlobalStreamId other) Performs a deep copy on other.Constructor parameters in org.apache.storm.generated with type arguments of type GlobalStreamIdModifierConstructorDescriptionBoltStats(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 GlobalStreamIdModifier and TypeMethodDescriptionvoidCustomStreamGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) Tells the stream grouping at runtime the tasks in the target bolt.voidLoadAwareShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidPartialKeyGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) voidShuffleGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks) -
Uses of GlobalStreamId in org.apache.storm.loadgen
Methods in org.apache.storm.loadgen that return GlobalStreamIdModifier and TypeMethodDescriptionInputStream.gsid()Get the global stream id for this input stream.Method parameters in org.apache.storm.loadgen with type arguments of type GlobalStreamIdModifier and TypeMethodDescriptionOutputStream.remap(String origId, Map<GlobalStreamId, GlobalStreamId> remappedStreams) 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 GlobalStreamIdConstructor parameters in org.apache.storm.scheduler with type arguments of type GlobalStreamIdModifierConstructorDescriptionComponent(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 GlobalStreamIdModifier and TypeMethodDescriptionGeneralTopologyContext.getSources(String componentId) Gets the declared inputs to the specified component.TopologyContext.getThisSources()Gets the declared inputs to this component.Methods in org.apache.storm.task with parameters of type GlobalStreamIdModifier and TypeMethodDescriptionGeneralTopologyContext.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 GlobalStreamIdModifier and TypeMethodDescriptionvoidNGrouping.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 GlobalStreamIdModifier and TypeMethodDescriptionInputDeclarer.grouping(GlobalStreamId id, Grouping grouping) 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 GlobalStreamIdModifier and TypeMethodDescriptionvoidGlobalGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets) voidIdentityGrouping.prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> tasks) voidIndexHashGrouping.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 GlobalStreamIdModifier and TypeFieldDescriptionTridentBoltExecutor.CoordCondition.commitStreamTridentBoltExecutor.CoordSpec.commitStreamConstructor parameters in org.apache.storm.trident.topology with type arguments of type GlobalStreamIdModifierConstructorDescriptionTridentBoltExecutor(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 GlobalStreamIdModifier and TypeMethodDescriptionTuple.getSourceGlobalStreamId()Returns the global stream id (component + stream) of this tuple.TupleImpl.getSourceGlobalStreamId() -
Uses of GlobalStreamId in org.apache.storm.utils
Methods in org.apache.storm.utils that return GlobalStreamIdModifier and TypeMethodDescriptionstatic GlobalStreamIdUtils.getGlobalStreamId(String componentId, String streamId) -
Uses of GlobalStreamId in org.apache.storm.windowing
Methods in org.apache.storm.windowing with parameters of type GlobalStreamIdModifier and TypeMethodDescriptionbooleanWaterMarkEventGenerator.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 GlobalStreamIdModifierConstructorDescriptionWaterMarkEventGenerator(WindowManager<T> windowManager, int intervalMs, int eventTsLagMs, Set<GlobalStreamId> inputStreams) Creates a new WatermarkEventGenerator.