Package com.linkedin.venice.controller

Class ZkAdminTopicMetadataAccessor

java.lang.Object

com.linkedin.venice.controller.AdminTopicMetadataAccessor

com.linkedin.venice.controller.ZkAdminTopicMetadataAccessor

public class ZkAdminTopicMetadataAccessor
extends AdminTopicMetadataAccessor

This class is responsible for accessing and updating the admin topic metadata stored in Zookeeper.

Field Summary

Fields inherited from class com.linkedin.venice.controller.AdminTopicMetadataAccessor

ADMIN_OPERATION_PROTOCOL_VERSION_KEY, EXECUTION_ID_KEY, OFFSET_KEY, POSITION_KEY, UNDEFINED_VALUE, UPSTREAM_OFFSET_KEY, UPSTREAM_POSITION_KEY

Constructor Summary

Constructors

Constructor	Description
ZkAdminTopicMetadataAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, VeniceControllerClusterConfig clusterConfig)
ZkAdminTopicMetadataAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, VeniceControllerMultiClusterConfig multiClusterConfig)

Method Summary

Modifier and Type	Method	Description
AdminMetadata	getMetadata(String clusterName)	Retrieve the latest metadata.
void	updateMetadata(String clusterName, AdminMetadata metadataDelta)	Update the upstream metadata map for the given cluster with specific information provided in metadata
void	updateV2Metadata(String clusterName, AdminMetadata metadata)

Methods inherited from class com.linkedin.venice.controller.AdminTopicMetadataAccessor

generateMetadataMap, getAdminOperationProtocolVersion, getExecutionId, getExecutionId, getOffsets, getOffsets, getPositions

Methods inherited from class java.lang.Object

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

Constructor Details

ZkAdminTopicMetadataAccessor

public ZkAdminTopicMetadataAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 VeniceControllerClusterConfig clusterConfig)

ZkAdminTopicMetadataAccessor

public ZkAdminTopicMetadataAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 VeniceControllerMultiClusterConfig multiClusterConfig)

Method Details

updateMetadata

public void updateMetadata(String clusterName,
 AdminMetadata metadataDelta)

Update the upstream metadata map for the given cluster with specific information provided in metadata

Specified by:

updateMetadata in class AdminTopicMetadataAccessor

Parameters:

clusterName - of the cluster at interest.

metadataDelta - AdminMetadata containing relevant information.

See Also:

• AdminTopicMetadataAccessor.updateMetadata(String, AdminMetadata)

updateV2Metadata

public void updateV2Metadata(String clusterName,
 AdminMetadata metadata)

getMetadata

public AdminMetadata getMetadata(String clusterName)

Description copied from class: AdminTopicMetadataAccessor

Retrieve the latest metadata.

Specified by:

getMetadata in class AdminTopicMetadataAccessor

Parameters:

clusterName - of the cluster at interest.

Returns:

AdminMetadata containing all metadata information

See Also:

• AdminTopicMetadataAccessor.getMetadata(String)