Package com.linkedin.venice

Class TopicMessageFinder

java.lang.Object

com.linkedin.venice.TopicMessageFinder

public class TopicMessageFinder
extends Object

This class is used to find messages for a given key from a specified topic.

Constructor Summary

Constructors

Constructor	Description
TopicMessageFinder()

Method Summary

Modifier and Type	Method	Description
static long	find(ControllerClient controllerClient, PubSubConsumerAdapter consumer, String topic, String keyString, long startTimestampEpochMs, long endTimestampEpochMs, long progressInterval)
static byte[]	serializeKey(String keyString, String keySchemaStr)

Methods inherited from class java.lang.Object

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

Constructor Details

TopicMessageFinder

public TopicMessageFinder()

Method Details

find

public static long find(ControllerClient controllerClient,
 PubSubConsumerAdapter consumer,
 String topic,
 String keyString,
 long startTimestampEpochMs,
 long endTimestampEpochMs,
 long progressInterval)

serializeKey

public static byte[] serializeKey(String keyString,
 String keySchemaStr)