Uses of Class
org.apache.storm.coordination.BatchOutputCollector
-
-
Uses of BatchOutputCollector in org.apache.storm.coordination
Subclasses of BatchOutputCollector in org.apache.storm.coordination Modifier and Type Class Description classBatchOutputCollectorImplMethods in org.apache.storm.coordination with parameters of type BatchOutputCollector Modifier and Type Method Description voidIBatchBolt. prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, T id) -
Uses of BatchOutputCollector in org.apache.storm.starter
Methods in org.apache.storm.starter with parameters of type BatchOutputCollector Modifier and Type Method Description voidReachTopology.CountAggregator. prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, Object id)voidReachTopology.PartialUniquer. prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, Object id) -
Uses of BatchOutputCollector in org.apache.storm.trident.planner
Methods in org.apache.storm.trident.planner with parameters of type BatchOutputCollector Modifier and Type Method Description voidSubtopologyBolt. prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector batchCollector)Constructors in org.apache.storm.trident.planner with parameters of type BatchOutputCollector Constructor Description BridgeReceiver(BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.planner.processor
Methods in org.apache.storm.trident.planner.processor that return BatchOutputCollector Modifier and Type Method Description BatchOutputCollectorTridentContext. getDelegateCollector()Constructors in org.apache.storm.trident.planner.processor with parameters of type BatchOutputCollector Constructor Description TridentContext(Fields selfFields, List<TridentTuple.Factory> parentFactories, List<String> parentStreams, List<TupleReceiver> receivers, String outStreamId, int stateIndex, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.spout
Methods in org.apache.storm.trident.spout with parameters of type BatchOutputCollector Modifier and Type Method Description voidTridentSpoutExecutor. prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.topology
Methods in org.apache.storm.trident.topology with parameters of type BatchOutputCollector Modifier and Type Method Description voidITridentBatchBolt. prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.windowing
Fields in org.apache.storm.trident.windowing declared as BatchOutputCollector Modifier and Type Field Description protected BatchOutputCollectorAbstractTridentWindowManager. delegateCollectorConstructors in org.apache.storm.trident.windowing with parameters of type BatchOutputCollector Constructor Description AbstractTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)InMemoryTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)StoreBasedTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields)
-