Package com.linkedin.venice.utils

Class DictionaryUtils

java.lang.Object

com.linkedin.venice.utils.DictionaryUtils

public class DictionaryUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
DictionaryUtils()

Method Summary

Modifier and Type	Method	Description
static ByteBuffer	readDictionaryFromKafka(String topicName, PubSubConsumerAdapter pubSubConsumer, PubSubTopicRepository pubSubTopicRepository)	This function reads the kafka topic for the store version for the Start Of Push message which contains the compression dictionary.
static ByteBuffer	readDictionaryFromKafka(String topicName, VeniceProperties props)

Methods inherited from class java.lang.Object

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

Constructor Details

DictionaryUtils

public DictionaryUtils()

Method Details

readDictionaryFromKafka

public static ByteBuffer readDictionaryFromKafka(String topicName,
 VeniceProperties props)

readDictionaryFromKafka

public static ByteBuffer readDictionaryFromKafka(String topicName,
 PubSubConsumerAdapter pubSubConsumer,
 PubSubTopicRepository pubSubTopicRepository)

This function reads the kafka topic for the store version for the Start Of Push message which contains the compression dictionary. Once the Start of Push message has been read, the consumer stops.

Returns:

The compression dictionary wrapped in a ByteBuffer, or null if no dictionary was present in the Start Of Push message.