Package com.linkedin.venice.schema.writecompute

Class DerivedSchemaEntry

java.lang.Object

com.linkedin.venice.schema.SchemaEntry

com.linkedin.venice.schema.GeneratedSchemaEntry

com.linkedin.venice.schema.writecompute.DerivedSchemaEntry

public class DerivedSchemaEntry
extends GeneratedSchemaEntry

Derived schemas are designed for write compute operations. The schema contains available operations that SN could apply on top of the record. Derived schemas can be generated automatically from value schemas and each value schema can have multiple derived schemas.Check out WriteComputeSchemaConverter for all available operations and how it gets generated.

Field Summary

Fields inherited from class com.linkedin.venice.schema.GeneratedSchemaEntry

valueSchemaID

Fields inherited from class com.linkedin.venice.schema.SchemaEntry

DEFAULT_SCHEMA_CREATION_COMPATIBILITY_TYPE

Constructor Summary

Constructors

Constructor	Description
DerivedSchemaEntry(int valueSchemaId, int protocolVersion, byte[] bytes)
DerivedSchemaEntry(int valueSchemaId, int protocolVersion, java.lang.String schemaStr)
DerivedSchemaEntry(int valueSchemaId, int protocolVersion, org.apache.avro.Schema schema)

Method Summary

Methods inherited from class com.linkedin.venice.schema.GeneratedSchemaEntry

equals, getValueSchemaID, hashCode, toString

Methods inherited from class com.linkedin.venice.schema.SchemaEntry

clone, getCanonicalSchemaStr, getId, getSchema, getSchemaBytes, getSchemaStr, isNewSchemaCompatible, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

DerivedSchemaEntry

public DerivedSchemaEntry(int valueSchemaId,
                          int protocolVersion,
                          java.lang.String schemaStr)

DerivedSchemaEntry

public DerivedSchemaEntry(int valueSchemaId,
                          int protocolVersion,
                          org.apache.avro.Schema schema)

DerivedSchemaEntry

public DerivedSchemaEntry(int valueSchemaId,
                          int protocolVersion,
                          byte[] bytes)