Package org.apache.storm.trident.testing
Class FixedBatchSpout
java.lang.Object
org.apache.storm.trident.testing.FixedBatchSpout
- All Implemented Interfaces:
Serializable,IBatchSpout,ITridentDataSource
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidack(long batchId) voidclose()voidemitBatch(long batchId, TridentCollector collector) voidopen(Map<String, Object> conf, TopologyContext context) voidsetCycle(boolean cycle)
-
Constructor Details
-
FixedBatchSpout
-
-
Method Details
-
setCycle
public void setCycle(boolean cycle) -
open
- Specified by:
openin interfaceIBatchSpout
-
emitBatch
- Specified by:
emitBatchin interfaceIBatchSpout
-
ack
public void ack(long batchId) - Specified by:
ackin interfaceIBatchSpout
-
close
public void close()- Specified by:
closein interfaceIBatchSpout
-
getComponentConfiguration
- Specified by:
getComponentConfigurationin interfaceIBatchSpout
-
getOutputFields
- Specified by:
getOutputFieldsin interfaceIBatchSpout
-