org.apache.storm.opentsdb

Class MetricGenBatchSpout

java.lang.Object

org.apache.storm.opentsdb.MetricGenBatchSpout

All Implemented Interfaces:

Serializable, IBatchSpout, ITridentDataSource

public class MetricGenBatchSpout
extends Object
implements IBatchSpout

BatchSpout implementation for metrics generation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MetricGenBatchSpout(int batchSize)

Method Summary

Modifier and Type	Method and Description
void	ack(long batchId)
void	close()
void	emitBatch(long batchId, TridentCollector collector)
Map<String,Object>	getComponentConfiguration()
Fields	getOutputFields()
void	open(Map<String,Object> conf, TopologyContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricGenBatchSpout

public MetricGenBatchSpout(int batchSize)

Method Detail

open

public void open(Map<String,Object> conf,
                 TopologyContext context)

Specified by:

open in interface IBatchSpout

emitBatch

public void emitBatch(long batchId,
                      TridentCollector collector)

Specified by:

emitBatch in interface IBatchSpout

ack

public void ack(long batchId)

Specified by:

ack in interface IBatchSpout

close

public void close()

Specified by:

close in interface IBatchSpout

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface IBatchSpout

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface IBatchSpout