Package com.linkedin.venice.helix

Class HelixReadOnlyZKSharedSchemaRepository

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlySchemaRepository

com.linkedin.venice.helix.HelixReadOnlyZKSharedSchemaRepository

All Implemented Interfaces:

ReadOnlySchemaRepository, StoreDataChangedListener, VeniceResource

Direct Known Subclasses:

SharedHelixReadOnlyZKSharedSchemaRepository

public class HelixReadOnlyZKSharedSchemaRepository
extends HelixReadOnlySchemaRepository

This repository is used to retrieve all the zk shared system store schemas from the system store cluster. The reason to introduce this class is that this class needs to use a HelixReadOnlyZKSharedSystemStoreRepository to make sure that this repo only accesses the schemas belonging to zk shared system stores to avoid unnnecessary zk watches.

Field Summary

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

VALUE_SCHEMA_STARTING_ID

Constructor Summary

Constructors

Constructor	Description
HelixReadOnlyZKSharedSchemaRepository(HelixReadOnlyZKSharedSystemStoreRepository storeRepository, org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapter, String systemStoreClusterName, int refreshAttemptsForZkReconnect, long refreshIntervalForZkReconnectInMs)

Method Summary

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

clear, getDerivedSchema, getDerivedSchemaId, getDerivedSchemas, getKeySchema, getLatestDerivedSchema, getReplicationMetadataSchema, getReplicationMetadataSchemas, getSupersetOrLatestValueSchema, getSupersetSchema, getValueSchema, getValueSchemaId, getValueSchemas, handleStoreChanged, handleStoreCreated, handleStoreDeleted, hasValueSchema, refresh

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.ReadOnlySchemaRepository

getLatestDerivedSchema

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

handleStoreDeleted

Constructor Details

HelixReadOnlyZKSharedSchemaRepository

public HelixReadOnlyZKSharedSchemaRepository(HelixReadOnlyZKSharedSystemStoreRepository storeRepository,
 org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapter,
 String systemStoreClusterName,
 int refreshAttemptsForZkReconnect,
 long refreshIntervalForZkReconnectInMs)