abstract class StatefulDeltaSet[K, V, StateKey, StateValue] extends DeltaSetImpl[K, V]
Results of a stateful DeltaSet are produced from upstream DeltaSets and from a state stored in the previous, reference run, here fetched and used as additional input. At the same time, the new state is calculated and persisted for the next run.
- K
The type of the keys of the DeltaSet.
- V
The type of the values of the DeltaSet. Instance bound types are supported and their use encouraged.
- StateKey
The type of the keys of the state.
- StateValue
The type of the values of the state.
- Alphabetic
- By Inheritance
- StatefulDeltaSet
- DeltaSetImpl
- DeltaSet
- BaseSetImpl
- BaseSet
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new StatefulDeltaSet()(implicit arg0: ClassTag[K], arg1: ClassTag[V], arg2: Ordering[StateKey], arg3: ClassTag[StateKey], arg4: ClassTag[StateValue])
Type Members
Abstract Value Members
- abstract val computeChangedKeyValuesWithState: Determine[(Changes[K, V], State)]
- Attributes
- protected
- abstract val computeChangedKeyValuesWithoutState: Determine[Changes[K, V]]
- Attributes
- protected
- abstract def keyValuesWithState(keys: Keys[K]): KeyValues[K, V]
- Attributes
- protected
- abstract val keyValuesWithState: (KeyValues[K, V], State)
- Attributes
- protected
- abstract def keyValuesWithoutState(keys: Keys[K]): KeyValues[K, V]
- Attributes
- protected
- abstract val keyValuesWithoutState: KeyValues[K, V]
- Attributes
- protected
- abstract def metadata: Metadata
The identification and configuration of the BaseSet
The identification and configuration of the BaseSet
- Definition Classes
- BaseSetImpl
- abstract val partitioner: Partitioner[K]
The partitioner for the DeltaSet.
The partitioner for the DeltaSet.
- Definition Classes
- DeltaSet
- abstract val stateManager: StateManager
Manages the state partitions.
Manages the state partitions.
- Attributes
- protected
- abstract val statePartitioner: Partitioner[StateKey]
The partitioner for state entries.
- abstract def upstreams: Iterable[BaseSet]
BaseSets used to compute this BaseSet
BaseSets used to compute this BaseSet
- Definition Classes
- BaseSet
- abstract def withMetadata(metadata: Metadata): BaseSetType
Returns a copy of the BaseSet with new metadata.
Returns a copy of the BaseSet with new metadata.
- Definition Classes
- BaseSetImpl
Concrete 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
- final def changedKeyValues: Determine[Changes[K, V]]
Returns the changed key-value pairs in the DeltaSet.
Returns the changed key-value pairs in the DeltaSet.
The implementation of the DeltaSet can persist the result of this function, but this behavior not guaranteed. When you use the data multiple times, make sure to persist the result.
- Definition Classes
- DeltaSetImpl → DeltaSet
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final lazy val computeChangedKeyValues: Determine[Changes[K, V]]
Returns the changed key-value pairs in the DeltaSet.
Returns the changed key-value pairs in the DeltaSet.
- Definition Classes
- StatefulDeltaSet → DeltaSetImpl
- def config: DeltaSetConfig
The effective configuration of this BaseSet, taking into account all configuration files and programmatic overrides.
The effective configuration of this BaseSet, taking into account all configuration files and programmatic overrides.
- Definition Classes
- BaseSetImpl → BaseSet
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def fqn: FQN
The fully qualified name of the BaseSet, which consists of its BaseSet.Namespace and its BaseSet.Id.
The fully qualified name of the BaseSet, which consists of its BaseSet.Namespace and its BaseSet.Id.
- Definition Classes
- BaseSetImpl → BaseSet
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def id: Id
The ID of the BaseSet, that identifies it in configuration files and logs, and for storing metadata in the output catalog.
The ID of the BaseSet, that identifies it in configuration files and logs, and for storing metadata in the output catalog. By default, the ID is automatically assigned.
- Definition Classes
- BaseSetImpl → BaseSet
- def inScope: Option[(K) => Boolean]
Defines that the DeltaSet is a scoped view on an underlying collection, for example a set of catalog layers.
Defines that the DeltaSet is a scoped view on an underlying collection, for example a set of catalog layers. Returns true if a given key is in the scope of the view.
If a key is in the scope of the view, but not contained in the DeltaSet, then it does not exist in the underlying collection. All keys in the DeltaSet must be in the scope of the view.
- Definition Classes
- DeltaSetImpl → DeltaSet
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def keyValues(keys: Keys[K]): KeyValues[K, V]
Returns all key-value pairs in the DeltaSet.
Returns all key-value pairs in the DeltaSet.
The implementation of the DeltaSet can persist this value, but this behavior not guaranteed. When you use the data multiple times, make sure to persist the result.
- Definition Classes
- StatefulDeltaSet → DeltaSet
- final lazy val keyValues: KeyValues[K, V]
Returns all key-value pairs in the DeltaSet.
Returns all key-value pairs in the DeltaSet.
- Definition Classes
- StatefulDeltaSet → DeltaSet
- def namespace: Namespace
The BaseSet.Namespace of the BaseSet.
The BaseSet.Namespace of the BaseSet.
- Definition Classes
- BaseSetImpl → BaseSet
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final lazy val newState: State
Accessed by the framework to obtain the new state.
Accessed by the framework to obtain the new state. This will either try to compute the state incrementally, or otherwise derive the complete state non-incrementally
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- lazy val previousState: Determine[KeyValues[StateKey, StateValue]]
- Attributes
- protected
- val stateKeyClassTag: ClassTag[StateKey]
ClassTag of the keys in the state.
ClassTag of the keys in the state. Required for serialization.
- val stateKeyOrdering: Ordering[StateKey]
Ordering of the keys in the state.
Ordering of the keys in the state. Required for serialization.
- val stateValueClassTag: ClassTag[StateValue]
ClassTag of the values in the state.
ClassTag of the values in the state. Required for serialization.
- 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)