Package com.infinyon.fluvio

Class Offset

java.lang.Object

com.infinyon.fluvio.Offset

public final class Offset
extends Object

Describes the position of a record in a Fluvio partition.

Method Summary

Modifier and Type	Method	Description
static Offset	absolute(long offset)	Create an Offset at a specific absolute position in the partition.
static Offset	beginning()	Create an Offset pointing to the very first record in the partition.
void	delete()
static Offset	end()	Create an Offset pointing to the very last record in the partition.
protected void	finalize()
static Offset	from_beginning(long offset)	Create an Offset pointing to the record X positions from the beginning of the partition.
static Offset	from_end(long offset)	Create an Offset pointing to the record X positions from the end of the partition.

Methods inherited from class java.lang.Object

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

Method Details

absolute

public static Offset absolute(long offset)
                       throws Exception

Create an Offset at a specific absolute position in the partition.

Throws:

Exception

beginning

public static Offset beginning()

Create an Offset pointing to the very first record in the partition.

from_beginning

public static Offset from_beginning(long offset)

Create an Offset pointing to the record X positions from the beginning of the partition.

end

public static Offset end()

Create an Offset pointing to the very last record in the partition.

from_end

public static Offset from_end(long offset)

Create an Offset pointing to the record X positions from the end of the partition.

delete

public void delete()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable