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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Map<String,Long>	getMetadata(String clusterName)	Retrieve the latest metadata map.
void	updateMetadata(String clusterName, Map<String,Long> metadata)	Update all relevant metadata for a given cluster in a single transaction.

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

generateMetadataMap, getExecutionId, getOffsets

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)

Method Details

updateMetadata

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

Description copied from class: AdminTopicMetadataAccessor

Update all relevant metadata for a given cluster in a single transaction.

Specified by:

updateMetadata in class AdminTopicMetadataAccessor

Parameters:

clusterName - of the cluster at interest.

metadata - map containing relevant information.

See Also:

• AdminTopicMetadataAccessor.updateMetadata(String, Map)

getMetadata

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

Description copied from class: AdminTopicMetadataAccessor

Retrieve the latest metadata map.

Specified by:

getMetadata in class AdminTopicMetadataAccessor

Parameters:

clusterName - of the cluster at interest.

See Also:

• AdminTopicMetadataAccessor.getMetadata(String)