Packages

package avro

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class AvroCodec[T <: SpecificRecordBase] extends Codec[T]
  2. case class AvroInlet[T <: SpecificRecordBase](name: String, hasUniqueGroupId: Boolean = false, errorHandler: (Array[Byte], Throwable) ⇒ Option[T] = ...)(implicit evidence$1: ClassTag[T]) extends CodecInlet[T] with Product with Serializable
  3. case class AvroOutlet[T <: SpecificRecordBase](name: String, partitioner: (T) ⇒ String = RoundRobinPartitioner)(implicit evidence$1: ClassTag[T]) extends CodecOutlet[T] with Product with Serializable

Value Members

  1. object AvroInlet extends Serializable
  2. object AvroOutlet extends Serializable
  3. object AvroUtil

Ungrouped