Package io.deephaven.kafka.ingest

Class JsonNodeChunkAdapter

java.lang.Object

io.deephaven.kafka.ingest.MultiFieldChunkAdapter

io.deephaven.kafka.ingest.JsonNodeChunkAdapter

All Implemented Interfaces:

KeyOrValueProcessor

public class JsonNodeChunkAdapter
extends MultiFieldChunkAdapter

Method Summary

Modifier and Type	Method	Description
static JsonNodeChunkAdapter	make(TableDefinition definition, IntFunction<ChunkType> chunkTypeForIndex, Map<String,String> jsonPointerStrToColumnNames, boolean allowNulls)	Create a JsonRecordChunkAdapter.

Methods inherited from class io.deephaven.kafka.ingest.MultiFieldChunkAdapter

chunkOffsets, handleChunk

Methods inherited from class java.lang.Object

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

Method Details

make

public static JsonNodeChunkAdapter make(TableDefinition definition,
 IntFunction<ChunkType> chunkTypeForIndex,
 Map<String,String> jsonPointerStrToColumnNames,
 boolean allowNulls)

Create a JsonRecordChunkAdapter.

Parameters:

definition - the definition of the output table

chunkTypeForIndex - a function from column index to chunk type

jsonPointerStrToColumnNames - a map from JSON pointer strings to Deephaven column names

allowNulls - true if null records should be allowed, if false then an ISE is thrown

Returns:

a JsonRecordChunkAdapter for the given definition and column mapping