io.confluent.kafka.schemaregistry.storage

Class SchemaValue

java.lang.Object

io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue

io.confluent.kafka.schemaregistry.storage.SubjectValue

io.confluent.kafka.schemaregistry.storage.SchemaValue

All Implemented Interfaces:

Comparable<SchemaValue>

public class SchemaValue
extends SubjectValue
implements Comparable<SchemaValue>

Field Summary

Fields

Modifier and Type	Field and Description
static String	ENCODED_PROPERTY

Fields inherited from class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue

offset, timestamp

Constructor Summary

Constructors

Constructor and Description
SchemaValue(Schema schemaEntity)
SchemaValue(Schema schemaEntity, RuleSetHandler ruleSetHandler)
SchemaValue(String subject, Integer version, Integer id, String schema, boolean deleted)
SchemaValue(String subject, Integer version, Integer id, String schemaType, List<SchemaReference> references, String schema, boolean deleted)
SchemaValue(String subject, Integer version, Integer id, String md5, String schemaType, List<SchemaReference> references, Metadata metadata, RuleSet ruleSet, String schema, boolean deleted)

Method Summary

Modifier and Type	Method and Description
int	compareTo(SchemaValue that)
boolean	equals(Object o)
Integer	getId()
String	getMd5()
byte[]	getMd5Bytes()
Metadata	getMetadata()
List<SchemaReference>	getReferences()
RuleSet	getRuleSet()
String	getSchema()
String	getSchemaType()
Integer	getVersion()
int	hashCode()
boolean	isDeleted()
void	setDeleted(boolean deleted)
void	setId(Integer id)
void	setMd5(String md5)
void	setMd5Bytes(byte[] bytes)
void	setMetadata(Metadata metadata)
void	setReferences(List<SchemaReference> references)
void	setRuleSet(RuleSet ruleSet)
void	setSchema(String schema)
void	setSchemaType(String schemaType)
void	setVersion(Integer version)
Schema	toHashKey()
SchemaKey	toKey()
Schema	toSchemaEntity()
String	toString()

Methods inherited from class io.confluent.kafka.schemaregistry.storage.SubjectValue

getSubject, setSubject

Methods inherited from class io.confluent.kafka.schemaregistry.storage.SchemaRegistryValue

getOffset, getTimestamp, setOffset, setTimestamp

Methods inherited from class java.lang.Object

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

Field Detail

ENCODED_PROPERTY

public static final String ENCODED_PROPERTY

See Also:

Constant Field Values

Constructor Detail

SchemaValue

public SchemaValue(String subject,
                   Integer version,
                   Integer id,
                   String schema,
                   boolean deleted)

SchemaValue

public SchemaValue(String subject,
                   Integer version,
                   Integer id,
                   String schemaType,
                   List<SchemaReference> references,
                   String schema,
                   boolean deleted)

SchemaValue

public SchemaValue(String subject,
                   Integer version,
                   Integer id,
                   String md5,
                   String schemaType,
                   List<SchemaReference> references,
                   Metadata metadata,
                   RuleSet ruleSet,
                   String schema,
                   boolean deleted)

SchemaValue

public SchemaValue(Schema schemaEntity)

SchemaValue

public SchemaValue(Schema schemaEntity,
                   RuleSetHandler ruleSetHandler)

Method Detail

getVersion

public Integer getVersion()

setVersion

public void setVersion(Integer version)

getId

public Integer getId()

setId

public void setId(Integer id)

getMd5

public String getMd5()

setMd5

public void setMd5(String md5)

getMd5Bytes

public byte[] getMd5Bytes()

setMd5Bytes

public void setMd5Bytes(byte[] bytes)

getSchemaType

public String getSchemaType()

setSchemaType

public void setSchemaType(String schemaType)

getReferences

public List<SchemaReference> getReferences()

setReferences

public void setReferences(List<SchemaReference> references)

getMetadata

public Metadata getMetadata()

setMetadata

public void setMetadata(Metadata metadata)

getRuleSet

public RuleSet getRuleSet()

setRuleSet

public void setRuleSet(RuleSet ruleSet)

getSchema

public String getSchema()

setSchema

public void setSchema(String schema)

isDeleted

public boolean isDeleted()

setDeleted

public void setDeleted(boolean deleted)

equals

public boolean equals(Object o)

Overrides:

equals in class SubjectValue

hashCode

public int hashCode()

Overrides:

hashCode in class SubjectValue

toString

public String toString()

Overrides:

toString in class Object

compareTo

public int compareTo(SchemaValue that)

Specified by:

compareTo in interface Comparable<SchemaValue>

toKey

public SchemaKey toKey()

Specified by:

toKey in class SubjectValue

toSchemaEntity

public Schema toSchemaEntity()

toHashKey

public Schema toHashKey()