Package io.deephaven.kafka.ingest

Class GenericRecordBooleanFieldCopier

java.lang.Object

io.deephaven.kafka.ingest.GenericRecordFieldCopier

io.deephaven.kafka.ingest.GenericRecordBooleanFieldCopier

All Implemented Interfaces:

FieldCopier

public class GenericRecordBooleanFieldCopier
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
GenericRecordBooleanFieldCopier(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

GenericRecordBooleanFieldCopier

public GenericRecordBooleanFieldCopier(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