Package com.linkedin.venice.helix

Class HelixSchemaAccessor

java.lang.Object
com.linkedin.venice.helix.HelixSchemaAccessor
public class HelixSchemaAccessor extends Object

  • Field Details

    • VALUE_SCHEMA_STARTING_ID

      public static final int VALUE_SCHEMA_STARTING_ID
      See Also:

  • Constructor Details

    • HelixSchemaAccessor

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

    • HelixSchemaAccessor

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

  • Method Details

    • getKeySchema

      public SchemaEntry getKeySchema(String storeName)

    • getValueSchema

      public SchemaEntry getValueSchema(String storeName, String id)

    • getAllValueSchemas

      public List<SchemaEntry> getAllValueSchemas(String storeName)

    • getDerivedSchema

      public DerivedSchemaEntry getDerivedSchema(String storeName, String derivedSchemaIdPair)

    • getAllDerivedSchemas

      public List<DerivedSchemaEntry> getAllDerivedSchemas(String storeName)

    • createKeySchema

      public void createKeySchema(String storeName, SchemaEntry schemaEntry)

    • addValueSchema

      public void addValueSchema(String storeName, SchemaEntry schemaEntry)

    • addDerivedSchema

      public void addDerivedSchema(String storeName, DerivedSchemaEntry derivedSchemaEntry)

    • removeDerivedSchema

      public void removeDerivedSchema(String storeName, String derivedSchemaIdPair)

    • subscribeKeySchemaCreationChange

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

    • unsubscribeKeySchemaCreationChange

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

    • subscribeValueSchemaCreationChange

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

    • unsubscribeValueSchemaCreationChange

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

    • subscribeDerivedSchemaCreationChange

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

    • unsubscribeDerivedSchemaCreationChanges

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

    • getStorePath

      protected StringBuilder getStorePath(String storeName)

    • getReplicationMetadataSchema

      public RmdSchemaEntry getReplicationMetadataSchema(String storeName, String replicationMetadataVersionIdPair)

    • getAllReplicationMetadataSchemas

      public List<RmdSchemaEntry> getAllReplicationMetadataSchemas(String storeName)

    • addReplicationMetadataSchema

      public void addReplicationMetadataSchema(String storeName, RmdSchemaEntry rmdSchemaEntry)

    • subscribeReplicationMetadataSchemaCreationChange

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

    • unsubscribeReplicationMetadataSchemaCreationChanges

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

    • removeValueSchema

      public void removeValueSchema(String storeName, int schemaID)