Package io.deephaven.kafka.publish

Class GenericRecordKeyOrValueSerializer

java.lang.Object

io.deephaven.kafka.publish.GenericRecordKeyOrValueSerializer

All Implemented Interfaces:

KeyOrValueSerializer<org.apache.avro.generic.GenericRecord>

public class GenericRecordKeyOrValueSerializer
extends Object
implements KeyOrValueSerializer<org.apache.avro.generic.GenericRecord>

Nested Class Summary

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

KeyOrValueSerializer.Context

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<io.deephaven.kafka.publish.GenericRecordKeyOrValueSerializer.GenericRecordFieldProcessor>	fieldProcessors

Constructor Summary

Constructors

Constructor	Description
GenericRecordKeyOrValueSerializer(Table source, org.apache.avro.Schema schema, String[] columnNames, String timestampFieldName, Properties columnProperties)

Method Summary

Modifier and Type	Method	Description
ObjectChunk<org.apache.avro.generic.GenericRecord,Values>	handleChunk(KeyOrValueSerializer.Context context, RowSequence toProcess, boolean previous)	Process the given update RowSequence and returns a list of JSON strings, reach representing one row of data.
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

Field Details

fieldProcessors

protected final List<io.deephaven.kafka.publish.GenericRecordKeyOrValueSerializer.GenericRecordFieldProcessor> fieldProcessors

Constructor Details

GenericRecordKeyOrValueSerializer

public GenericRecordKeyOrValueSerializer(Table source,
 org.apache.avro.Schema schema,
 String[] columnNames,
 String timestampFieldName,
 Properties columnProperties)

Method Details

handleChunk

public ObjectChunk<org.apache.avro.generic.GenericRecord,Values> handleChunk(KeyOrValueSerializer.Context context,
 RowSequence toProcess,
 boolean previous)

Process the given update RowSequence and returns a list of JSON strings, reach representing one row of data.

Specified by:

handleChunk in interface KeyOrValueSerializer<org.apache.avro.generic.GenericRecord>

Parameters:

toProcess - A RowSequence indicating which rows were involved

previous - True if this should be performed using the 'previous' data instead of current, as for removals.

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

Returns:

A List of Strings containing all of the parsed update statements

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<org.apache.avro.generic.GenericRecord>

Parameters:

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

Returns:

A Context for the KeyOrValueSerializer