Package com.linkedin.venice.schema.rmd

Class RmdSchemaEntry

java.lang.Object

com.linkedin.venice.schema.SchemaEntry

com.linkedin.venice.schema.GeneratedSchemaEntry

com.linkedin.venice.schema.rmd.RmdSchemaEntry

public class RmdSchemaEntry
extends GeneratedSchemaEntry

This holds the schema to perform conflict resolution on records when samza produces data in active active replication mode. More information can be found here RmdSchemaGenerator about the structure of the schema.

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
RmdSchemaEntry(int valueSchemaId, int protocolVersion, byte[] bytes)
RmdSchemaEntry(int valueSchemaId, int protocolVersion, String schemaStr)
RmdSchemaEntry(int valueSchemaId, int protocolVersion, org.apache.avro.Schema schema)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
int	hashCode()

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

getValueSchemaID, 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 Details

RmdSchemaEntry

public RmdSchemaEntry(int valueSchemaId,
 int protocolVersion,
 String schemaStr)

RmdSchemaEntry

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

RmdSchemaEntry

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

Method Details

equals

public boolean equals(Object obj)

Overrides:

equals in class GeneratedSchemaEntry

hashCode

public int hashCode()

Overrides:

hashCode in class GeneratedSchemaEntry