Package com.linkedin.venice.writer
Class VeniceWriterOptions.Builder
java.lang.Object
com.linkedin.venice.writer.VeniceWriterOptions.Builder
- Enclosing class:
- VeniceWriterOptions
-
Constructor Summary
ConstructorsConstructorDescriptionBuilder
(String topic, VeniceWriterOptions options) Create a newVeniceWriterOptions.Builder
instance from an existingVeniceWriterOptions
instance. -
Method Summary
Modifier and TypeMethodDescriptionbuild()
setBatchIntervalInMs
(long batchIntervalInMs) setBrokerAddress
(String brokerAddress) setChunkingEnabled
(boolean chunkingEnabled) setKeyPayloadSerializer
(VeniceKafkaSerializer keyPayloadSerializer) setMaxBatchSizeInBytes
(int maxBatchSizeInBytes) setMaxRecordSizeBytes
(int maxRecordSizeBytes) setPartitionCount
(Integer partitionCount) setPartitioner
(VenicePartitioner partitioner) setProducerCompressionEnabled
(boolean producerCompressionEnabled) setProducerCount
(int producerCount) setProducerQueueSize
(int producerQueueSize) setProducerThreadCount
(int producerThreadCount) setPubSubMessageSerializer
(PubSubMessageSerializer pubSubMessageSerializer) setRmdChunkingEnabled
(boolean rmdChunkingEnabled) setUseKafkaKeySerializer
(boolean useKafkaKeySerializer) setValuePayloadSerializer
(VeniceKafkaSerializer valuePayloadSerializer) setWriteComputePayloadSerializer
(VeniceKafkaSerializer writeComputePayloadSerializer)
-
Constructor Details
-
Builder
-
Builder
Create a newVeniceWriterOptions.Builder
instance from an existingVeniceWriterOptions
instance. Having a dummy topic here is to avoid ambiguous constructor match for compiler.
-
-
Method Details
-
build
-
setBrokerAddress
-
setUseKafkaKeySerializer
-
setChunkingEnabled
-
setRmdChunkingEnabled
-
setKeyPayloadSerializer
public VeniceWriterOptions.Builder setKeyPayloadSerializer(VeniceKafkaSerializer keyPayloadSerializer) -
setValuePayloadSerializer
public VeniceWriterOptions.Builder setValuePayloadSerializer(VeniceKafkaSerializer valuePayloadSerializer) -
setWriteComputePayloadSerializer
public VeniceWriterOptions.Builder setWriteComputePayloadSerializer(VeniceKafkaSerializer writeComputePayloadSerializer) -
setPartitioner
-
setTime
-
setPartitionCount
-
setMaxRecordSizeBytes
-
setProducerCompressionEnabled
public VeniceWriterOptions.Builder setProducerCompressionEnabled(boolean producerCompressionEnabled) -
setProducerCount
-
setProducerThreadCount
-
setProducerQueueSize
-
setPubSubMessageSerializer
public VeniceWriterOptions.Builder setPubSubMessageSerializer(PubSubMessageSerializer pubSubMessageSerializer) -
setBatchIntervalInMs
-
setMaxBatchSizeInBytes
-