Package io.deephaven.kafka.ingest

Class KafkaStreamPublisher.Parameters.Builder

java.lang.Object

io.deephaven.kafka.ingest.KafkaStreamPublisher.Parameters.Builder

Enclosing class:

KafkaStreamPublisher.Parameters

public static class KafkaStreamPublisher.Parameters.Builder
extends Object

Method Summary

Modifier and Type	Method	Description
KafkaStreamPublisher.Parameters	build()
KafkaStreamPublisher.Parameters.Builder	setKafkaPartitionColumnIndex(int kafkaPartitionColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setKeyBytesColumnIndex(int keyBytesColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setKeyProcessor(KeyOrValueProcessor keyProcessor)
KafkaStreamPublisher.Parameters.Builder	setKeyToChunkObjectMapper(@NotNull Function<Object,Object> keyToChunkObjectMapper)
KafkaStreamPublisher.Parameters.Builder	setOffsetColumnIndex(int offsetColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setReceiveTimeColumnIndex(int receiveTimeColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setSimpleKeyColumnIndex(int simpleKeyColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setSimpleValueColumnIndex(int simpleValueColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setTableDefinition(@NotNull TableDefinition tableDefinition)
KafkaStreamPublisher.Parameters.Builder	setTimestampColumnIndex(int timestampColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setValueBytesColumnIndex(int valueBytesColumnIndex)
KafkaStreamPublisher.Parameters.Builder	setValueProcessor(KeyOrValueProcessor valueProcessor)
KafkaStreamPublisher.Parameters.Builder	setValueToChunkObjectMapper(@NotNull Function<Object,Object> valueToChunkObjectMapper)

Methods inherited from class java.lang.Object

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

Method Details

setTableDefinition

public KafkaStreamPublisher.Parameters.Builder setTableDefinition(@NotNull
 @NotNull TableDefinition tableDefinition)

setKafkaPartitionColumnIndex

public KafkaStreamPublisher.Parameters.Builder setKafkaPartitionColumnIndex(int kafkaPartitionColumnIndex)

setOffsetColumnIndex

public KafkaStreamPublisher.Parameters.Builder setOffsetColumnIndex(int offsetColumnIndex)

setTimestampColumnIndex

public KafkaStreamPublisher.Parameters.Builder setTimestampColumnIndex(int timestampColumnIndex)

setReceiveTimeColumnIndex

public KafkaStreamPublisher.Parameters.Builder setReceiveTimeColumnIndex(int receiveTimeColumnIndex)

setKeyBytesColumnIndex

public KafkaStreamPublisher.Parameters.Builder setKeyBytesColumnIndex(int keyBytesColumnIndex)

setValueBytesColumnIndex

public KafkaStreamPublisher.Parameters.Builder setValueBytesColumnIndex(int valueBytesColumnIndex)

setKeyProcessor

public KafkaStreamPublisher.Parameters.Builder setKeyProcessor(KeyOrValueProcessor keyProcessor)

setValueProcessor

public KafkaStreamPublisher.Parameters.Builder setValueProcessor(KeyOrValueProcessor valueProcessor)

setSimpleKeyColumnIndex

public KafkaStreamPublisher.Parameters.Builder setSimpleKeyColumnIndex(int simpleKeyColumnIndex)

setSimpleValueColumnIndex

public KafkaStreamPublisher.Parameters.Builder setSimpleValueColumnIndex(int simpleValueColumnIndex)

setKeyToChunkObjectMapper

public KafkaStreamPublisher.Parameters.Builder setKeyToChunkObjectMapper(@NotNull
 @NotNull Function<Object,Object> keyToChunkObjectMapper)

setValueToChunkObjectMapper

public KafkaStreamPublisher.Parameters.Builder setValueToChunkObjectMapper(@NotNull
 @NotNull Function<Object,Object> valueToChunkObjectMapper)

build

public KafkaStreamPublisher.Parameters build()