Package com.linkedin.venice.writer

Class VeniceWriterOptions.Builder

java.lang.Object

com.linkedin.venice.writer.VeniceWriterOptions.Builder

Enclosing class:

VeniceWriterOptions

public static class VeniceWriterOptions.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Builder(java.lang.String topic)

Method Summary

Modifier and Type	Method	Description
VeniceWriterOptions	build()
VeniceWriterOptions.Builder	setBrokerAddress(java.lang.String brokerAddress)
VeniceWriterOptions.Builder	setChunkingEnabled(boolean chunkingEnabled)
VeniceWriterOptions.Builder	setKeySerializer(VeniceKafkaSerializer keySerializer)
VeniceWriterOptions.Builder	setPartitionCount(java.lang.Integer partitionCount)
VeniceWriterOptions.Builder	setPartitioner(VenicePartitioner partitioner)
VeniceWriterOptions.Builder	setRmdChunkingEnabled(boolean rmdChunkingEnabled)
VeniceWriterOptions.Builder	setTime(Time time)
VeniceWriterOptions.Builder	setUseKafkaKeySerializer(boolean useKafkaKeySerializer)
VeniceWriterOptions.Builder	setValueSerializer(VeniceKafkaSerializer valueSerializer)
VeniceWriterOptions.Builder	setWriteComputeSerializer(VeniceKafkaSerializer writeComputeSerializer)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(java.lang.String topic)

Method Detail

build

public VeniceWriterOptions build()

setBrokerAddress

public VeniceWriterOptions.Builder setBrokerAddress(java.lang.String brokerAddress)

setUseKafkaKeySerializer

public VeniceWriterOptions.Builder setUseKafkaKeySerializer(boolean useKafkaKeySerializer)

setChunkingEnabled

public VeniceWriterOptions.Builder setChunkingEnabled(boolean chunkingEnabled)

setRmdChunkingEnabled

public VeniceWriterOptions.Builder setRmdChunkingEnabled(boolean rmdChunkingEnabled)

setKeySerializer

public VeniceWriterOptions.Builder setKeySerializer(VeniceKafkaSerializer keySerializer)

setValueSerializer

public VeniceWriterOptions.Builder setValueSerializer(VeniceKafkaSerializer valueSerializer)

setWriteComputeSerializer

public VeniceWriterOptions.Builder setWriteComputeSerializer(VeniceKafkaSerializer writeComputeSerializer)

setPartitioner

public VeniceWriterOptions.Builder setPartitioner(VenicePartitioner partitioner)

setTime

public VeniceWriterOptions.Builder setTime(Time time)

setPartitionCount

public VeniceWriterOptions.Builder setPartitionCount(java.lang.Integer partitionCount)