Package com.infinyon.fluvio

Class Record

java.lang.Object

com.infinyon.fluvio.Record

public final class Record
extends Object

Carries the data (key and value) for a Record in a Fluvio stream.

Method Summary

Modifier and Type	Method	Description
void	delete()
protected void	finalize()
final byte[]	key()	The key of this Record as bytes.
final String	key_string()	The key of this Record as a String.
final long	offset()	The absolute offset in the partition where this Record is located.
final byte[]	value()	The value of this Record as bytes.
final String	value_string()	The contents of this Record as a String.

Methods inherited from class java.lang.Object

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

Method Details

offset

public final long offset()

The absolute offset in the partition where this Record is located.

value

public final byte[] value()

The value of this Record as bytes.

key

public final byte[] key()

The key of this Record as bytes.

value_string

public final String value_string()
                          throws Exception

The contents of this Record as a String.

Throws:

Exception

key_string

public final String key_string()
                        throws Exception

The key of this Record as a String.

Throws:

Exception

delete

public void delete()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable