Package com.linkedin.venice.hadoop.input.kafka

Class KafkaInputDictTrainer.ParamBuilder

java.lang.Object

com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer.ParamBuilder

Enclosing class:

KafkaInputDictTrainer

public static class KafkaInputDictTrainer.ParamBuilder
extends Object

Constructor Summary

Constructors

Constructor	Description
ParamBuilder()

Method Summary

Modifier and Type	Method	Description
KafkaInputDictTrainer.Param	build()
KafkaInputDictTrainer.ParamBuilder	setCompressionDictSize(int compressionDictSize)
KafkaInputDictTrainer.ParamBuilder	setDictSampleSize(int dictSampleSize)
KafkaInputDictTrainer.ParamBuilder	setKafkaInputBroker(String kafkaInputBroker)
KafkaInputDictTrainer.ParamBuilder	setKeySchema(String keySchema)
KafkaInputDictTrainer.ParamBuilder	setNewKMESchemasFromController(Map<Integer,String> newKMESchemasFromController)
KafkaInputDictTrainer.ParamBuilder	setSourceVersionChunkingEnabled(boolean chunkingEnabled)
KafkaInputDictTrainer.ParamBuilder	setSourceVersionCompressionStrategy(CompressionStrategy compressionStrategy)
KafkaInputDictTrainer.ParamBuilder	setSslProperties(Properties sslProperties)
KafkaInputDictTrainer.ParamBuilder	setTopicName(String topicName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ParamBuilder

public ParamBuilder()

Method Details

setKafkaInputBroker

public KafkaInputDictTrainer.ParamBuilder setKafkaInputBroker(String kafkaInputBroker)

setTopicName

public KafkaInputDictTrainer.ParamBuilder setTopicName(String topicName)

setKeySchema

public KafkaInputDictTrainer.ParamBuilder setKeySchema(String keySchema)

setSslProperties

public KafkaInputDictTrainer.ParamBuilder setSslProperties(Properties sslProperties)

setCompressionDictSize

public KafkaInputDictTrainer.ParamBuilder setCompressionDictSize(int compressionDictSize)

setDictSampleSize

public KafkaInputDictTrainer.ParamBuilder setDictSampleSize(int dictSampleSize)

setSourceVersionCompressionStrategy

public KafkaInputDictTrainer.ParamBuilder setSourceVersionCompressionStrategy(CompressionStrategy compressionStrategy)

setSourceVersionChunkingEnabled

public KafkaInputDictTrainer.ParamBuilder setSourceVersionChunkingEnabled(boolean chunkingEnabled)

setNewKMESchemasFromController

public KafkaInputDictTrainer.ParamBuilder setNewKMESchemasFromController(Map<Integer,String> newKMESchemasFromController)

build

public KafkaInputDictTrainer.Param build()