Package org.apache.storm.trident.spout
Interface IBatchSpout
- All Superinterfaces:
ITridentDataSource
,Serializable
- All Known Implementing Classes:
FixedBatchSpout
,FixedBatchSpout
,RandomNumberGeneratorSpout
,TridentEsTopology.FixedBatchSpout
,TridentHiveTopology.FixedBatchSpout
-
Method Summary
Modifier and TypeMethodDescriptionvoid
ack
(long batchId) void
close()
void
emitBatch
(long batchId, TridentCollector collector) void
open
(Map<String, Object> conf, TopologyContext context)
-
Method Details
-
open
-
emitBatch
-
ack
void ack(long batchId) -
close
void close() -
getComponentConfiguration
-
getOutputFields
Fields getOutputFields()
-