Package com.tangosol.util

Class ConverterCollections.ConverterAsyncNamedCache<FK,TK,FV,TV>

java.lang.Object
com.tangosol.util.ConverterCollections.ConverterAsyncNamedCache<FK,TK,FV,TV>
All Implemented Interfaces:
AsyncNamedCache<TK,TV>, AsyncNamedMap<TK,TV>
Enclosing class:
ConverterCollections
public static class ConverterCollections.ConverterAsyncNamedCache<FK,TK,FV,TV> extends Object implements AsyncNamedCache<TK,TV>

  • Field Details

    • m_asyncNamedCache

      protected final AsyncNamedMap<FK,FV> m_asyncNamedCache
      The underlying AsyncNamedMap.

    • m_namedCache

      protected final ConverterCollections.ConverterNamedCache<FK,TK,FV,TV> m_namedCache
      A converter version of the underlying NamedCache.

    • m_convKeyUp

      protected final Converter<FK,TK> m_convKeyUp
      The Converter used to view keys stored in the Map.

    • m_convKeyDown

      protected final Converter<TK,FK> m_convKeyDown
      The Converter used to pass keys down to the Map.

    • m_convValUp

      protected final Converter<FV,TV> m_convValUp
      The Converter used to view values stored in the Map.

    • m_convValDown

      protected final Converter<TV,FV> m_convValDown
      The Converter used to pass keys down to the Map.

  • Constructor Details

    • ConverterAsyncNamedCache

      public ConverterAsyncNamedCache(AsyncNamedCache<FK,FV> cache, Converter<FK,TK> convKeyUp, Converter<TK,FK> convKeyDown, Converter<FV,TV> convValUp, Converter<TV,FV> convValDown)
      Constructor.
      Parameters:
      cache - the underlying AsyncNamedCache
      convKeyUp - the Converter to view the underlying AsyncNamedMap's keys through
      convKeyDown - the Converter to use to pass keys down to the underlying AsyncNamedMap
      convValUp - the Converter to view the underlying AsyncNamedMap's values through
      convValDown - the Converter to use to pass values down to the underlying AsyncNamedMap

  • Method Details

    • getNamedMap

      public NamedMap<TK,TV> getNamedMap()
      Description copied from interface: AsyncNamedMap
      Return the NamedCache instance this AsyncNamedCache is based on.
      Specified by:
      getNamedMap in interface AsyncNamedMap<FK,TK>
      Returns:
      the NamedCache instance this AsyncNamedCache is based on

    • getNamedCache

      public NamedCache<TK,TV> getNamedCache()
      Description copied from interface: AsyncNamedCache
      Return the NamedCache instance this AsyncNamedCache is based on.
      Specified by:
      getNamedCache in interface AsyncNamedCache<FK,TK>
      Returns:
      the NamedCache instance this AsyncNamedCache is based on

    • invoke

      public <R> CompletableFuture<R> invoke(TK key, InvocableMap.EntryProcessor<TK,TV,R> processor)
      Description copied from interface: AsyncNamedMap
      Invoke the passed EntryProcessor against the Entry specified by the passed key asynchronously, returning a CompletableFuture that can be used to obtain the result of the invocation.
      Specified by:
      invoke in interface AsyncNamedMap<FK,TK>
      Type Parameters:
      R - the type of value returned by the EntryProcessor
      Parameters:
      key - the key to process; it is not required to exist within the Map
      processor - the EntryProcessor to use to process the specified key
      Returns:
      a CompletableFuture that can be used to obtain the result of the invocation

    • invokeAll

      public <R> CompletableFuture<Map<TK,R>> invokeAll(Collection<? extends TK> collKeys, InvocableMap.EntryProcessor<TK,TV,R> processor)
      Description copied from interface: AsyncNamedMap
      Invoke the passed EntryProcessor against the entries specified by the passed keys asynchronously, returning a CompletableFuture that can be used to obtain the result of the invocation for each entry.
      Specified by:
      invokeAll in interface AsyncNamedMap<FK,TK>
      Type Parameters:
      R - the type of value returned by the EntryProcessor
      Parameters:
      collKeys - the keys to process; these keys are not required to exist within the Map
      processor - the EntryProcessor to use to process the specified keys
      Returns:
      a CompletableFuture that can be used to obtain the result of the invocation for each entry

    • invokeAll

      public <R> CompletableFuture<Map<TK,R>> invokeAll(Filter<?> filter, InvocableMap.EntryProcessor<TK,TV,R> processor)
      Description copied from interface: AsyncNamedMap
      Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a CompletableFuture that can be used to obtain the result of the invocation for each entry.
      Specified by:
      invokeAll in interface AsyncNamedMap<FK,TK>
      Type Parameters:
      R - the type of value returned by the EntryProcessor
      Parameters:
      filter - a Filter that results in the set of keys to be processed
      processor - the EntryProcessor to use to process the specified keys
      Returns:
      a CompletableFuture that can be used to obtain the result of the invocation for each entry

    • invokeAll

      public <R> CompletableFuture<Void> invokeAll(Collection<? extends TK> collKeys, InvocableMap.EntryProcessor<TK,TV,R> processor, Consumer<? super Map.Entry<? extends TK,? extends R>> callback)
      Description copied from interface: AsyncNamedMap
      Invoke the passed EntryProcessor against the entries specified by the passed keys asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.

      Instead of collecting and returning the complete result, this method will stream partial results of the processor execution to the specified partial result callback, which allows for a much lower memory overhead.

      Note: the callback implementation must be thread-safe as it may be called by multiple worker threads in cases where Coherence splits the operation over multiple partitions.

      Specified by:
      invokeAll in interface AsyncNamedMap<FK,TK>
      Type Parameters:
      R - the type of value returned by the EntryProcessor
      Parameters:
      collKeys - the keys to process; these keys are not required to exist within the Map
      processor - the EntryProcessor to use to process the specified keys
      callback - a user-defined callback that will be called for each partial result
      Returns:
      a CompletableFuture that can be used to determine if the operation completed successfully

    • invokeAll

      public <R> CompletableFuture<Void> invokeAll(Filter<?> filter, InvocableMap.EntryProcessor<TK,TV,R> processor, Consumer<? super Map.Entry<? extends TK,? extends R>> callback)
      Description copied from interface: AsyncNamedMap
      Invoke the passed EntryProcessor against the set of entries that are selected by the given Filter asynchronously, returning a CompletableFuture that can be used to determine if the operation completed successfully.

      Instead of collecting and returning the complete result, this method will stream partial results of the processor execution to the specified partial result callback, which allows for a much lower memory overhead.

      Note: the callback implementation must be thread-safe as it may be called by multiple worker threads in cases where Coherence splits the operation over multiple partitions.

      Specified by:
      invokeAll in interface AsyncNamedMap<FK,TK>
      Type Parameters:
      R - the type of value returned by the EntryProcessor
      Parameters:
      filter - a Filter that results in the set of keys to be processed
      processor - the EntryProcessor to use to process the specified keys
      callback - a user-defined callback that will be called for each partial result
      Returns:
      a CompletableFuture that can be used to determine if the operation completed successfully

    • aggregate

      public <R> CompletableFuture<R> aggregate(Collection<? extends TK> collKeys, InvocableMap.EntryAggregator<? super TK,? super TV,R> aggregator)
      Description copied from interface: AsyncNamedMap
      Perform an aggregating operation asynchronously against the entries specified by the passed keys.
      Specified by:
      aggregate in interface AsyncNamedMap<FK,TK>
      Type Parameters:
      R - the type of value returned by the EntryAggregator
      Parameters:
      collKeys - the Collection of keys that specify the entries within this Map to aggregate across
      aggregator - the EntryAggregator that is used to aggregate across the specified entries of this Map
      Returns:
      a CompletableFuture that can be used to obtain the result of the aggregation

    • aggregate

      public <R> CompletableFuture<R> aggregate(Filter<?> filter, InvocableMap.EntryAggregator<? super TK,? super TV,R> aggregator)
      Description copied from interface: AsyncNamedMap
      Perform an aggregating operation asynchronously against the set of entries that are selected by the given Filter.
      Specified by:
      aggregate in interface AsyncNamedMap<FK,TK>
      Type Parameters:
      R - the type of value returned by the EntryAggregator
      Parameters:
      filter - the Filter that is used to select entries within this Map to aggregate across
      aggregator - the EntryAggregator that is used to aggregate across the selected entries of this Map
      Returns:
      a CompletableFuture that can be used to obtain the result of the aggregation

    • instantiateMap

      protected <R> Map<TK,R> instantiateMap(Map<FK,R> mapResult)

    • instantiateCallback

      protected <R> Consumer<? extends Map.Entry<FK,R>> instantiateCallback(Consumer<? super Map.Entry<? extends TK,? extends R>> callback)