Packages

case class AvroEncoder(keySerializer: AvroSerializer, keyDeserializer: AvroDeserializer, valueSerializer: AvroSerializer, valueDeserializer: AvroDeserializer, suffixKeySerializer: Option[AvroSerializer] = None, suffixKeyDeserializer: Option[AvroDeserializer] = None) extends Serializable with Product

An Avro-based encoder used for serializing between UnsafeRow and Avro byte arrays in RocksDB state stores.

This encoder is primarily utilized by RocksDBStateStoreProvider and RocksDBStateEncoder to handle serialization and deserialization of state store data.

keySerializer

Serializer for converting state store keys to Avro format

keyDeserializer

Deserializer for converting Avro-encoded keys back to UnsafeRow

valueSerializer

Serializer for converting state store values to Avro format

valueDeserializer

Deserializer for converting Avro-encoded values back to UnsafeRow

suffixKeySerializer

Optional serializer for handling suffix keys in Avro format

suffixKeyDeserializer

Optional deserializer for converting Avro-encoded suffix keys back to UnsafeRow

Linear Supertypes
Product, Equals, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AvroEncoder
  2. Product
  3. Equals
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AvroEncoder(keySerializer: AvroSerializer, keyDeserializer: AvroDeserializer, valueSerializer: AvroSerializer, valueDeserializer: AvroDeserializer, suffixKeySerializer: Option[AvroSerializer] = None, suffixKeyDeserializer: Option[AvroDeserializer] = None)

    keySerializer

    Serializer for converting state store keys to Avro format

    keyDeserializer

    Deserializer for converting Avro-encoded keys back to UnsafeRow

    valueSerializer

    Serializer for converting state store values to Avro format

    valueDeserializer

    Deserializer for converting Avro-encoded values back to UnsafeRow

    suffixKeySerializer

    Optional serializer for handling suffix keys in Avro format

    suffixKeyDeserializer

    Optional deserializer for converting Avro-encoded suffix keys back to UnsafeRow

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  8. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  9. val keyDeserializer: AvroDeserializer
  10. val keySerializer: AvroSerializer
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  14. def productElementNames: Iterator[String]
    Definition Classes
    Product
  15. val suffixKeyDeserializer: Option[AvroDeserializer]
  16. val suffixKeySerializer: Option[AvroSerializer]
  17. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  18. val valueDeserializer: AvroDeserializer
  19. val valueSerializer: AvroSerializer
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from Product

Inherited from Equals

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped