Package io.deephaven.kafka.ingest

Class GenericRecordByteFieldCopier

java.lang.Object

io.deephaven.kafka.ingest.GenericRecordFieldCopier

io.deephaven.kafka.ingest.GenericRecordByteFieldCopier

All Implemented Interfaces:

FieldCopier

public class GenericRecordByteFieldCopier
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
GenericRecordByteFieldCopier(String fieldPathStr, Pattern separator, org.apache.avro.Schema schema)

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

GenericRecordByteFieldCopier

public GenericRecordByteFieldCopier(String fieldPathStr,
 Pattern separator,
 org.apache.avro.Schema schema)

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