Packages

package avro

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class EncodedKV(key: String, value: Array[Byte]) extends Product with Serializable
  2. case class SparkAvroDecoder[T](avroSchema: String)(implicit evidence$1: Encoder[T], evidence$2: scala.reflect.api.JavaUniverse.TypeTag[T]) extends Product with Serializable
  3. case class SparkAvroEncoder[T](avroSchema: String)(implicit evidence$3: Encoder[T], evidence$4: scala.reflect.api.JavaUniverse.TypeTag[T]) extends Product with Serializable

    Instances of this class are used to translate a Dataset[T] into a Byte Array using an AVRO schema in its String JSON representation for the type T being encoded.

    Instances of this class are used to translate a Dataset[T] into a Byte Array using an AVRO schema in its String JSON representation for the type T being encoded. The type T must have a matching implicit Spark Encoder in scope. Note that most supported Encoders can be imported from cloudflow.spark.sql.SQLImplicits

Value Members

  1. object AvroConverter
  2. object SchemaConverters

    This object contains method that are used to convert sparkSQL schemas to avro schemas and vice versa.

Ungrouped