Package io.deephaven.kafka.publish

Class JsonKeyOrValueSerializer

java.lang.Object

io.deephaven.kafka.publish.JsonKeyOrValueSerializer

All Implemented Interfaces:

KeyOrValueSerializer<String>

public class JsonKeyOrValueSerializer
extends Object
implements KeyOrValueSerializer<String>

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.JsonKeyOrValueSerializer.JSONFieldProcessor>	fieldProcessors
protected final String	nestedObjectDelimiter
protected final boolean	outputNulls

Constructor Summary

Constructors

Constructor	Description
JsonKeyOrValueSerializer(Table source, String[] columnNames, String[] fieldNames, String timestampFieldName, String nestedObjectDelimiter, boolean outputNulls)

Method Summary

Modifier and Type	Method	Description
ObjectChunk<String,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

nestedObjectDelimiter

protected final String nestedObjectDelimiter

outputNulls

protected final boolean outputNulls

fieldProcessors

protected final List<io.deephaven.kafka.publish.JsonKeyOrValueSerializer.JSONFieldProcessor> fieldProcessors

Constructor Details

JsonKeyOrValueSerializer

public JsonKeyOrValueSerializer(Table source,
 String[] columnNames,
 String[] fieldNames,
 String timestampFieldName,
 String nestedObjectDelimiter,
 boolean outputNulls)

Method Details

handleChunk

public ObjectChunk<String,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<String>

Parameters:

toProcess - An 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<String>

Parameters:

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

Returns:

A Context for the KeyOrValueSerializer