Package com.linkedin.venice.writer
Class VeniceWriterOptions
- java.lang.Object
-
- com.linkedin.venice.writer.VeniceWriterOptions
-
public class VeniceWriterOptions extends java.lang.Object
VeniceWriterOptions is used to pass arguments to VeniceWriter constructor. Before passing VeniceWriterOptions object to VeniceWriter, VeniceWriterFactory methods use it to set some configs.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
VeniceWriterOptions.Builder
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
getBrokerAddress()
VeniceKafkaSerializer
getKeySerializer()
int
getMaxRecordSizeBytes()
java.lang.Integer
getPartitionCount()
VenicePartitioner
getPartitioner()
int
getProducerCount()
int
getProducerQueueSize()
int
getProducerThreadCount()
Time
getTime()
java.lang.String
getTopicName()
VeniceKafkaSerializer
getValueSerializer()
VeniceKafkaSerializer
getWriteComputeSerializer()
boolean
isChunkingEnabled()
boolean
isProducerCompressionEnabled()
boolean
isRmdChunkingEnabled()
java.lang.String
toString()
-
-
-
Method Detail
-
getBrokerAddress
public java.lang.String getBrokerAddress()
-
getTopicName
public java.lang.String getTopicName()
-
getKeySerializer
public VeniceKafkaSerializer getKeySerializer()
-
getValueSerializer
public VeniceKafkaSerializer getValueSerializer()
-
getWriteComputeSerializer
public VeniceKafkaSerializer getWriteComputeSerializer()
-
getPartitioner
public VenicePartitioner getPartitioner()
-
getTime
public Time getTime()
-
getPartitionCount
public java.lang.Integer getPartitionCount()
-
isChunkingEnabled
public boolean isChunkingEnabled()
-
isRmdChunkingEnabled
public boolean isRmdChunkingEnabled()
-
getMaxRecordSizeBytes
public int getMaxRecordSizeBytes()
-
isProducerCompressionEnabled
public boolean isProducerCompressionEnabled()
-
getProducerCount
public int getProducerCount()
-
getProducerThreadCount
public int getProducerThreadCount()
-
getProducerQueueSize
public int getProducerQueueSize()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-