Package org.apache.storm.trident.spout
Interface IBatchSpout
-
- All Superinterfaces:
ITridentDataSource,Serializable
- All Known Implementing Classes:
FixedBatchSpout,FixedBatchSpout,RandomNumberGeneratorSpout,TridentHiveTopology.FixedBatchSpout
public interface IBatchSpout extends ITridentDataSource
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidack(long batchId)voidclose()voidemitBatch(long batchId, TridentCollector collector)Map<String,Object>getComponentConfiguration()FieldsgetOutputFields()voidopen(Map<String,Object> conf, TopologyContext context)
-
-
-
Method Detail
-
open
void open(Map<String,Object> conf, TopologyContext context)
-
emitBatch
void emitBatch(long batchId, TridentCollector collector)
-
ack
void ack(long batchId)
-
close
void close()
-
getOutputFields
Fields getOutputFields()
-
-