Skip to content

CachedDS — Cached Delta State

CachedDS is used when StateCache is requested to cacheDS.

When created, CachedDS immediately initializes the cachedDs internal registry that requests the Dataset to generate a RDD[InternalRow] and associates the RDD with the given name:

The RDD is marked to be persisted using StorageLevel.MEMORY_AND_DISK_SER storage level.


CachedDS is an internal class of StateCache and has access to its internals.

Creating Instance

CachedDS takes the following to be created:

  • Dataset[A]
  • Name

CachedDS is created when StateCache is requested to cacheDS.

getDS Method

getDS: Dataset[A]


getDS is used when:

Back to top