Packages

package schema

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

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

    Mixin for DatumReader and DatumWriter.

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

  5. class DefaultAvroSchemaEvolution extends AvroSchemaEvolution with DatumReaderWriterMixin

    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.

  6. trait SchemaValidator extends Serializable
  7. trait StringForcingDatumReader[T] extends GenericDatumReader[T]
  8. class StringForcingDatumReaderProvider[T] extends AnyRef

    object StringForcingDatumReader doesn't cooperate with Java well

Value Members

  1. object AvroSchemaBasedParameter
  2. object AvroSchemaValidator extends SchemaValidator
  3. object AvroSinkSingleValueParameter
  4. object StringForcingDatumReaderProvider

Ungrouped