Class SchemaRepoBackedSchemaReader

  • All Implemented Interfaces:
    SchemaReader,, java.lang.AutoCloseable

    public class SchemaRepoBackedSchemaReader
    extends java.lang.Object
    implements SchemaReader
    • Constructor Detail

      • SchemaRepoBackedSchemaReader

        public SchemaRepoBackedSchemaReader​(ReadOnlySchemaRepository schemaRepository,
                                            java.lang.String storeName)
    • Method Detail

      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface
      • getValueSchema

        public org.apache.avro.Schema getValueSchema​(int id)
        Specified by:
        getValueSchema in interface SchemaReader
      • getValueSchemaId

        public int getValueSchemaId​(org.apache.avro.Schema schema)
        Specified by:
        getValueSchemaId in interface SchemaReader
      • getLatestValueSchemaId

        public java.lang.Integer getLatestValueSchemaId()
        Description copied from interface: SchemaReader
        Get the latest value schema id. This may be different from the value schema with the largest id if the superset schema is not the value schema with the largest id
        Specified by:
        getLatestValueSchemaId in interface SchemaReader
      • getUpdateSchema

        public org.apache.avro.Schema getUpdateSchema​(int valueSchemaId)
        Specified by:
        getUpdateSchema in interface SchemaReader