Package com.linkedin.venice.offsets

Class DeepCopyOffsetManager

java.lang.Object

com.linkedin.venice.offsets.DeepCopyOffsetManager

All Implemented Interfaces:

OffsetManager

Direct Known Subclasses:

DeepCopyStorageMetadataService

public class DeepCopyOffsetManager
extends Object
implements OffsetManager

This class is used to systematically copy OffsetRecord instances rather than passing them as is. This is necessary in TestAdminConsumptionTask and StoreConsumptionTaskTest.

Constructor Summary

Constructors

Constructor	Description
DeepCopyOffsetManager(OffsetManager delegate)

Method Summary

Modifier and Type	Method	Description
void	clearOffset(String topicName, int partitionId)
OffsetRecord	getLastOffset(String topicName, int partitionId, PubSubContext pubSubContext)	Gets the Last Known persisted offset of this consumer.
void	put(String topicName, int partitionId, OffsetRecord record)	Records the offset with underlying/external storage.

Methods inherited from class java.lang.Object

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

Constructor Details

DeepCopyOffsetManager

public DeepCopyOffsetManager(OffsetManager delegate)

Method Details

put

public void put(String topicName,
 int partitionId,
 OffsetRecord record)
         throws VeniceException

Description copied from interface: OffsetManager

Records the offset with underlying/external storage. Persistence to disk happens in configurable time interval by a background thread. For example in case of BDB the check pointer thread can be configured to do this.

Specified by:

put in interface OffsetManager

Parameters:

topicName - kafka topic to which the consumer thread is registered to.

partitionId - kafka partition id for which the consumer thread is registered to.

record - OffSetRecord containing last read offset for the topic and partition combination.

Throws:

VeniceException

clearOffset

public void clearOffset(String topicName,
 int partitionId)

Specified by:

clearOffset in interface OffsetManager

getLastOffset

public OffsetRecord getLastOffset(String topicName,
 int partitionId,
 PubSubContext pubSubContext)
                           throws VeniceException

Description copied from interface: OffsetManager

Gets the Last Known persisted offset of this consumer.

Specified by:

getLastOffset in interface OffsetManager

Parameters:

topicName - kafka topic to which the consumer thread is registered to.

partitionId - kafka partition id for which the consumer thread is registered to.

pubSubContext - PubSubContext for passing PubSub related dependencies

Returns:

OffsetRecord - contains offset and time when it was recorded before the consumer thread went down. consumer

Throws:

VeniceException