Package org.apache.storm.hdfs.trident
Class FixedBatchSpout
java.lang.Object
org.apache.storm.hdfs.trident.FixedBatchSpout
- All Implemented Interfaces:
Serializable
,IBatchSpout
,ITridentDataSource
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
ack
(long batchId) void
close()
void
emitBatch
(long batchId, TridentCollector collector) void
open
(Map<String, Object> conf, TopologyContext context) void
setCycle
(boolean cycle)
-
Constructor Details
-
FixedBatchSpout
-
-
Method Details
-
setCycle
public void setCycle(boolean cycle) -
open
- Specified by:
open
in interfaceIBatchSpout
-
emitBatch
- Specified by:
emitBatch
in interfaceIBatchSpout
-
ack
public void ack(long batchId) - Specified by:
ack
in interfaceIBatchSpout
-
close
public void close()- Specified by:
close
in interfaceIBatchSpout
-
getComponentConfiguration
- Specified by:
getComponentConfiguration
in interfaceIBatchSpout
-
getOutputFields
- Specified by:
getOutputFields
in interfaceIBatchSpout
-