Package com.linkedin.venice.helix

Class HelixSchemaAccessor

  • public class HelixSchemaAccessor
extends java.lang.Object

    • Field Detail

      • VALUE_SCHEMA_STARTING_ID

        public static final int VALUE_SCHEMA_STARTING_ID
        See Also:
        Constant Field Values

    • Constructor Detail

      • HelixSchemaAccessor

        public HelixSchemaAccessor​(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
                           HelixAdapterSerializer helixAdapterSerializer,
                           java.lang.String clusterName)

      • HelixSchemaAccessor

        public HelixSchemaAccessor​(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
                           HelixAdapterSerializer helixAdapterSerializer,
                           java.lang.String clusterName,
                           int refreshAttemptsForZkReconnect,
                           long refreshIntervalForZkReconnectInMs)

    • Method Detail

      • getKeySchema

        public SchemaEntry getKeySchema​(java.lang.String storeName)

      • getValueSchema

        public SchemaEntry getValueSchema​(java.lang.String storeName,
                                  java.lang.String id)

      • getAllValueSchemas

        public java.util.List<SchemaEntry> getAllValueSchemas​(java.lang.String storeName)

      • getDerivedSchema

        public DerivedSchemaEntry getDerivedSchema​(java.lang.String storeName,
                                           java.lang.String derivedSchemaIdPair)

      • getAllDerivedSchemas

        public java.util.List<DerivedSchemaEntry> getAllDerivedSchemas​(java.lang.String storeName)

      • createKeySchema

        public void createKeySchema​(java.lang.String storeName,
                            SchemaEntry schemaEntry)

      • addValueSchema

        public void addValueSchema​(java.lang.String storeName,
                           SchemaEntry schemaEntry)

      • addDerivedSchema

        public void addDerivedSchema​(java.lang.String storeName,
                             DerivedSchemaEntry derivedSchemaEntry)

      • removeDerivedSchema

        public void removeDerivedSchema​(java.lang.String storeName,
                                java.lang.String derivedSchemaIdPair)

      • subscribeKeySchemaCreationChange

        public void subscribeKeySchemaCreationChange​(java.lang.String storeName,
                                             org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • unsubscribeKeySchemaCreationChange

        public void unsubscribeKeySchemaCreationChange​(java.lang.String storeName,
                                               org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • subscribeValueSchemaCreationChange

        public void subscribeValueSchemaCreationChange​(java.lang.String storeName,
                                               org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • unsubscribeValueSchemaCreationChange

        public void unsubscribeValueSchemaCreationChange​(java.lang.String storeName,
                                                 org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • subscribeDerivedSchemaCreationChange

        public void subscribeDerivedSchemaCreationChange​(java.lang.String storeName,
                                                 org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • unsubscribeDerivedSchemaCreationChanges

        public void unsubscribeDerivedSchemaCreationChanges​(java.lang.String storeName,
                                                    org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • getStorePath

        protected java.lang.StringBuilder getStorePath​(java.lang.String storeName)

      • getReplicationMetadataSchema

        public RmdSchemaEntry getReplicationMetadataSchema​(java.lang.String storeName,
                                                   java.lang.String replicationMetadataVersionIdPair)

      • getAllReplicationMetadataSchemas

        public java.util.List<RmdSchemaEntry> getAllReplicationMetadataSchemas​(java.lang.String storeName)

      • addReplicationMetadataSchema

        public void addReplicationMetadataSchema​(java.lang.String storeName,
                                         RmdSchemaEntry rmdSchemaEntry)

      • subscribeReplicationMetadataSchemaCreationChange

        public void subscribeReplicationMetadataSchemaCreationChange​(java.lang.String storeName,
                                                             org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • unsubscribeReplicationMetadataSchemaCreationChanges

        public void unsubscribeReplicationMetadataSchemaCreationChanges​(java.lang.String storeName,
                                                                org.apache.helix.zookeeper.zkclient.IZkChildListener childListener)

      • removeValueSchema

        public void removeValueSchema​(java.lang.String storeName,
                              int schemaID)