Package com.linkedin.venice.utils

Class DictionaryUtils

java.lang.Object

com.linkedin.venice.utils.DictionaryUtils

public class DictionaryUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
DictionaryUtils()

Method Summary

Modifier and Type	Method	Description
static java.nio.ByteBuffer	readDictionaryFromKafka(java.lang.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 java.nio.ByteBuffer	readDictionaryFromKafka(java.lang.String topicName, VeniceProperties props)

Methods inherited from class java.lang.Object

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

Constructor Detail

DictionaryUtils

public DictionaryUtils()

Method Detail

readDictionaryFromKafka

public static java.nio.ByteBuffer readDictionaryFromKafka(java.lang.String topicName,
                                                          VeniceProperties props)

readDictionaryFromKafka

public static java.nio.ByteBuffer readDictionaryFromKafka(java.lang.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.