Package io.confluent.parallelconsumer.offsets

Class ByteBufferEncoder

java.lang.Object

io.confluent.parallelconsumer.offsets.OffsetEncoder

io.confluent.parallelconsumer.offsets.ByteBufferEncoder

public class ByteBufferEncoder
extends OffsetEncoder

Constructor Summary

Constructors

Constructor	Description
ByteBufferEncoder(int length, OffsetSimultaneousEncoder offsetSimultaneousEncoder)

Method Summary

Modifier and Type	Method	Description
void	encodeCompletedOffset(int rangeIndex)
void	encodeIncompleteOffset(int rangeIndex)
protected byte[]	getEncodedBytes()
int	getEncodedSize()
protected OffsetEncoding	getEncodingType()
protected OffsetEncoding	getEncodingTypeCompressed()
byte[]	serialise()

Methods inherited from class java.lang.Object

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

Constructor Details

ByteBufferEncoder

public ByteBufferEncoder(int length,
 OffsetSimultaneousEncoder offsetSimultaneousEncoder)

Method Details

getEncodingType

protected OffsetEncoding getEncodingType()

Specified by:

getEncodingType in class OffsetEncoder

getEncodingTypeCompressed

protected OffsetEncoding getEncodingTypeCompressed()

Specified by:

getEncodingTypeCompressed in class OffsetEncoder

encodeIncompleteOffset

public void encodeIncompleteOffset(int rangeIndex)

encodeCompletedOffset

public void encodeCompletedOffset(int rangeIndex)

serialise

public byte[] serialise()

getEncodedSize

public int getEncodedSize()

getEncodedBytes

protected byte[] getEncodedBytes()

Specified by:

getEncodedBytes in class OffsetEncoder