Package com.linkedin.venice.controller.helix

Class SharedHelixReadOnlyZKSharedSchemaRepository

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlySchemaRepository

com.linkedin.venice.helix.HelixReadOnlyZKSharedSchemaRepository

com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSchemaRepository

All Implemented Interfaces:

ReadOnlySchemaRepository, StoreDataChangedListener, VeniceResource, java.io.Closeable, java.lang.AutoCloseable

public class SharedHelixReadOnlyZKSharedSchemaRepository
extends HelixReadOnlyZKSharedSchemaRepository
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.HelixReadOnlySchemaRepository

VALUE_SCHEMA_STARTING_ID

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	clear()	Clear local cache and watches
void	close()

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

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 Detail

SharedHelixReadOnlyZKSharedSchemaRepository

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

Method Detail

clear

public void clear()

Description copied from class: HelixReadOnlySchemaRepository

Clear local cache and watches

Specified by:

clear in interface VeniceResource

Overrides:

clear in class HelixReadOnlySchemaRepository

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