Package io.deephaven.kafka.ingest

Class JsonNodeLongFieldCopier

java.lang.Object

io.deephaven.kafka.ingest.JsonNodeLongFieldCopier

All Implemented Interfaces:

FieldCopier

public class JsonNodeLongFieldCopier
extends Object
implements FieldCopier

Nested Class Summary

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

FieldCopier.Factory

Constructor Summary

Constructors

Constructor	Description
JsonNodeLongFieldCopier(String fieldPointerStr)

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

JsonNodeLongFieldCopier

public JsonNodeLongFieldCopier(String fieldPointerStr)

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.

Specified by:

copyField in interface FieldCopier

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