object TransformWithStateKeyValueRowSchemaUtils
Helper object for getting schema of key/value row that are used in state schema
files and to be passed into RocksDBStateKey(/Value)Encoder.
- Alphabetic
- By Inheritance
- TransformWithStateKeyValueRowSchemaUtils
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- 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
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getCompositeKeySchema(groupingKeySchema: StructType, userKeySchema: StructType): StructType
Creates a schema that is the concatenation of the grouping key and a user-defined key.
Creates a schema that is the concatenation of the grouping key and a user-defined key. This is used by MapState to create a composite key that is then treated as an "elementKey" by OneToOneTTLState.
- def getExpirationMsRowSchema(): StructType
Represents the schema of a single long value, which is used to store the expiration timestamp of elements in the minimum index, managed by OneToManyTTLState.
- def getTTLRowKeySchema(keySchema: StructType): StructType
Represents the schema of keys in the TTL index, managed by TTLState implementations.
Represents the schema of keys in the TTL index, managed by TTLState implementations. There is no value associated with entries in the TTL index, so there is no method called, for example, getTTLValueSchema.
- def getValueSchemaWithTTL(schema: StructType, hasTTL: Boolean): StructType
Represents the schema of an element with TTL in the primary index.
Represents the schema of an element with TTL in the primary index. We store the expiration of each value along with the value itself, since each value has its own TTL. It is used as the value schema of every value, for every stateful variable.
- def hashCode(): Int
- 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()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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)