Package com.linkedin.venice.client.schema

Class RouterBackedSchemaReader

java.lang.Object

com.linkedin.venice.client.schema.RouterBackedSchemaReader

All Implemented Interfaces:

SchemaReader, Closeable, AutoCloseable

public class RouterBackedSchemaReader
extends Object
implements SchemaReader

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE_ALL_VALUE_SCHEMA_IDS
static final String	TYPE_KEY_SCHEMA
static final String	TYPE_UPDATE_SCHEMA
static final String	TYPE_VALUE_SCHEMA

Constructor Summary

Constructors

Constructor	Description
RouterBackedSchemaReader(InternalAvroStoreClient storeClient, Optional<org.apache.avro.Schema> readerSchema, Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter, Duration valueSchemaRefreshPeriod, ICProvider icProvider)
RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier, Optional<org.apache.avro.Schema> readerSchema, Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter)
RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier, Optional<org.apache.avro.Schema> readerSchema, Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter, ICProvider icProvider)
RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier, Optional<org.apache.avro.Schema> readerSchema, Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter, Duration valueSchemaRefreshPeriod)
RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier, Optional<org.apache.avro.Schema> readerSchema, Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter, Duration valueSchemaRefreshPeriod, ICProvider icProvider)

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.
Integer	getLatestValueSchemaId(boolean forceRefresh)
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

Field Details

TYPE_KEY_SCHEMA

public static final String TYPE_KEY_SCHEMA

See Also:

• Constant Field Values

TYPE_VALUE_SCHEMA

public static final String TYPE_VALUE_SCHEMA

See Also:

• Constant Field Values

TYPE_ALL_VALUE_SCHEMA_IDS

public static final String TYPE_ALL_VALUE_SCHEMA_IDS

See Also:

• Constant Field Values

TYPE_UPDATE_SCHEMA

public static final String TYPE_UPDATE_SCHEMA

See Also:

• Constant Field Values

Constructor Details

RouterBackedSchemaReader

public RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier,
 Optional<org.apache.avro.Schema> readerSchema,
 Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter)

RouterBackedSchemaReader

public RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier,
 Optional<org.apache.avro.Schema> readerSchema,
 Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter,
 ICProvider icProvider)

RouterBackedSchemaReader

public RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier,
 Optional<org.apache.avro.Schema> readerSchema,
 Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter,
 Duration valueSchemaRefreshPeriod)

RouterBackedSchemaReader

public RouterBackedSchemaReader(Supplier<InternalAvroStoreClient> clientSupplier,
 Optional<org.apache.avro.Schema> readerSchema,
 Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter,
 Duration valueSchemaRefreshPeriod,
 ICProvider icProvider)

RouterBackedSchemaReader

public RouterBackedSchemaReader(InternalAvroStoreClient storeClient,
 Optional<org.apache.avro.Schema> readerSchema,
 Optional<Predicate<org.apache.avro.Schema>> preferredSchemaFilter,
 Duration valueSchemaRefreshPeriod,
 ICProvider icProvider)

Method Details

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

getLatestValueSchema

public org.apache.avro.Schema getLatestValueSchema()
                                            throws VeniceClientException

Specified by:

getLatestValueSchema in interface SchemaReader

Throws:

VeniceClientException

getLatestValueSchemaId

public Integer getLatestValueSchemaId(boolean forceRefresh)
                               throws VeniceClientException

Specified by:

getLatestValueSchemaId in interface SchemaReader

Throws:

VeniceClientException

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

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

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

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException