Class KafkaInputDictTrainer

java.lang.Object
com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer

public class KafkaInputDictTrainer extends Object
Zstd dict trainer for Kafka Repush. This class will try to read a few records from every partition as samples of dict trainer.
  • Constructor Details

  • Method Details

    • trainDict

      public byte[] trainDict()