Package io.deephaven.kafka.publish

Interface KeyOrValueSerializer<SERIALIZED_TYPE>

All Known Implementing Classes:

GenericRecordKeyOrValueSerializer, JsonKeyOrValueSerializer, SimpleKeyOrValueSerializer

public interface KeyOrValueSerializer<SERIALIZED_TYPE>

Chunk-oriented serializer that supplies keys or values for stream publishing.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	KeyOrValueSerializer.Context	Context interface.

Method Summary

Modifier and Type	Method	Description
ObjectChunk<SERIALIZED_TYPE,Values>	handleChunk(KeyOrValueSerializer.Context context, RowSequence rowSequence, boolean previous)	Create a chunk of output keys or values that correspond to rowSequence.
KeyOrValueSerializer.Context	makeContext(int size)	Create a context for calling handleChunk(Context, RowSequence, boolean).

Method Details

handleChunk

ObjectChunk<SERIALIZED_TYPE,Values> handleChunk(KeyOrValueSerializer.Context context,
 RowSequence rowSequence,
 boolean previous)

Create a chunk of output keys or values that correspond to rowSequence. The output chunks should be cached in the context for re-use, but the data returned in them should be functionally immutable and not rely on pooled or re-usable objects.

Parameters:

context - A KeyOrValueSerializer.Context created by makeContext(int)

rowSequence - The row keys to serialize

previous - If previous row values should be used, as with row key removals

Returns:

A chunk of serialized data keys or values, with ObjectChunk.size() == rowSequence.size()

makeContext

KeyOrValueSerializer.Context makeContext(int size)

Create a context for calling handleChunk(Context, RowSequence, boolean).

Parameters:

size - The maximum number of rows that will be serialized for each chunk

Returns:

A Context for the KeyOrValueSerializer