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
java.util.Map<java.lang.String,java.lang.Long>	getMetadata(java.lang.String clusterName)	Retrieve the latest metadata map.
void	updateMetadata(java.lang.String clusterName, java.util.Map<java.lang.String,java.lang.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 Detail

ZkAdminTopicMetadataAccessor

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

Method Detail

updateMetadata

public void updateMetadata(java.lang.String clusterName,
                           java.util.Map<java.lang.String,java.lang.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 java.util.Map<java.lang.String,java.lang.Long> getMetadata(java.lang.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)