org.apache.storm.utils

Class DisruptorQueue

java.lang.Object

org.apache.storm.utils.DisruptorQueue

All Implemented Interfaces:

IStatefulObject

public class DisruptorQueue
extends Object
implements IStatefulObject

A single consumer queue that uses the LMAX Disruptor. They key to the performance is the ability to catch up to the producer by processing tuples in batches.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DisruptorQueue.QueueMetrics This inner class provides methods to access the metrics of the disruptor queue.

Constructor Summary

Constructors

Constructor and Description
DisruptorQueue(String queueName, com.lmax.disruptor.dsl.ProducerType type, int size, long readTimeout, int inputBatchSize, long flushInterval, String topologyId, String componentId, Integer taskId, int port)

Method Summary

Modifier and Type	Method and Description
void	consumeBatch(com.lmax.disruptor.EventHandler<Object> handler)
void	consumeBatchWhenAvailable(com.lmax.disruptor.EventHandler<Object> handler)
int	getHighWaterMark()
int	getLowWaterMark()
DisruptorQueue.QueueMetrics	getMetrics()
String	getName()
Object	getState()
boolean	getThrottleOn()
void	haltWithInterrupt()
boolean	isFull()
void	publish(Object obj)
void	registerBackpressureCallback(DisruptorBackpressureCallback cb)
DisruptorQueue	setEnableBackpressure(boolean enableBackpressure)
DisruptorQueue	setHighWaterMark(double highWaterMark)
DisruptorQueue	setLowWaterMark(double lowWaterMark)

Methods inherited from class java.lang.Object

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

Constructor Detail

DisruptorQueue

public DisruptorQueue(String queueName,
                      com.lmax.disruptor.dsl.ProducerType type,
                      int size,
                      long readTimeout,
                      int inputBatchSize,
                      long flushInterval,
                      String topologyId,
                      String componentId,
                      Integer taskId,
                      int port)

Method Detail

getName

public String getName()

isFull

public boolean isFull()

haltWithInterrupt

public void haltWithInterrupt()

consumeBatch

public void consumeBatch(com.lmax.disruptor.EventHandler<Object> handler)

consumeBatchWhenAvailable

public void consumeBatchWhenAvailable(com.lmax.disruptor.EventHandler<Object> handler)

registerBackpressureCallback

public void registerBackpressureCallback(DisruptorBackpressureCallback cb)

publish

public void publish(Object obj)

getState

public Object getState()

Specified by:

getState in interface IStatefulObject

setHighWaterMark

public DisruptorQueue setHighWaterMark(double highWaterMark)

setLowWaterMark

public DisruptorQueue setLowWaterMark(double lowWaterMark)

getHighWaterMark

public int getHighWaterMark()

getLowWaterMark

public int getLowWaterMark()

setEnableBackpressure

public DisruptorQueue setEnableBackpressure(boolean enableBackpressure)

getThrottleOn

public boolean getThrottleOn()

getMetrics

public DisruptorQueue.QueueMetrics getMetrics()