Package com.linkedin.davinci.consumer

Class RecordChangeEventReadOnlySchemaRepository

java.lang.Object

com.linkedin.davinci.consumer.RecordChangeEventReadOnlySchemaRepository

All Implemented Interfaces:

ReadOnlySchemaRepository, VeniceResource

public class RecordChangeEventReadOnlySchemaRepository
extends Object
implements ReadOnlySchemaRepository

TODO: This class is a bit of a hack. We need to add functionality into the server to be able to query and retrieve schemas for different view types. But this functionality isn't available today. This class right now operates a shim interface to retrieve the right schema, but it runs the risk of the protocol not being easily evolvable.

Method Summary

Modifier and Type	Method	Description
void	clear()
DerivedSchemaEntry	getDerivedSchema(String storeName, int valueSchemaId, int writeComputeSchemaId)
GeneratedSchemaID	getDerivedSchemaId(String storeName, String derivedSchemaStr)	Look up derived schema id and its corresponding value schema id by given store name and derived schema.
Collection<DerivedSchemaEntry>	getDerivedSchemas(String storeName)
SchemaEntry	getKeySchema(String storeName)	Get key schema for the given store.
DerivedSchemaEntry	getLatestDerivedSchema(String storeName, int valueSchemaId)	Get the most recent derived schema added to the given store and value schema id
RmdSchemaEntry	getReplicationMetadataSchema(String storeName, int valueSchemaId, int replicationMetadataVersionId)
Collection<RmdSchemaEntry>	getReplicationMetadataSchemas(String storeName)
SchemaEntry	getSupersetOrLatestValueSchema(String storeName)	Get the most recent value schema or superset value schema if one exists.
SchemaEntry	getSupersetSchema(String storeName)	Get the superset value schema for a given store.
SchemaEntry	getValueSchema(String storeName, int id)	Get value schema for the given store and value schema id.
int	getValueSchemaId(String storeName, String valueSchemaStr)	Return the schema ID of any schema for the store that has the same parsing canonical form as the schema provided.
Collection<SchemaEntry>	getValueSchemas(String storeName)	Get all the value schemas for the given store.
boolean	hasValueSchema(String storeName, int id)	Check whether the specified schema id is valid or not
void	refresh()

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.meta.ReadOnlySchemaRepository

getLatestDerivedSchema

Method Details

refresh

public void refresh()

Specified by:

refresh in interface VeniceResource

clear

public void clear()

Specified by:

clear in interface VeniceResource

getKeySchema

public SchemaEntry getKeySchema(String storeName)

Description copied from interface: ReadOnlySchemaRepository

Get key schema for the given store.

Specified by:

getKeySchema in interface ReadOnlySchemaRepository

getValueSchema

public SchemaEntry getValueSchema(String storeName,
 int id)

Description copied from interface: ReadOnlySchemaRepository

Get value schema for the given store and value schema id.

Specified by:

getValueSchema in interface ReadOnlySchemaRepository

hasValueSchema

public boolean hasValueSchema(String storeName,
 int id)

Description copied from interface: ReadOnlySchemaRepository

Check whether the specified schema id is valid or not

Specified by:

hasValueSchema in interface ReadOnlySchemaRepository

getValueSchemaId

public int getValueSchemaId(String storeName,
 String valueSchemaStr)

Description copied from interface: ReadOnlySchemaRepository

Return the schema ID of any schema for the store that has the same parsing canonical form as the schema provided.

Specified by:

getValueSchemaId in interface ReadOnlySchemaRepository

getValueSchemas

public Collection<SchemaEntry> getValueSchemas(String storeName)

Description copied from interface: ReadOnlySchemaRepository

Get all the value schemas for the given store.

Specified by:

getValueSchemas in interface ReadOnlySchemaRepository

getSupersetOrLatestValueSchema

public SchemaEntry getSupersetOrLatestValueSchema(String storeName)

Description copied from interface: ReadOnlySchemaRepository

Get the most recent value schema or superset value schema if one exists.

Specified by:

getSupersetOrLatestValueSchema in interface ReadOnlySchemaRepository

getSupersetSchema

public SchemaEntry getSupersetSchema(String storeName)

Description copied from interface: ReadOnlySchemaRepository

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.

Specified by:

getSupersetSchema in interface ReadOnlySchemaRepository

Returns:

Superset value schema or null if store does not have any superset value schema.

getDerivedSchemaId

public GeneratedSchemaID getDerivedSchemaId(String storeName,
 String derivedSchemaStr)

Description copied from interface: ReadOnlySchemaRepository

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

Specified by:

getDerivedSchemaId in interface ReadOnlySchemaRepository

Returns:

a pair where the first value is value schema id and the second value is derived schema id

getDerivedSchema

public DerivedSchemaEntry getDerivedSchema(String storeName,
 int valueSchemaId,
 int writeComputeSchemaId)

Specified by:

getDerivedSchema in interface ReadOnlySchemaRepository

getDerivedSchemas

public Collection<DerivedSchemaEntry> getDerivedSchemas(String storeName)

Specified by:

getDerivedSchemas in interface ReadOnlySchemaRepository

getLatestDerivedSchema

public DerivedSchemaEntry getLatestDerivedSchema(String storeName,
 int valueSchemaId)

Description copied from interface: ReadOnlySchemaRepository

Get the most recent derived schema added to the given store and value schema id

Specified by:

getLatestDerivedSchema in interface ReadOnlySchemaRepository

getReplicationMetadataSchema

public RmdSchemaEntry getReplicationMetadataSchema(String storeName,
 int valueSchemaId,
 int replicationMetadataVersionId)

Specified by:

getReplicationMetadataSchema in interface ReadOnlySchemaRepository

getReplicationMetadataSchemas

public Collection<RmdSchemaEntry> getReplicationMetadataSchemas(String storeName)

Specified by:

getReplicationMetadataSchemas in interface ReadOnlySchemaRepository