Uses of Class
org.apache.storm.generated.GlobalStreamId
-
-
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() -
Uses of GlobalStreamId in org.apache.storm.coordination
Methods in org.apache.storm.coordination that return GlobalStreamId Modifier and Type Method Description GlobalStreamIdCoordinatedBolt.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 voidGrouperFactory.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 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 GlobalStreamIdGlobalStreamId. 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 intGlobalStreamId. 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)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 voidCustomStreamGrouping. 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 GlobalStreamId Modifier and Type Method Description GlobalStreamIdInputStream. 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 OutputStreamOutputStream. remap(String origId, Map<GlobalStreamId,GlobalStreamId> remappedStreams)OutputStreamOutputStream. 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 FieldsGeneralTopologyContext. 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 voidNGrouping. 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 TInputDeclarer. grouping(GlobalStreamId id, Grouping grouping)BoltDeclarerTopologyBuilder.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 voidGlobalGrouping. 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 GlobalStreamId Modifier and Type Field Description GlobalStreamIdTridentBoltExecutor.CoordCondition. commitStreamGlobalStreamIdTridentBoltExecutor.CoordSpec. commitStreamConstructor 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 GlobalStreamIdTuple. getSourceGlobalStreamId()Returns the global stream id (component + stream) of this tuple.GlobalStreamIdTupleImpl. getSourceGlobalStreamId() -
Uses of GlobalStreamId in org.apache.storm.utils
Methods in org.apache.storm.utils that return GlobalStreamId Modifier and Type Method Description static GlobalStreamIdUtils. 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 booleanWaterMarkEventGenerator. 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.
-