Package io.deephaven.kafka.ingest

Class KafkaStreamPublisher.Parameters

java.lang.Object

io.deephaven.kafka.ingest.KafkaStreamPublisher.Parameters

Enclosing class:

KafkaStreamPublisher

public static class KafkaStreamPublisher.Parameters
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaStreamPublisher.Parameters.Builder

Method Summary

Modifier and Type	Method	Description
static KafkaStreamPublisher.Parameters.Builder	builder()
int	getKafkaPartitionColumnIndex()
int	getKeyBytesColumnIndex()
KeyOrValueProcessor	getKeyProcessor()
Function<Object,Object>	getKeyToChunkObjectMapper()
int	getOffsetColumnIndex()
int	getReceiveTimeColumnIndex()
int	getSimpleKeyColumnIndex()
int	getSimpleValueColumnIndex()
@NotNull TableDefinition	getTableDefinition()
int	getTimestampColumnIndex()
int	getValueBytesColumnIndex()
KeyOrValueProcessor	getValueProcessor()
Function<Object,Object>	getValueToChunkObjectMapper()

Methods inherited from class java.lang.Object

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

Method Details

getTableDefinition

@NotNull
public @NotNull TableDefinition getTableDefinition()

getKafkaPartitionColumnIndex

public int getKafkaPartitionColumnIndex()

getOffsetColumnIndex

public int getOffsetColumnIndex()

getTimestampColumnIndex

public int getTimestampColumnIndex()

getKeyProcessor

public KeyOrValueProcessor getKeyProcessor()

getValueProcessor

public KeyOrValueProcessor getValueProcessor()

getSimpleKeyColumnIndex

public int getSimpleKeyColumnIndex()

getSimpleValueColumnIndex

public int getSimpleValueColumnIndex()

getReceiveTimeColumnIndex

public int getReceiveTimeColumnIndex()

getKeyBytesColumnIndex

public int getKeyBytesColumnIndex()

getValueBytesColumnIndex

public int getValueBytesColumnIndex()

getKeyToChunkObjectMapper

public Function<Object,Object> getKeyToChunkObjectMapper()

getValueToChunkObjectMapper

public Function<Object,Object> getValueToChunkObjectMapper()

builder

public static KafkaStreamPublisher.Parameters.Builder builder()