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)
Builder(String topic, VeniceWriterOptions options)	Create a new VeniceWriterOptions.Builder instance from an existing VeniceWriterOptions instance.

Method Summary

Modifier and Type	Method	Description
VeniceWriterOptions	build()
VeniceWriterOptions.Builder	setBatchIntervalInMs(long batchIntervalInMs)
VeniceWriterOptions.Builder	setBrokerAddress(String brokerAddress)
VeniceWriterOptions.Builder	setChunkingEnabled(boolean chunkingEnabled)
VeniceWriterOptions.Builder	setKeyPayloadSerializer(VeniceKafkaSerializer keyPayloadSerializer)
VeniceWriterOptions.Builder	setMaxBatchSizeInBytes(int maxBatchSizeInBytes)
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	setPubSubMessageSerializer(PubSubMessageSerializer pubSubMessageSerializer)
VeniceWriterOptions.Builder	setRmdChunkingEnabled(boolean rmdChunkingEnabled)
VeniceWriterOptions.Builder	setTime(Time time)
VeniceWriterOptions.Builder	setUseKafkaKeySerializer(boolean useKafkaKeySerializer)
VeniceWriterOptions.Builder	setValuePayloadSerializer(VeniceKafkaSerializer valuePayloadSerializer)
VeniceWriterOptions.Builder	setWriteComputePayloadSerializer(VeniceKafkaSerializer writeComputePayloadSerializer)

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)

Builder

public Builder(String topic,
 VeniceWriterOptions options)

Create a new VeniceWriterOptions.Builder instance from an existing VeniceWriterOptions instance. Having a dummy topic here is to avoid ambiguous constructor match for compiler.

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)

setKeyPayloadSerializer

public VeniceWriterOptions.Builder setKeyPayloadSerializer(VeniceKafkaSerializer keyPayloadSerializer)

setValuePayloadSerializer

public VeniceWriterOptions.Builder setValuePayloadSerializer(VeniceKafkaSerializer valuePayloadSerializer)

setWriteComputePayloadSerializer

public VeniceWriterOptions.Builder setWriteComputePayloadSerializer(VeniceKafkaSerializer writeComputePayloadSerializer)

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)

setPubSubMessageSerializer

public VeniceWriterOptions.Builder setPubSubMessageSerializer(PubSubMessageSerializer pubSubMessageSerializer)

setBatchIntervalInMs

public VeniceWriterOptions.Builder setBatchIntervalInMs(long batchIntervalInMs)

setMaxBatchSizeInBytes

public VeniceWriterOptions.Builder setMaxBatchSizeInBytes(int maxBatchSizeInBytes)