case class StateSchemaIdRow(schemaId: Short, bytes: Array[Byte]) extends Product with Serializable
Represents a row of state data along with its schema version. Used during state storage operations to track which schema version was used to encode the data, enabling proper decoding even when schemas have evolved.
- schemaId
The version identifier for the schema that was used to encode this row. This could be either a key schema ID or value schema ID depending on context.
- bytes
The actual encoded data bytes for this row. When using Avro encoding, these bytes contain the Avro-serialized data. For UnsafeRow encoding, these contain the binary-encoded row data.
- Alphabetic
- By Inheritance
- StateSchemaIdRow
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new StateSchemaIdRow(schemaId: Short, bytes: Array[Byte])
- schemaId
The version identifier for the schema that was used to encode this row. This could be either a key schema ID or value schema ID depending on context.
- bytes
The actual encoded data bytes for this row. When using Avro encoding, these bytes contain the Avro-serialized data. For UnsafeRow encoding, these contain the binary-encoded row data.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val bytes: Array[Byte]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val schemaId: Short
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)