Package com.linkedin.venice.controller

Class AdminTopicMetadataAccessor

java.lang.Object

com.linkedin.venice.controller.AdminTopicMetadataAccessor

Direct Known Subclasses:

InMemoryAdminTopicMetadataAccessor, ZkAdminTopicMetadataAccessor

public abstract class AdminTopicMetadataAccessor
extends Object

Constructor Summary

Constructors

Constructor	Description
AdminTopicMetadataAccessor()

Method Summary

Modifier and Type	Method	Description
static Map<String,Long>	generateMetadataMap(Optional<Long> localOffset, Optional<Long> upstreamOffset, Optional<Long> executionId, Optional<Long> adminOperationProtocolVersion)
static long	getAdminOperationProtocolVersion(Map<String,Long> metadata)
static long	getExecutionId(Map<String,Long> metadata)
abstract Map<String,Long>	getMetadata(String clusterName)	Retrieve the latest metadata map.
static Pair<Long,Long>	getOffsets(Map<String,Long> metadata)
abstract void	updateMetadata(String clusterName, Map<String,Long> metadata)	Update specific metadata for a given cluster in a single transaction with information provided in metadata.

Methods inherited from class java.lang.Object

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

Constructor Details

AdminTopicMetadataAccessor

public AdminTopicMetadataAccessor()

Method Details

generateMetadataMap

public static Map<String,Long> generateMetadataMap(Optional<Long> localOffset,
 Optional<Long> upstreamOffset,
 Optional<Long> executionId,
 Optional<Long> adminOperationProtocolVersion)

Returns:

a map with OFFSET_KEY, UPSTREAM_OFFSET_KEY, EXECUTION_ID_KEY, ADMIN_OPERATION_PROTOCOL_VERSION_KEY specified to input values.

getOffsets

public static Pair<Long,Long> getOffsets(Map<String,Long> metadata)

Returns:

a pair of values to which the specified keys are mapped to OFFSET_KEY and UPSTREAM_OFFSET_KEY.

getExecutionId

public static long getExecutionId(Map<String,Long> metadata)

Returns:

the value to which the specified key is mapped to EXECUTION_ID_KEY.

getAdminOperationProtocolVersion

public static long getAdminOperationProtocolVersion(Map<String,Long> metadata)

Returns:

the value to which the specified key is mapped to ADMIN_OPERATION_PROTOCOL_VERSION_KEY.

updateMetadata

public abstract void updateMetadata(String clusterName,
 Map<String,Long> metadata)

Update specific metadata for a given cluster in a single transaction with information provided in metadata.

Parameters:

clusterName - of the cluster at interest.

metadata - map containing relevant information.

getMetadata

public abstract Map<String,Long> getMetadata(String clusterName)

Retrieve the latest metadata map.

Parameters:

clusterName - of the cluster at interest.