Package io.deephaven.kafka.ingest

Class MultiFieldChunkAdapter

java.lang.Object

io.deephaven.kafka.ingest.MultiFieldChunkAdapter

All Implemented Interfaces:

KeyOrValueProcessor

Direct Known Subclasses:

GenericRecordChunkAdapter, JsonNodeChunkAdapter

public class MultiFieldChunkAdapter
extends Object
implements KeyOrValueProcessor

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MultiFieldChunkAdapter(TableDefinition definition, IntFunction<ChunkType> chunkTypeForIndex, Map<String,String> fieldNamesToColumnNames, boolean allowNulls, FieldCopier.Factory fieldCopierFactory)

Method Summary

Modifier and Type	Method	Description
static int[]	chunkOffsets(TableDefinition definition, Map<String,String> fieldNamesToColumnNames)
void	handleChunk(ObjectChunk<Object,Values> inputChunk, WritableChunk<Values>[] publisherChunks)	After consuming a set of generic records for a batch that are not raw objects, we pass the keys or values to an appropriate handler.

Methods inherited from class java.lang.Object

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

Constructor Details

MultiFieldChunkAdapter

protected MultiFieldChunkAdapter(TableDefinition definition,
 IntFunction<ChunkType> chunkTypeForIndex,
 Map<String,String> fieldNamesToColumnNames,
 boolean allowNulls,
 FieldCopier.Factory fieldCopierFactory)

Method Details

chunkOffsets

public static int[] chunkOffsets(TableDefinition definition,
 Map<String,String> fieldNamesToColumnNames)

handleChunk

public void handleChunk(ObjectChunk<Object,Values> inputChunk,
 WritableChunk<Values>[] publisherChunks)

Description copied from interface: KeyOrValueProcessor

After consuming a set of generic records for a batch that are not raw objects, we pass the keys or values to an appropriate handler. The handler must know its data types and offsets within the publisher chunks, and "copy" the data from the inputChunk to the appropriate chunks for the stream publisher.

Specified by:

handleChunk in interface KeyOrValueProcessor

Parameters:

inputChunk - the chunk containing the keys or values as Kafka deserialized them from the consumer record

publisherChunks - the output chunks for this table that must be appended to.