Uses of Interface
com.tangosol.util.stream.RemoteCollector

Packages that use RemoteCollector

Package	Description
com.oracle.coherence.repository	Contains classes to enable Repository-like access to Coherence data.
com.tangosol.util.stream	Contains classes to support functional-style operations on remote streams of elements, such as map-reduce transformations on collections.

Uses of RemoteCollector in com.oracle.coherence.repository

Methods in com.oracle.coherence.repository with parameters of type RemoteCollector

Modifier and Type	Method	Description
<K, A, R, M extends Map<K,R>> CompletableFuture<M>	AbstractAsyncRepository.groupBy(Filter<?> filter, ValueExtractor<? super T, ? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.
<K,A,R> CompletableFuture<Map<K,R>>	AbstractAsyncRepository.groupBy(Filter<?> filter, ValueExtractor<? super T, ? extends K> extractor, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.
<K, A, R, M extends Map<K,R>> CompletableFuture<M>	AbstractAsyncRepository.groupBy(ValueExtractor<? super T, ? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.
<K,A,R> CompletableFuture<Map<K,R>>	AbstractAsyncRepository.groupBy(ValueExtractor<? super T, ? extends K> extractor, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.
<K, A, R, M extends Map<K,R>> M	AbstractRepository.groupBy(Filter<?> filter, ValueExtractor<? super T, ? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.
<K,A,R> Map<K,R>	AbstractRepository.groupBy(Filter<?> filter, ValueExtractor<? super T, ? extends K> extractor, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.
<K, A, R, M extends Map<K,R>> M	AbstractRepository.groupBy(ValueExtractor<? super T, ? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.
<K,A,R> Map<K,R>	AbstractRepository.groupBy(ValueExtractor<? super T, ? extends K> extractor, RemoteCollector<? super T, A, R> collector)	Return the grouping of entities by the specified extractor.

Uses of RemoteCollector in com.tangosol.util.stream

Methods in com.tangosol.util.stream that return RemoteCollector

Modifier and Type	Method	Description
static <T,U> RemoteCollector<T,?,Double>	RemoteCollectors.averagingDouble(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector that produces the arithmetic mean of a double-valued function applied to the input elements.
static <T,U> RemoteCollector<T,?,Double>	RemoteCollectors.averagingInt(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector that produces the arithmetic mean of an integer-valued function applied to the input elements.
static <T,U> RemoteCollector<T,?,Double>	RemoteCollectors.averagingLong(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector that produces the arithmetic mean of a long-valued function applied to the input elements.
static <T,A,R,RR> RemoteCollector<T,A,RR>	RemoteCollectors.collectingAndThen(RemoteCollector<T,A,R> downstream, Remote.Function<R,RR> finisher)	Adapts a Collector to perform an additional finishing transformation.
static <T> RemoteCollector<T,?,Long>	RemoteCollectors.counting()	Returns a Collector accepting elements of type T that counts the number of input elements.
static <T,U,K> RemoteCollector<T, ?, Map<K,List<T>>>	RemoteCollectors.groupingBy(ValueExtractor<? super U, ? extends K> classifier)	Returns a Collector implementing a "group by" operation on input elements of type T, grouping elements according to a classification function, and returning the results in a Map.
static <T, U, K, D, A, M extends Map<K,D>> RemoteCollector<T,?,M>	RemoteCollectors.groupingBy(ValueExtractor<? super U, ? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T, A, D> downstream)	Returns a Collector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream Collector.
static <T,U,K,A,D> RemoteCollector<T,?,Map<K,D>>	RemoteCollectors.groupingBy(ValueExtractor<? super U, ? extends K> classifier, RemoteCollector<? super T, A, D> downstream)	Returns a Collector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream Collector.
static <T,U,A,R> RemoteCollector<T,A,R>	RemoteCollectors.mapping(Remote.Function<? super T, ? extends U> mapper, RemoteCollector<? super U, A, R> downstream)	Adapts a Collector accepting elements of type U to one accepting elements of type T by applying a mapping function to each input element before accumulation.
static <T> RemoteCollector<T, ?, Optional<T>>	RemoteCollectors.maxBy(Remote.Comparator<? super T> comparator)	Returns a Collector that produces the maximal element according to a given Comparator, described as an Optional<T>.
static <T, E extends Comparable<? super E>> RemoteCollector<T, ?, Optional<T>>	RemoteCollectors.maxBy(ValueExtractor<? super T, ? extends E> comparable)	Returns a Collector that produces the maximal element according to a given Comparable attribute, described as an Optional<T>.
static <T> RemoteCollector<T, ?, Optional<T>>	RemoteCollectors.minBy(Remote.Comparator<? super T> comparator)	Returns a Collector that produces the minimal element according to a given Comparator, described as an Optional<T>.
static <T, E extends Comparable<? super E>> RemoteCollector<T, ?, Optional<T>>	RemoteCollectors.minBy(ValueExtractor<? super T, ? extends E> comparable)	Returns a Collector that produces the minimal element according to a given Comparable attribute, described as an Optional<T>.
static <T,A,R> RemoteCollector<T,A,R>	RemoteCollector.of(Remote.Supplier<A> supplier, Remote.BiConsumer<A,T> accumulator, Remote.BinaryOperator<A> combiner, Remote.Function<A,R> finisher, Collector.Characteristics... characteristics)	Returns a new Collector described by the given supplier, accumulator, combiner, and finisher functions.
static <T,R> RemoteCollector<T,R,R>	RemoteCollector.of(Remote.Supplier<R> supplier, Remote.BiConsumer<R,T> accumulator, Remote.BinaryOperator<R> combiner, Collector.Characteristics... characteristics)	Returns a new Collector described by the given supplier, accumulator, and combiner functions.
static <T,A,R> RemoteCollector<T,A,R>	RemoteCollector.of(Supplier<A> supplier, BiConsumer<A,T> accumulator, BinaryOperator<A> combiner, Function<A,R> finisher, Collector.Characteristics... characteristics)	Returns a new Collector described by the given supplier, accumulator, combiner, and finisher functions.
static <T,R> RemoteCollector<T,R,R>	RemoteCollector.of(Supplier<R> supplier, BiConsumer<R,T> accumulator, BinaryOperator<R> combiner, Collector.Characteristics... characteristics)	Returns a new Collector described by the given supplier, accumulator, and combiner functions.
static <T> RemoteCollector<T, ?, Optional<T>>	RemoteCollectors.reducing(Remote.BinaryOperator<T> op)	Returns a Collector which performs a reduction of its input elements under a specified BinaryOperator.
static <T> RemoteCollector<T, SimpleHolder<T>, T>	RemoteCollectors.reducing(T identity, Remote.BinaryOperator<T> op)	Returns a Collector which performs a reduction of its input elements under a specified BinaryOperator using the provided identity.
static <T,U> RemoteCollector<T,?,U>	RemoteCollectors.reducing(U identity, Remote.BiFunction<? super U, ? super T, ? extends U> mapper, Remote.BinaryOperator<U> op)	Returns a Collector which performs a reduction of its input elements under a specified mapping function and BinaryOperator.
static <T,U> RemoteCollector<T,?,U>	RemoteCollectors.reducing(U identity, Remote.Function<? super T, ? extends U> mapper, Remote.BinaryOperator<U> op)	Returns a Collector which performs a reduction of its input elements under a specified mapping function and BinaryOperator.
static <T,U> RemoteCollector<T, ?, com.tangosol.internal.util.DoubleSummaryStatistics>	RemoteCollectors.summarizingDouble(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector which applies an double-producing mapping function to each input element, and returns summary statistics for the resulting values.
static <T,U> RemoteCollector<T, ?, com.tangosol.internal.util.IntSummaryStatistics>	RemoteCollectors.summarizingInt(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector which applies an int-producing mapping function to each input element, and returns summary statistics for the resulting values.
static <T,U> RemoteCollector<T, ?, com.tangosol.internal.util.LongSummaryStatistics>	RemoteCollectors.summarizingLong(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector which applies an long-producing mapping function to each input element, and returns summary statistics for the resulting values.
static <T,U> RemoteCollector<T,?,Double>	RemoteCollectors.summingDouble(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector that produces the sum of a double-valued function applied to the input elements.
static <T,U> RemoteCollector<T,?,Integer>	RemoteCollectors.summingInt(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector that produces the sum of a integer-valued function applied to the input elements.
static <T,U> RemoteCollector<T,?,Long>	RemoteCollectors.summingLong(ValueExtractor<? super U, ? extends Number> extractor)	Returns a Collector that produces the sum of a long-valued function applied to the input elements.
static <T, C extends Collection<T>> RemoteCollector<T,?,C>	RemoteCollectors.toCollection(Remote.Supplier<C> supplier)	Returns a Collector that accumulates the input elements into a new Collection, in encounter order.
static <T,U1,U2,K,V> RemoteCollector<T, ?, ConcurrentMap<K,V>>	RemoteCollectors.toConcurrentMap(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper)	Returns a concurrent Collector that accumulates elements into a ConcurrentMap whose keys and values are the result of applying the provided mapping functions to the input elements.
static <T,U1,U2,K,V> RemoteCollector<T, ?, ConcurrentMap<K,V>>	RemoteCollectors.toConcurrentMap(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction)	Returns a concurrent Collector that accumulates elements into a ConcurrentMap whose keys and values are the result of applying the provided mapping functions to the input elements.
static <T> RemoteCollector<T,?,List<T>>	RemoteCollectors.toList()	Returns a Collector that accumulates the input elements into a new List.
static <T,U1,U2,K,V> RemoteCollector<T,?,Map<K,V>>	RemoteCollectors.toMap(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper)	Returns a Collector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.
static <T,U1,U2,K,V> RemoteCollector<T,?,Map<K,V>>	RemoteCollectors.toMap(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction)	Returns a Collector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.
static <T, U1, U2, K, V, M extends Map<K,V>> RemoteCollector<T,?,M>	RemoteCollectors.toMap(ValueExtractor<? super U1, ? extends K> keyExtractor, ValueExtractor<? super U2, ? extends V> valueExtractor, Remote.BinaryOperator<V> mergeFunction, Remote.Supplier<M> mapSupplier)	Returns a Collector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.
static <T> RemoteCollector<T,?,Set<T>>	RemoteCollectors.toSet()	Returns a Collector that accumulates the input elements into a new Set.
static <T> RemoteCollector<T, ?, Collection<T>>	RemoteCollectors.toSortedBag()	Returns a Collector that accumulates the input elements into a new SortedBag.
static <T> RemoteCollector<T, ?, Collection<T>>	RemoteCollectors.toSortedBag(Remote.Comparator<? super T> comparator)	Returns a Collector that accumulates the input elements into a new SortedBag.
static <T, E extends Comparable<? super E>> RemoteCollector<T, ?, Collection<T>>	RemoteCollectors.toSortedBag(ValueExtractor<? super T, ? extends E> comparable)	Returns a Collector that accumulates the input elements into a new SortedBag.
static <T> RemoteCollector<T, ?, Collection<T>>	RemoteCollectors.toSortedBag(Comparator<? super T> comparator)	Returns a Collector that accumulates the input elements into a new SortedBag.
static <T> RemoteCollector<T, ?, SortedSet<T>>	RemoteCollectors.toSortedSet()	Returns a Collector that accumulates the input elements into a new SortedSet.
static <T> RemoteCollector<T, ?, SortedSet<T>>	RemoteCollectors.toSortedSet(Remote.Comparator<? super T> comparator)	Returns a Collector that accumulates the input elements into a new SortedSet.
static <T, E extends Comparable<? super E>> RemoteCollector<T, ?, SortedSet<T>>	RemoteCollectors.toSortedSet(ValueExtractor<? super T, ? extends E> comparable)	Returns a Collector that accumulates the input elements into a new SortedSet.
static <T> RemoteCollector<T, ?, SortedSet<T>>	RemoteCollectors.toSortedSet(Comparator<? super T> comparator)	Returns a Collector that accumulates the input elements into a new SortedSet.
static <T> RemoteCollector<T,?,List<T>>	RemoteCollectors.toUnmodifiableList()	Returns a Collector that accumulates the input elements into an unmodifiable List in encounter order.
static <T,U1,U2,K,V> RemoteCollector<T,?,Map<K,V>>	RemoteCollectors.toUnmodifiableMap(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper)	Returns a Collector that accumulates elements into an unmodifiable Map whose keys and values are the result of applying the provided mapping functions to the input elements.
static <T,U1,U2,K,V> RemoteCollector<T,?,Map<K,V>>	RemoteCollectors.toUnmodifiableMap(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction)	Returns a Collector that accumulates elements into an unmodifiable Map whose keys and values are the result of applying the provided mapping functions to the input elements.
static <T> RemoteCollector<T,?,Set<T>>	RemoteCollectors.toUnmodifiableSet()	Returns a Collector that accumulates the input elements into an unmodifiable List in encounter order.

Methods in com.tangosol.util.stream with parameters of type RemoteCollector

Modifier and Type	Method	Description
<R,A> R	RemoteStream.collect(RemoteCollector<? super T, A, R> collector)	Performs a mutable reduction operation on the elements of this stream using a Collector.
static <T,A,R,RR> RemoteCollector<T,A,RR>	RemoteCollectors.collectingAndThen(RemoteCollector<T,A,R> downstream, Remote.Function<R,RR> finisher)	Adapts a Collector to perform an additional finishing transformation.
static <T, U, K, D, A, M extends Map<K,D>> RemoteCollector<T,?,M>	RemoteCollectors.groupingBy(ValueExtractor<? super U, ? extends K> extractor, Remote.Supplier<M> mapFactory, RemoteCollector<? super T, A, D> downstream)	Returns a Collector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream Collector.
static <T,U,K,A,D> RemoteCollector<T,?,Map<K,D>>	RemoteCollectors.groupingBy(ValueExtractor<? super U, ? extends K> classifier, RemoteCollector<? super T, A, D> downstream)	Returns a Collector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream Collector.
static <T,U,A,R> RemoteCollector<T,A,R>	RemoteCollectors.mapping(Remote.Function<? super T, ? extends U> mapper, RemoteCollector<? super U, A, R> downstream)	Adapts a Collector accepting elements of type U to one accepting elements of type T by applying a mapping function to each input element before accumulation.