Package io.confluent.kafka.serializers

Class GenericContainerWithVersion

java.lang.Object

io.confluent.kafka.serializers.GenericContainerWithVersion

All Implemented Interfaces:

ParsedSchemaAndValue

public class GenericContainerWithVersion
extends Object
implements ParsedSchemaAndValue

Wrapper for GenericContainer along with a version number, which may be null.

The version is typically the version of the Avro schema of the GenericContainer in the context of a subject. The version is used to set the version on the Connect Schema that is derived from the Avro schema, but only if the Avro schema does not have a property named "connect.version", which takes precedence over the version here.

Nested Class Summary

Nested classes/interfaces inherited from interface io.confluent.kafka.schemaregistry.ParsedSchemaAndValue

ParsedSchemaAndValue.SchemaInfo

Constructor Summary

Constructors

Constructor	Description
GenericContainerWithVersion(AvroSchema schema, org.apache.avro.generic.GenericContainer container, Integer version)
GenericContainerWithVersion(AvroSchema schema, org.apache.avro.generic.GenericContainer container, Integer version, ParsedSchemaAndValue.SchemaInfo writerSchemaInfo, AvroSchema writerSchema, List<RuleResult> ruleResults)
GenericContainerWithVersion(org.apache.avro.generic.GenericContainer container, Integer version)

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericContainer	container()
boolean	equals(Object o)
List<RuleResult>	getRuleResults()
ParsedSchema	getSchema()
Object	getValue()
ParsedSchema	getWriterSchema()
ParsedSchemaAndValue.SchemaInfo	getWriterSchemaInfo()
int	hashCode()
Integer	version()

Methods inherited from class java.lang.Object

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

Constructor Details

GenericContainerWithVersion

public GenericContainerWithVersion(org.apache.avro.generic.GenericContainer container,
 Integer version)

GenericContainerWithVersion

public GenericContainerWithVersion(AvroSchema schema,
 org.apache.avro.generic.GenericContainer container,
 Integer version)

GenericContainerWithVersion

public GenericContainerWithVersion(AvroSchema schema,
 org.apache.avro.generic.GenericContainer container,
 Integer version,
 ParsedSchemaAndValue.SchemaInfo writerSchemaInfo,
 AvroSchema writerSchema,
 List<RuleResult> ruleResults)

Method Details

getSchema

public ParsedSchema getSchema()

Specified by:

getSchema in interface ParsedSchemaAndValue

getValue

public Object getValue()

Specified by:

getValue in interface ParsedSchemaAndValue

getWriterSchemaInfo

public ParsedSchemaAndValue.SchemaInfo getWriterSchemaInfo()

Specified by:

getWriterSchemaInfo in interface ParsedSchemaAndValue

getWriterSchema

public ParsedSchema getWriterSchema()

Specified by:

getWriterSchema in interface ParsedSchemaAndValue

getRuleResults

public List<RuleResult> getRuleResults()

Specified by:

getRuleResults in interface ParsedSchemaAndValue

container

public org.apache.avro.generic.GenericContainer container()

version

public Integer version()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object