Package com.linkedin.venice.meta

Interface ReadOnlySchemaRepository

    • Method Detail

      • getKeySchema

        SchemaEntry getKeySchema​(java.lang.String storeName)
        Get key schema for the given store.

      • getValueSchema

        SchemaEntry getValueSchema​(java.lang.String storeName,
                           int id)
        Get value schema for the given store and value schema id.

      • hasValueSchema

        boolean hasValueSchema​(java.lang.String storeName,
                       int id)
        Check whether the specified schema id is valid or not

      • getValueSchemaId

        int getValueSchemaId​(java.lang.String storeName,
                     java.lang.String valueSchemaStr)
        Look up the schema id by store name and value schema.

      • getValueSchemas

        java.util.Collection<SchemaEntry> getValueSchemas​(java.lang.String storeName)
        Get all the value schemas for the given store.

      • getSupersetOrLatestValueSchema

        SchemaEntry getSupersetOrLatestValueSchema​(java.lang.String storeName)
        Get the most recent value schema or superset value schema if one exists.

      • getSupersetSchema

        SchemaEntry getSupersetSchema​(java.lang.String storeName)
        Get the superset value schema for a given store. Each store has at most one active superset schema. Specifically a store must have some features enabled (e.g. read compute, write compute) to have a superset value schema which evolves as new value schemas are added.
        Returns:
        Superset value schema or null if store {@param storeName} does not have any superset value schema.

      • getDerivedSchemaId

        GeneratedSchemaID getDerivedSchemaId​(java.lang.String storeName,
                                     java.lang.String derivedSchemaStr)
        Look up derived schema id and its corresponding value schema id by given store name and derived schema. This is likely used by clients that write to Venice
        Returns:
        a pair where the first value is value schema id and the second value is derived schema id

      • getDerivedSchema

        DerivedSchemaEntry getDerivedSchema​(java.lang.String storeName,
                                    int valueSchemaId,
                                    int writeComputeSchemaId)

      • getDerivedSchemas

        java.util.Collection<DerivedSchemaEntry> getDerivedSchemas​(java.lang.String storeName)

      • getLatestDerivedSchema

        DerivedSchemaEntry getLatestDerivedSchema​(java.lang.String storeName,
                                          int valueSchemaId)
        Get the most recent derived schema added to the given store and value schema id

      • getReplicationMetadataSchema

        RmdSchemaEntry getReplicationMetadataSchema​(java.lang.String storeName,
                                            int valueSchemaId,
                                            int replicationMetadataVersionId)

      • getReplicationMetadataSchemas

        java.util.Collection<RmdSchemaEntry> getReplicationMetadataSchemas​(java.lang.String storeName)

      • getLatestDerivedSchema

        default DerivedSchemaEntry getLatestDerivedSchema​(java.lang.String storeName)