Package com.linkedin.venice.schema

Class SchemaRepoBackedSchemaReader

java.lang.Object

com.linkedin.venice.schema.SchemaRepoBackedSchemaReader

All Implemented Interfaces:

SchemaReader, Closeable, AutoCloseable

public class SchemaRepoBackedSchemaReader
extends Object
implements SchemaReader

Constructor Summary

Constructors

Constructor	Description
SchemaRepoBackedSchemaReader(ReadOnlySchemaRepository schemaRepository, String storeName)

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.avro.Schema	getKeySchema()
DerivedSchemaEntry	getLatestUpdateSchema()
org.apache.avro.Schema	getLatestValueSchema()
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)	Return the schema ID of any schema that has the same parsing canonical form as the schema provided.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.schema.SchemaReader

getLatestValueSchemaId

Constructor Details

SchemaRepoBackedSchemaReader

public SchemaRepoBackedSchemaReader(ReadOnlySchemaRepository schemaRepository,
 String storeName)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface 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)

Description copied from interface: SchemaReader

Return the schema ID of any schema that has the same parsing canonical form as the schema provided. If multiple schemas have the same parsing canonical form, return the one with the largest ID.

Specified by:

getValueSchemaId in interface SchemaReader

Parameters:

schema - The schema for which the schema ID is needed

Returns:

The ID of the schema that has the same parsing canonical form as the schema provided

getLatestValueSchema

public org.apache.avro.Schema getLatestValueSchema()

Specified by:

getLatestValueSchema in interface SchemaReader

getLatestValueSchemaId

public 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