Class TxDistributedCacheStream<Original,​R,​K,​V>

  • Type Parameters:
    Original - original stream type
    R - the type of stream
    K - the type of context entry key
    V - the type of context entry value
    All Implemented Interfaces:
    AutoCloseable, BaseStream<R,​Stream<R>>, Stream<R>, BaseCacheStream<R,​Stream<R>>, CacheStream<R>

    public class TxDistributedCacheStream<Original,​R,​K,​V>
    extends DistributedCacheStream<Original,​R>
    A distributed cache stream that also utilizes transactional awareness. Basically this adds functionality to take items from the local tx context and add them to the local stream that is produced to enable our stream to operate upon entries in the context that don't map to our segments that are normally ignored in a distributed stream.