public class RecordQueue
extends java.lang.Object
StampedRecord
(ConsumerRecord + timestamp). It also keeps track of the
partition timestamp defined as the minimum timestamp of records in its queue; in addition, its partition
timestamp is monotonically increasing such that once it is advanced, it will not be decremented.Modifier and Type | Method and Description |
---|---|
void |
clear()
Clear the fifo queue of its elements, also clear the time tracker's kept stamped elements
|
boolean |
isEmpty()
Tests if the queue is empty
|
org.apache.kafka.common.TopicPartition |
partition()
Returns the partition with which this queue is associated
|
StampedRecord |
poll()
Get the next
StampedRecord from the queue |
int |
size()
Returns the number of records in the queue
|
SourceNode |
source()
Returns the corresponding source node in the topology
|
long |
timestamp()
Returns the tracked partition timestamp
|
public SourceNode source()
public org.apache.kafka.common.TopicPartition partition()
public StampedRecord poll()
StampedRecord
from the queuepublic int size()
public boolean isEmpty()
public long timestamp()
public void clear()