Package com.linkedin.venice.schema

Class SchemaRepoBackedSchemaReader

java.lang.Object

com.linkedin.venice.schema.SchemaRepoBackedSchemaReader

All Implemented Interfaces:

SchemaReader, java.io.Closeable, java.lang.AutoCloseable

public class SchemaRepoBackedSchemaReader
extends java.lang.Object
implements SchemaReader

Constructor Summary

Constructors

Constructor	Description
SchemaRepoBackedSchemaReader(ReadOnlySchemaRepository schemaRepository, java.lang.String storeName)

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.avro.Schema	getKeySchema()
DerivedSchemaEntry	getLatestUpdateSchema()
org.apache.avro.Schema	getLatestValueSchema()
java.lang.Integer	getLatestValueSchemaId()	Get the latest value schema id.
org.apache.avro.Schema	getUpdateSchema(int valueSchemaId)
org.apache.avro.Schema	getValueSchema(int id)
int	getValueSchemaId(org.apache.avro.Schema schema)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 java.io.Closeable

getKeySchema

public org.apache.avro.Schema getKeySchema()

Specified by:

getKeySchema in interface SchemaReader

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

getLatestValueSchema

public org.apache.avro.Schema getLatestValueSchema()

Specified by:

getLatestValueSchema 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

getLatestUpdateSchema

public DerivedSchemaEntry getLatestUpdateSchema()

Specified by:

getLatestUpdateSchema in interface SchemaReader