package caching
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
class
CachingMappingRetriever[T <: AnyRef] extends Serializable with ContextLogging
A wrapper for the Retriever class, that applies a mapping function on the retrieved payloads and caches the resulting values.
A wrapper for the Retriever class, that applies a mapping function on the retrieved payloads and caches the resulting values.
- T
The type of the decoded payload, after applying the mapping function.
- Note
A CachingMappingRetriever can be only created from the Spark driver. If a CachingMappingRetriever is created from inside a Spark worker node, an exception is thrown.
-
class
CachingRetriever extends Retriever
Wraps a retriever and caches the payloads.
Wraps a retriever and caches the payloads.
- Note
Payloads retrieved as stream are not cached. Moreover statistics when retrieving as stream are updated only in case the stream is closed.
Value Members
- object CachingMappingRetriever extends Serializable
- object CachingRetriever extends Serializable