Package io.deephaven.kafka.publish

Class SimpleKeyOrValueSerializer<SERIALIZED_TYPE>

java.lang.Object

io.deephaven.kafka.publish.SimpleKeyOrValueSerializer<SERIALIZED_TYPE>

All Implemented Interfaces:

KeyOrValueSerializer<SERIALIZED_TYPE>

public class SimpleKeyOrValueSerializer<SERIALIZED_TYPE>
extends Object
implements KeyOrValueSerializer<SERIALIZED_TYPE>

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.kafka.publish.KeyOrValueSerializer

KeyOrValueSerializer.Context

Constructor Summary

Constructors

Constructor	Description
SimpleKeyOrValueSerializer(Table table, String columnName)

Method Summary

Modifier and Type	Method	Description
ObjectChunk<SERIALIZED_TYPE,Values>	handleChunk(@NotNull KeyOrValueSerializer.Context context, @NotNull 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 KeyOrValueSerializer.handleChunk(Context, RowSequence, boolean).

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleKeyOrValueSerializer

public SimpleKeyOrValueSerializer(Table table,
 String columnName)

Method Details

handleChunk

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

Description copied from interface: KeyOrValueSerializer

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.

Specified by:

handleChunk in interface KeyOrValueSerializer<SERIALIZED_TYPE>

Parameters:

context - A KeyOrValueSerializer.Context created by KeyOrValueSerializer.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

public KeyOrValueSerializer.Context makeContext(int size)

Description copied from interface: KeyOrValueSerializer

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

Specified by:

makeContext in interface KeyOrValueSerializer<SERIALIZED_TYPE>

Parameters:

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

Returns:

A Context for the KeyOrValueSerializer