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	setKeyPayloadSerializer(VeniceKafkaSerializer keyPayloadSerializer)
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)

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)