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 Object

Constructor Summary

Constructors

Constructor	Description
Builder(String topic)

Method Summary

Modifier and Type	Method	Description
VeniceWriterOptions	build()
VeniceWriterOptions.Builder	setBrokerAddress(String brokerAddress)
VeniceWriterOptions.Builder	setChunkingEnabled(boolean chunkingEnabled)
VeniceWriterOptions.Builder	setKeySerializer(VeniceKafkaSerializer keySerializer)
VeniceWriterOptions.Builder	setMaxRecordSizeBytes(int maxRecordSizeBytes)
VeniceWriterOptions.Builder	setPartitionCount(Integer partitionCount)
VeniceWriterOptions.Builder	setPartitioner(VenicePartitioner partitioner)
VeniceWriterOptions.Builder	setProducerCompressionEnabled(boolean producerCompressionEnabled)
VeniceWriterOptions.Builder	setProducerCount(int producerCount)
VeniceWriterOptions.Builder	setProducerQueueSize(int producerQueueSize)
VeniceWriterOptions.Builder	setProducerThreadCount(int producerThreadCount)
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 Details

Builder

public Builder(String topic)

Method Details

build

public VeniceWriterOptions build()

setBrokerAddress

public VeniceWriterOptions.Builder setBrokerAddress(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(Integer partitionCount)

setMaxRecordSizeBytes

public VeniceWriterOptions.Builder setMaxRecordSizeBytes(int maxRecordSizeBytes)

setProducerCompressionEnabled

public VeniceWriterOptions.Builder setProducerCompressionEnabled(boolean producerCompressionEnabled)

setProducerCount

public VeniceWriterOptions.Builder setProducerCount(int producerCount)

setProducerThreadCount

public VeniceWriterOptions.Builder setProducerThreadCount(int producerThreadCount)

setProducerQueueSize

public VeniceWriterOptions.Builder setProducerQueueSize(int producerQueueSize)