Uses of Interface
com.tangosol.util.function.Remote.Predicate

Packages that use Remote.Predicate

Package	Description
com.oracle.coherence.concurrent.executor	Classes to allow submission of tasks to the grid for execution.
com.oracle.coherence.concurrent.executor.function	Various predicates used by the Executor Service.
com.oracle.coherence.concurrent.executor.util	Utility types leveraged by the Coherence Executor Service.
com.tangosol.util	Contains various generic utilities.
com.tangosol.util.function	Contains Functional interfaces allowing remote execution of lambda expressions and method references.
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 Remote.Predicate in com.oracle.coherence.concurrent.executor

Fields in com.oracle.coherence.concurrent.executor declared as Remote.Predicate

Modifier and Type	Field	Description
protected Remote.Predicate<? super R>	AbstractCollectable.m_completionPredicate	The optional Remote.Predicate to indicate if collection is completed.
protected Remote.Predicate<? super R>	ClusteredTaskManager.m_completionPredicate	The Remote.Predicate to determine if the Task is complete, based on a collected result.
protected Remote.Predicate<? super Iterator<T>>	ConditionalCollector.m_predicate	The Remote.Predicate to determine when results can be collected.
protected Remote.Predicate<? super TaskExecutorService.ExecutorInfo>	ExecutionStrategyBuilder.m_predicate	The Remote.Predicate for choosing candidate Executors to execute a Task.
protected Remote.Predicate<? super TaskExecutorService.ExecutorInfo>	StandardExecutionStrategy.m_predicate	The Remote.Predicate that must be satisfied by Executor to be a candidate for executing a Task.

Methods in com.oracle.coherence.concurrent.executor that return Remote.Predicate

Modifier and Type	Method	Description
Remote.Predicate<List<T>>	AbstractCollector.finishable()
Remote.Predicate<List<T>>	ConditionalCollector.finishable()
Remote.Predicate<A>	Task.Collector.finishable()	A Remote.Predicate to determine if a result container can be finished early avoiding further accumulation of results using the container.
Remote.Predicate<AtomicReference<T>>	TaskCollectors.FirstOfCollector.finishable()
Remote.Predicate<List<T>>	TaskCollectors.ListOfCollector.finishable()
Remote.Predicate<Set<T>>	TaskCollectors.SetOfCollector.finishable()

Methods in com.oracle.coherence.concurrent.executor with parameters of type Remote.Predicate

Modifier and Type	Method	Description
Task.Orchestration<T>	AbstractOrchestration.filter(Remote.Predicate<? super TaskExecutorService.ExecutorInfo> predicate)
ExecutionStrategyBuilder	ExecutionStrategyBuilder.filter(Remote.Predicate<? super TaskExecutorService.ExecutorInfo> predicate)	Limit the ExecutionStrategy to use only those Executors that satisfy the specified Remote.Predicate.
Task.Orchestration<T>	NamedClusteredExecutorService.NamedOrchestration.filter(Remote.Predicate<? super TaskExecutorService.ExecutorInfo> predicate)	As this orchestration installs a filter as part of its required function, any user predicates will be and'd together.
Task.Orchestration<T>	Task.Orchestration.filter(Remote.Predicate<? super TaskExecutorService.ExecutorInfo> predicate)	Limit the Executors to only those that satisfy the specified Remote.Predicate.
protected <T,A,R> Task.Coordinator<R>	ClusteredExecutorService.submit(Task<T> task, String sTaskId, ExecutionStrategy strategy, OptionsByType<Task.Option> optionsByType, Task.Properties properties, Task.Collector<? super T, A, R> collector, Remote.Predicate<? super R> completionPredicate, Task.CompletionRunnable<? super R> completionRunnable, Duration retainDuration, Iterator<Task.Subscriber<? super R>> subscribers)	Submit a Task for execution with the given taskId, ExecutionStrategy, OptionsByType, result collector, completion Remote.Predicate, and Task.Subscriber(s).
Task.Completable<T,R>	AbstractCollectable.until(Remote.Predicate<? super R> predicate)
Task.Completable<T,R>	Task.Collectable.until(Remote.Predicate<? super R> predicate)	Sets the Remote.Predicate to determine when the collection of results will be considered completed, based on the collected result, after which no further results will be published to Task.Subscribers.

Constructors in com.oracle.coherence.concurrent.executor with parameters of type Remote.Predicate

Modifier	Constructor	Description
	ClusteredTaskManager(String sTaskId, Task<T> task, ExecutionStrategy executionStrategy, Task.Collector<? super T, A, R> collector, Remote.Predicate<? super R> completionPredicate, Task.CompletionRunnable<? super R> completionRunnable, Duration retainDuration, OptionsByType<Task.Option> optionsByType)	Constructs a ClusteredTaskManager for the specified Task.
	ConditionalCollector(Remote.Predicate<? super Iterator<T>> predicate, Task.Collector<? super T, A, R> collector, R defaultResult)	Constructs a ConditionalCollector.
	StandardExecutionStrategy(int cDesiredExecutors, Remote.Predicate<? super TaskExecutorService.ExecutorInfo> predicate, boolean fConcurrentExecution)	Constructs a StandardExecutionStrategy.

Uses of Remote.Predicate in com.oracle.coherence.concurrent.executor.function

Subinterfaces of Remote.Predicate in com.oracle.coherence.concurrent.executor.function

Modifier and Type	Interface	Description
interface	PortablePredicate<T>	Represents a portable Remote.Predicate (boolean-valued function) with a single argument; a convenience interface for an implementation with no properties that require serialization.

Classes in com.oracle.coherence.concurrent.executor.function that implement Remote.Predicate

Modifier and Type	Class	Description
static class	Predicates.AlwaysPredicate	An Predicates.AlwaysPredicate returns true for any value provided to the Predicate.test(Object) method.
static class	Predicates.EqualToPredicate<T>	A Remote.Predicate to compare a value using Object.equals(Object).
static class	Predicates.IsValuePredicate<T>	An Predicates.IsValuePredicate returns true when a provided Result.isValue().
static class	Predicates.NegatePredicate<T>	A Remote.Predicate that negates the result of another Remote.Predicate.
static class	Predicates.NeverPredicate	An Predicates.NeverPredicate returns false for any value provided to the Predicate.test(Object) method.
static class	Predicates.NullValuePredicate	An Predicates.NullValuePredicate returns true for any value provided to the Predicate.test(Object) method that is null.
static class	Predicates.OptionPredicate	A Remote.Predicate to determine if an TaskExecutorService.ExecutorInfo has a specific TaskExecutorService.Registration.Option.
static class	Predicates.RolePredicate	A Remote.Predicate for matching the name of a Role.
static class	Predicates.ThrowablePredicate<T>	An Predicates.ThrowablePredicate returns true when a provided Result.isThrowable().

Methods in com.oracle.coherence.concurrent.executor.function that return Remote.Predicate

Modifier and Type	Method	Description
static <T> Remote.Predicate<T>	Predicates.always()	Obtains a Remote.Predicate that always succeeds.
static <T> Remote.Predicate<T>	Predicates.anything()	Obtains a Remote.Predicate that always succeeds.
static <T> Remote.Predicate<Result<T>>	Predicates.available()	Obtains a Remote.Predicate that succeeds when Result.isPresent() ()}.
static <T> Remote.Predicate<T>	Predicates.equalTo(T value)	Obtains a Remote.Predicate that uses Object.equals(Object) to compare against a specified value.
static <T> Remote.Predicate<T>	Predicates.AlwaysPredicate.get()	Obtains an instance of the Predicates.AlwaysPredicate.
static Remote.Predicate<TaskExecutorService.ExecutorInfo>	Predicates.has(TaskExecutorService.Registration.Option option)	Obtains a Remote.Predicate for TaskExecutorService.ExecutorInfo to determine if a specific TaskExecutorService.Registration.Option is defined.
static <T> Remote.Predicate<T>	Predicates.is(Remote.Predicate<T> predicate)	Returns the specified Remote.Predicate.
static <T> Remote.Predicate<T>	Predicates.is(T value)	Obtains a Remote.Predicate that uses Object.equals(Object) to compare against a specified value.
static <T> Remote.Predicate<T>	Predicates.never()	Obtains a Remote.Predicate that never succeeds.
static <T> Remote.Predicate<T>	Predicates.not(Remote.Predicate<T> predicate)	Obtains a Remote.Predicate that negates the result of another Remote.Predicate.
static <T> Remote.Predicate<T>	Predicates.notNullValue()	Obtains a Remote.Predicate that succeeds when provided with a non-null value.
static <T> Remote.Predicate<T>	Predicates.nullValue()	Obtains a Remote.Predicate that succeeds when provided with a null value.
static <T> Remote.Predicate<Result<T>>	Predicates.onException()	Obtains a Remote.Predicate to ensure that the Throwable is handled.
static <T> Remote.Predicate<Result<T>>	Predicates.onException(Throwable throwable)	Obtains a Remote.Predicate to ensure that the Result satisfies a specified Remote.Predicate.
static Remote.Predicate<TaskExecutorService.ExecutorInfo>	Predicates.role(String pattern)	Obtains a Remote.Predicate for TaskExecutorService.ExecutorInfo to match the Role name.

Methods in com.oracle.coherence.concurrent.executor.function with parameters of type Remote.Predicate

Modifier and Type	Method	Description
static <T> Remote.BiPredicate<ExecutionPlan, Map<String,T>>	BiPredicates.all(Remote.Predicate<? super T> predicate)	Obtains a Remote.Predicate that ensures all results satisfy a specified Remote.Predicate.
static <T> Remote.BiPredicate<ExecutionPlan, Map<String,T>>	BiPredicates.any(Remote.Predicate<? super T> predicate)	Obtains a Remote.Predicate that ensures any result satisfies a specified Remote.Predicate.
static <T> Remote.Predicate<T>	Predicates.is(Remote.Predicate<T> predicate)	Returns the specified Remote.Predicate.
static <T> Remote.Predicate<T>	Predicates.not(Remote.Predicate<T> predicate)	Obtains a Remote.Predicate that negates the result of another Remote.Predicate.

Constructors in com.oracle.coherence.concurrent.executor.function with parameters of type Remote.Predicate

Modifier	Constructor	Description
	AllResultsBiPredicate(Remote.Predicate<? super T> predicate)	Constructs an BiPredicates.AllResultsBiPredicate.
	AnyResultBiPredicate(Remote.Predicate<? super T> predicate)	Constructs an BiPredicates.AnyResultBiPredicate.
	NegatePredicate(Remote.Predicate<T> predicate)	Constructs a Predicates.NegatePredicate.

Uses of Remote.Predicate in com.oracle.coherence.concurrent.executor.util

Fields in com.oracle.coherence.concurrent.executor.util declared as Remote.Predicate

Modifier and Type	Field	Description
protected final Remote.Predicate<? super T>	FilteringIterator.f_predicate	The Remote.Predicate that must be satisfied for an element to be returned by the Iterator.

Fields in com.oracle.coherence.concurrent.executor.util with type parameters of type Remote.Predicate

Modifier and Type	Field	Description
protected List<Remote.Predicate<?>>	CronPattern.m_listDayOfMonthMatchers	The Predicate list for the "day of month" field.
protected List<Remote.Predicate<?>>	CronPattern.m_listDayOfWeekMatchers	The Predicate list for the "day of week" field.
protected List<Remote.Predicate<?>>	CronPattern.m_listHourMatchers	The Predicate list for the "hour" field.
protected List<Remote.Predicate<?>>	CronPattern.m_listMinuteMatchers	The Predicate list for the "minute" field.
protected List<Remote.Predicate<?>>	CronPattern.m_listMonthMatchers	The Predicate list for the "month" field.

Methods in com.oracle.coherence.concurrent.executor.util that return Remote.Predicate

Modifier and Type	Method	Description
protected Remote.Predicate<?>	CronPattern.buildPredicate(String sPattern, CronPattern.ValueParser parser)	A Predicate utility builder.

Methods in com.oracle.coherence.concurrent.executor.util with parameters of type Remote.Predicate

Modifier and Type	Method	Description
int	CronPattern.getNextDayOfMonth(ZonedDateTime zdt, Remote.Predicate<?> predicate)	Returns the next dayOfMonth to execute the task.
int	CronPattern.getNextDayOfWeek(int nDayOfWeek, Remote.Predicate<?> predicate)	Returns the next dayOfWeek (0(Sunday) - 6(Saturday)) to execute the task.
int	CronPattern.getNextHour(int nHour, Remote.Predicate<?> predicate)	Returns the next hour to execute the task.
int	CronPattern.getNextMinute(int nMinute, Remote.Predicate<?> predicate)	Returns the next minute to execute the task.
int	CronPattern.getNextMonth(int nMonth, Remote.Predicate<?> predicate)	Returns the next dayOfWeek to execute the task.

Constructors in com.oracle.coherence.concurrent.executor.util with parameters of type Remote.Predicate

Modifier	Constructor	Description
	FilteringIterable(Iterable<T> iterable, Remote.Predicate<? super T> predicate)	Constructs a FilteringIterable.
	FilteringIterator(Iterator<T> iterator, Remote.Predicate<? super T> predicate)	Constructs a FilteringIterator.

Uses of Remote.Predicate in com.tangosol.util

Methods in com.tangosol.util with parameters of type Remote.Predicate

Modifier and Type	Method	Description
static <T> PredicateFilter<T,?>	Filters.predicate(Remote.Predicate<T> predicate)	Return a PredicateFilter for a given Predicate.
static <T,E> PredicateFilter<T,E>	Filters.predicate(ValueExtractor<T, ? extends E> extractor, Remote.Predicate<? super E> predicate)	Return a PredicateFilter for a given Predicate.

Uses of Remote.Predicate in com.tangosol.util.function

Methods in com.tangosol.util.function that return Remote.Predicate

Modifier and Type	Method	Description
default Remote.Predicate<T>	Remote.Predicate.and(Remote.Predicate<? super T> other)	Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
static <T> Remote.Predicate<T>	Remote.Predicate.isEqual(Object targetRef)	Returns a predicate that tests if two arguments are equal according to Objects.equals(Object, Object).
default Remote.Predicate<T>	Remote.Predicate.negate()	Returns a predicate that represents the logical negation of this predicate.
default Remote.Predicate<T>	Remote.Predicate.or(Remote.Predicate<? super T> other)	Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
static <T> Remote.Predicate<T>	Remote.predicate(Remote.Predicate<T> predicate)	Capture serializable Predicate.

Methods in com.tangosol.util.function with parameters of type Remote.Predicate

Modifier and Type	Method	Description
default Remote.Predicate<T>	Remote.Predicate.and(Remote.Predicate<? super T> other)	Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
default Remote.Predicate<T>	Remote.Predicate.or(Remote.Predicate<? super T> other)	Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
static <T> Remote.Predicate<T>	Remote.predicate(Remote.Predicate<T> predicate)	Capture serializable Predicate.

Uses of Remote.Predicate in com.tangosol.util.stream

Methods in com.tangosol.util.stream with parameters of type Remote.Predicate

Modifier and Type	Method	Description
default boolean	RemoteStream.allMatch(Remote.Predicate<? super T> predicate)	Returns whether all elements of this stream match the provided predicate.
default boolean	RemoteStream.anyMatch(Remote.Predicate<? super T> predicate)	Returns whether any elements of this stream match the provided predicate.
default RemoteStream<T>	RemoteStream.filter(Remote.Predicate<? super T> predicate)	Returns a stream consisting of the elements of this stream that match the given predicate.
default boolean	RemoteStream.noneMatch(Remote.Predicate<? super T> predicate)	Returns whether no elements of this stream match the provided predicate.