class DefaultAvroSchemaEvolution extends AvroSchemaEvolution with DatumReaderWriterMixin
It's base implementation of AvroSchemaEvolution. In this case strategy to evolve record to schema is as follows:
serialize record to record schema -> deserialize record to provided schema (final schema)
This strategy is based on Confluent implementation of: serialization and deserialization method. But we don't allocate bytes for MagicByte and Id, because we don't need it.
For now it's easiest way to convert GenericContainer record to wanted schema.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DefaultAvroSchemaEvolution
- DatumReaderWriterMixin
- AvroSchemaEvolution
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new DefaultAvroSchemaEvolution()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def alignRecordToSchema(record: GenericContainer, schema: Schema): GenericContainer
- Definition Classes
- DefaultAvroSchemaEvolution → AvroSchemaEvolution
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def canBeEvolved(record: GenericContainer, schema: Schema): Boolean
- Definition Classes
- DefaultAvroSchemaEvolution → AvroSchemaEvolution
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def createDatumReader(writerSchema: Schema, readerSchema: Schema): DatumReader[AnyRef]
- Definition Classes
- DatumReaderWriterMixin
- def createDatumWriter(schema: Schema): GenericDatumWriter[Any]
- Definition Classes
- DatumReaderWriterMixin
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)