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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	TopicMessageFinder.KeyPartitionInfo

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)
protected static TopicMessageFinder.KeyPartitionInfo	findPartitionIdForKey(ControllerClient controllerClient, String storeName, int versionNumber, String key, String keySchemaStr)
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)

findPartitionIdForKey

protected static TopicMessageFinder.KeyPartitionInfo findPartitionIdForKey(ControllerClient controllerClient,
 String storeName,
 int versionNumber,
 String key,
 String keySchemaStr)