Packages

package schema

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. trait AvroSchemaEvolution extends AnyRef
  2. class AvroSchemaEvolutionException extends RuntimeException
  3. trait DatumReaderWriterMixin extends AnyRef

    Mixin for DatumReader and DatumWriter.

    Mixin for DatumReader and DatumWriter. It collects factory methods for Datums.

  4. class DefaultAvroSchemaEvolution extends AvroSchemaEvolution with DatumReaderWriterMixin with RecordDeserializer

    It's base implementation of AvroSchemaEvolution.

    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.

  5. trait RecordDeserializer extends AnyRef
  6. trait StringForcingDatumReader[T] extends GenericDatumReader[T]
  7. class StringForcingDatumReaderProvider[T] extends AnyRef

    object StringForcingDatumReader doesn't cooperate with Java well

Value Members

  1. object AvroStringSettings extends LazyLogging
  2. object StringForcingDatumReaderProvider

Ungrouped