org.apache.storm.hdfs.trident

Class FixedBatchSpout

java.lang.Object

org.apache.storm.hdfs.trident.FixedBatchSpout

All Implemented Interfaces:

Serializable, org.apache.storm.trident.spout.IBatchSpout, org.apache.storm.trident.spout.ITridentDataSource

public class FixedBatchSpout
extends Object
implements org.apache.storm.trident.spout.IBatchSpout

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FixedBatchSpout(org.apache.storm.tuple.Fields fields, int maxBatchSize, List<Object>... outputs)

Method Summary

Modifier and Type	Method and Description
void	ack(long batchId)
void	close()
void	emitBatch(long batchId, org.apache.storm.trident.operation.TridentCollector collector)
Map<String,Object>	getComponentConfiguration()
org.apache.storm.tuple.Fields	getOutputFields()
void	open(Map<String,Object> conf, org.apache.storm.task.TopologyContext context)
void	setCycle(boolean cycle)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FixedBatchSpout

public FixedBatchSpout(org.apache.storm.tuple.Fields fields,
                       int maxBatchSize,
                       List<Object>... outputs)

Method Detail

setCycle

public void setCycle(boolean cycle)

open

public void open(Map<String,Object> conf,
                 org.apache.storm.task.TopologyContext context)

Specified by:

open in interface org.apache.storm.trident.spout.IBatchSpout

emitBatch

public void emitBatch(long batchId,
                      org.apache.storm.trident.operation.TridentCollector collector)

Specified by:

emitBatch in interface org.apache.storm.trident.spout.IBatchSpout

ack

public void ack(long batchId)

Specified by:

ack in interface org.apache.storm.trident.spout.IBatchSpout

close

public void close()

Specified by:

close in interface org.apache.storm.trident.spout.IBatchSpout

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface org.apache.storm.trident.spout.IBatchSpout

getOutputFields

public org.apache.storm.tuple.Fields getOutputFields()

Specified by:

getOutputFields in interface org.apache.storm.trident.spout.IBatchSpout