org.apache.flume.channel
Class SpillableMemoryChannel.DrainOrderQueue

java.lang.Object
  org.apache.flume.channel.SpillableMemoryChannel.DrainOrderQueue

Enclosing class:

SpillableMemoryChannel

public static class SpillableMemoryChannel.DrainOrderQueue
extends Object

Field Summary

ArrayDeque<org.apache.flume.channel.SpillableMemoryChannel.MutableInteger>	queue
int	totalPuts

Constructor Summary

SpillableMemoryChannel.DrainOrderQueue()

Method Summary

String	dump()
int	front()
boolean	isEmpty()
void	putFirstOverflow(Integer eventCount)
void	putFirstPrimary(Integer eventCount)
void	putOverflow(Integer eventCount)
void	putPrimary(Integer eventCount)
void	takeOverflow(int takeCount)
void	takePrimary(int takeCount)

Methods inherited from class java.lang.Object

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

Field Detail

queue

public ArrayDeque<org.apache.flume.channel.SpillableMemoryChannel.MutableInteger> queue

totalPuts

public int totalPuts

Constructor Detail

SpillableMemoryChannel.DrainOrderQueue

public SpillableMemoryChannel.DrainOrderQueue()

Method Detail

dump

public String dump()

putPrimary

public void putPrimary(Integer eventCount)

putFirstPrimary

public void putFirstPrimary(Integer eventCount)

putOverflow

public void putOverflow(Integer eventCount)

putFirstOverflow

public void putFirstOverflow(Integer eventCount)

front

public int front()

isEmpty

public boolean isEmpty()

takePrimary

public void takePrimary(int takeCount)

takeOverflow

public void takeOverflow(int takeCount)