Package com.linkedin.venice.helix
package com.linkedin.venice.helix
-
ClassDescriptionInterface defines the ways to access to the allowlist of Helix NodeId.Listener used to monitor zk connection state change and refresh venice resource once zk connection is reconnected.This class is registered in ZKClient to handle derive schema serialization.Serializer to adapt venice serializer to PathBasedZkSerializer.Get routing data from Helix and convert it to our Venice partition and replica objects.Extend
HelixBaseRoutingRepositoryto leverage customized view data for offline push.Extend HelixBaseRoutingRepository to leverage external view data.Extend RoutingTableChangeListener to leverage customized view data for hybrid store quota.This repository is used to store the instance config per instance.Convert between ZNRecord in Helix instanceConfig and Venice instance.This class is used to monitor the current live instances(Helix participators).An Enum enumerating all valid types ofHelixPartitionState.A parent class to access Helix customized partition state, which is different from the states defined in the state model.A class for accessing partition offline push and hybrid quota status in Helix customized state (per Helix instance) on ZookeeperThis class is used to cache live cluster configs.This class is used to cache store schema and provide various query operations.This repository provides the read-only access to both system stores and regular stores.This class is used to fetch all store configs from ZK and cached locally, then provide the way to read those configs.This repository provides an read only interface to access both system store and regular venice store.This repository is used to retrieve all the zk shared system store schemas from the system store cluster.This repository provides an interface to access zk shared system stores only.This class is used to modify live cluster configs.This class is used to add schema entries for stores.This repository supports the following operations: 1.Read write store repository which uses Helix as storage.This repository provides an read-write interface to access both system store and regular venice store.States of Venice node in Helix.The control message changed built on Helix message service.Serializer used to convert the data betweenOfflinePushStatusand json.Serializer used to convert the data betweenPartitionStatusand json.Replica is the basic unit to distribute data, replica is belong to a partition and running in a instance.This class is registered in ZKClient to handle Replication metadata schema serialization.Assignments for all of resources.Serializer used to convert data between RouterClusterConfig Object and JSON stringA wrapper aroundHelixDataAccessorwhich disables the unsafe functionality.A wrapper aroundHelixManagerwhich disables the unsafe functionality.This class to use to serialize/deserialize Zookeeper nodeCached wrapper for theStoragePersonaAccessorclass, which keeps a map of store names to personas that contain them, as well as caches Zookeeper personas.Helper class which listens to changes from aReadOnlyStoreRepositoryand updates the caches and ZK of the StoragePersonaRepository accordingly.Serializer used to convert the data between Store and json.Mixin used to add the annotation to figure out the constructor used by Jackson lib when deserialize the versionMixin used to add the annotation to figure out the constructor used by Jackson lib when deserialize the store.Mixin used to add the annotation to figure out the constructor used by Jackson lib when deserialize the versionVenice implementation ofOfflinePushAccessor.Class used to access to the allowlist stored in ZK.Manage live routers through Zookeeper.The class is used to access the store configs in Zookeeper.