Package io.deephaven.kafka.ingest

Class GenericRecordArrayFieldCopier

java.lang.Object

io.deephaven.kafka.ingest.GenericRecordFieldCopier

io.deephaven.kafka.ingest.GenericRecordArrayFieldCopier

All Implemented Interfaces:

FieldCopier

public class GenericRecordArrayFieldCopier
extends GenericRecordFieldCopier

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.kafka.ingest.FieldCopier

FieldCopier.Factory

Field Summary

Fields inherited from class io.deephaven.kafka.ingest.GenericRecordFieldCopier

fieldPath

Constructor Summary

Constructors

Constructor	Description
GenericRecordArrayFieldCopier(String fieldPathStr, Pattern separator, org.apache.avro.Schema schema, Class<?> componentType)

Method Summary

Modifier and Type	Method	Description
void	copyField(ObjectChunk<Object,Values> inputChunk, WritableChunk<Values> publisherChunk, int sourceOffset, int destOffset, int length)	Copy fields from a chunk of Kafka key or value objects to a chunk that will be published to a blink table.

Methods inherited from class java.lang.Object

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

Constructor Details

GenericRecordArrayFieldCopier

public GenericRecordArrayFieldCopier(String fieldPathStr,
 Pattern separator,
 org.apache.avro.Schema schema,
 Class<?> componentType)

Method Details

copyField

public void copyField(ObjectChunk<Object,Values> inputChunk,
 WritableChunk<Values> publisherChunk,
 int sourceOffset,
 int destOffset,
 int length)

Description copied from interface: FieldCopier

Copy fields from a chunk of Kafka key or value objects to a chunk that will be published to a blink table.

Parameters:

inputChunk - the chunk containing Kafka keys or values

publisherChunk - the output chunk for the provided field

sourceOffset - the source chunk offset

destOffset - the destination chunk offset

length - the length to copy