package avro
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- case class EncodedKV(key: String, value: Array[Byte]) extends Product with Serializable
- case class SparkAvroDecoder[T](avroSchema: String)(implicit evidence$1: Encoder[T], evidence$2: scala.reflect.api.JavaUniverse.TypeTag[T]) extends Product with Serializable
-
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
- object AvroConverter
-
object
SchemaConverters
This object contains method that are used to convert sparkSQL schemas to avro schemas and vice versa.