org.thales.punch.kafka.impl

Class OffsetTree

java.lang.Object

org.thales.punch.kafka.impl.OffsetTree

public class OffsetTree
extends Object

An OffsetTree is a sorted set of longs to manage Kafka offset. But it offers one additional service: it returns the largest offset of the first contiguous offset serie.

I.e. if you have 0 1 2 3 6 7 8 , it will return 3.

Why is that useful ? to quickly return the largest offset terminating a continuously increasing sequence.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
OffsetTree()

Method Summary

Modifier and Type	Method and Description
long	add(long l) Add an offset to the tree.
void	clearUpTo(long l) Clear all items up to the given value
boolean	contains(long offset) Return true if this offset is currently in the set
long	getLargestOffsetFromFirstSequence() getLargestOffsetFromFirstSequence(1 2 6 7) returns 2.
protected boolean	isEmpty()
protected void	removeStartingFrom(long l)
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

OffsetTree

public OffsetTree()

Method Detail

getLargestOffsetFromFirstSequence

public long getLargestOffsetFromFirstSequence()

getLargestOffsetFromFirstSequence(1 2 6 7) returns 2.

getLargestOffsetFromFirstSequence(1 2 3 4) returns 4.

Returns:

the largest offset from the first monotonically increasing sequence.

add

public long add(long l)

Add an offset to the tree.

Parameters:

l - the new offset

Returns:

the new largest offset

contains

public boolean contains(long offset)

Return true if this offset is currently in the set

Parameters:

offset -

Returns:

true or false

size

public int size()

Returns:

the number of element in the tree

isEmpty

protected boolean isEmpty()

clearUpTo

public void clearUpTo(long l)

Clear all items up to the given value

Parameters:

l - a value

toString

public String toString()

Overrides:

toString in class Object

removeStartingFrom

protected void removeStartingFrom(long l)