StateStore

abstract def abort(): Unit

Abort all the updates that have been made to the store.

abstract def commit(): Long

Commit all the updates that have been made to the store, and return the new version.

abstract def get(key: UnsafeRow): Option[UnsafeRow]

Get the current value of a key.

abstract def id: StateStoreId

Unique identifier of the store

abstract def iterator(): Iterator[(UnsafeRow, UnsafeRow)]

Iterator of store data after a set of updates have been committed.

abstract def numKeys(): Long

Number of keys in the state store

abstract def put(key: UnsafeRow, value: UnsafeRow): Unit

Put a new value for a key.

abstract def remove(condition: (UnsafeRow) ⇒ Boolean): Unit

Remove keys that match the following condition.

abstract def updates(): Iterator[StoreUpdate]

Iterator of the updates that have been committed.

abstract def version: Long

Version of the data in this store before committing updates.

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit