Package com.linkedin.venice.controller.helix

Class SharedHelixReadOnlyZKSharedSystemStoreRepository

java.lang.Object

com.linkedin.venice.helix.CachedReadOnlyStoreRepository

com.linkedin.venice.helix.HelixReadOnlyStoreRepository

com.linkedin.venice.helix.HelixReadOnlyZKSharedSystemStoreRepository

com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSystemStoreRepository

All Implemented Interfaces:

ReadOnlyStoreRepository, VeniceResource, java.io.Closeable, java.lang.AutoCloseable

public class SharedHelixReadOnlyZKSharedSystemStoreRepository
extends HelixReadOnlyZKSharedSystemStoreRepository
implements java.io.Closeable

This class is intended to only be used in Controller, which is sharing one instance across all the clusters. Since the leader->standby transition for a given cluster will clear all the resources, this implementation will do nothing in clear() since it will be shared across all the clusters, whose leader are in the same Controller node.

Field Summary

Fields inherited from class com.linkedin.venice.helix.CachedReadOnlyStoreRepository

clusterLockManager, clusterName, clusterStoreRepositoryPath, STORE_REPOSITORY_PATH, storeMap, zkClient, zkDataAccessor

Constructor Summary

Constructors

Constructor	Description
SharedHelixReadOnlyZKSharedSystemStoreRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer compositeSerializer, java.lang.String systemStoreClusterName)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	close()

Methods inherited from class com.linkedin.venice.helix.HelixReadOnlyZKSharedSystemStoreRepository

getBatchGetLimit, getStore, getStoreOrThrow, getStoresFromZk, getTotalStoreReadQuota, hasStore, isReadComputationEnabled, onRepositoryChanged, refresh, refreshOneStore

Methods inherited from class com.linkedin.venice.helix.HelixReadOnlyStoreRepository

onStoreChanged, putStore, removeStore

Methods inherited from class com.linkedin.venice.helix.CachedReadOnlyStoreRepository

getAllStores, getStoreFromZk, getStoresFromZk, getStoreZkPath, notifyStoreChanged, notifyStoreCreated, notifyStoreDeleted, registerStoreDataChangedListener, unregisterStoreDataChangedListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.meta.ReadOnlyStoreRepository

waitVersion, waitVersion

Constructor Detail

SharedHelixReadOnlyZKSharedSystemStoreRepository

public SharedHelixReadOnlyZKSharedSystemStoreRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
                                                        HelixAdapterSerializer compositeSerializer,
                                                        java.lang.String systemStoreClusterName)

Method Detail

clear

public void clear()

Specified by:

clear in interface VeniceResource

Overrides:

clear in class HelixReadOnlyZKSharedSystemStoreRepository

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException