| Modifier and Type | Method and Description |
|---|---|
void |
IgniteEvents.localListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Adds an event listener for local events.
|
<T extends Event> |
IgniteEvents.localQuery(IgnitePredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends Event> |
IgniteEvents.remoteListen(IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEvents.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
boolean |
IgniteEvents.stopLocalListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes local event listener.
|
<T extends Event> |
IgniteEvents.waitForLocal(IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
ClusterGroup.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
CacheConfiguration.IgniteAllNodesPredicate
Filter that accepts all nodes.
|
| Modifier and Type | Field and Description |
|---|---|
static IgnitePredicate<ClusterNode> |
CacheConfiguration.ALL_NODES
Filter that accepts all nodes.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
CollectionConfiguration.getNodeFilter() |
IgnitePredicate<ClusterNode> |
CacheConfiguration.getNodeFilter()
Gets filter which determines on what nodes the cache should be started.
|
| Modifier and Type | Method and Description |
|---|---|
Map<IgnitePredicate<? extends Event>,int[]> |
IgniteConfiguration.getLocalEventListeners()
Gets map of pre-configured local event listeners.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CollectionConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter) |
CacheConfiguration<K,V> |
CacheConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
Sets filter which determines on what nodes the cache should be started.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteConfiguration |
IgniteConfiguration.setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)
Sets map of pre-configured local event listeners.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteInternalCache<?,?>> |
IgniteEx.cachesx(IgnitePredicate<? super IgniteInternalCache<?,?>>... p)
Gets configured cache instance that satisfy all provided predicates including non-public caches.
|
Collection<IgniteInternalCache<?,?>> |
IgniteKernal.cachesx(IgnitePredicate<? super IgniteInternalCache<?,?>>[] p)
Gets configured cache instance that satisfy all provided predicates including non-public caches.
|
void |
IgniteEventsImpl.localListen(IgnitePredicate<? extends Event> lsnr,
int[] types)
Adds an event listener for local events.
|
<T extends Event> |
IgniteEventsImpl.localQuery(IgnitePredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends Event> |
IgniteEventsImpl.remoteListen(IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the cluster group (possibly including
local node if it belongs to the cluster group as well).
|
<T extends Event> |
IgniteEventsImpl.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
boolean |
IgniteEventsImpl.stopLocalListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes local event listener.
|
<T extends Event> |
IgniteEventsImpl.waitForLocal(IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.p
Cluster group predicate.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
IgnitePredicate<ClusterNode> |
IgniteClusterAsyncImpl.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
| Constructor and Description |
|---|
ClusterGroupAdapter(GridKernalContext ctx,
UUID subjId,
IgnitePredicate<ClusterNode> p) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,Class<? extends ComputeTask<?,?>>> |
GridDeploymentManager.findAllTasks(IgnitePredicate<? super Class<? extends ComputeTask<?,?>>>... p) |
GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
GridDiscoveryManager.nodes(Collection<UUID> ids,
IgnitePredicate<UUID>... p)
Gets collection of node for given node IDs and predicates.
|
void |
GridDiscoveryManager.setCacheFilter(String cacheName,
IgnitePredicate<ClusterNode> filter,
boolean nearEnabled,
CacheMode cacheMode)
Adds dynamic cache filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEventStorageManager.addLocalEventListener(IgnitePredicate<? extends Event> lsnr,
int[] types)
Adds local user event listener.
|
<T extends Event> |
GridEventStorageManager.localEvents(IgnitePredicate<T> p) |
<T extends Event> |
GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p,
Collection<? extends ClusterNode> nodes,
long timeout) |
boolean |
GridEventStorageManager.removeLocalEventListener(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes user listener for specified events, if any.
|
<T extends Event> |
GridEventStorageManager.waitForEvent(IgnitePredicate<T> p,
int... types) |
Event |
GridEventStorageManager.waitForEvent(long timeout,
Runnable c,
IgnitePredicate<? super Event> p,
int... types) |
| Constructor and Description |
|---|
GridAffinityAssignmentCache(GridKernalContext ctx,
String cacheName,
AffinityFunction aff,
IgnitePredicate<ClusterNode> nodeFilter,
int backups,
boolean locCache)
Constructs affinity cached calculations.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CacheEntryPredicate |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheEntryPredicateAdapter |
class |
CacheEntryPredicateContainsValue |
class |
CacheEntryPredicateHasValue |
class |
CacheEntryPredicateNoValue |
class |
CacheEntrySerializablePredicate |
| Modifier and Type | Field and Description |
|---|---|
protected IgnitePredicate<GridCacheEntryInfo> |
GridCachePreloaderAdapter.preloadPred
Preload predicate.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheUtils.empty() |
static IgnitePredicate<KeyCacheObject> |
GridCacheUtils.keyHasMeta(GridCacheContext ctx,
int meta) |
IgnitePredicate<GridCacheEntryInfo> |
GridCachePreloaderAdapter.preloadPredicate() |
IgnitePredicate<GridCacheEntryInfo> |
GridCachePreloader.preloadPredicate() |
static <K,V> IgnitePredicate<IgniteTxEntry> |
GridCacheUtils.reads() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p) |
static <K,V> IgnitePredicate<IgniteTxEntry> |
GridCacheUtils.writes() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
GridCacheUtils.affinityNode(ClusterNode node,
IgnitePredicate<ClusterNode> filter) |
<E> boolean |
GridCacheContext.isAll(E e,
IgnitePredicate<? super E>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
<K1,V1> boolean |
GridCacheContext.isAll(GridCacheEntryEx e,
IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
void |
GridCachePreloaderAdapter.preloadPredicate(IgnitePredicate<GridCacheEntryInfo> preloadPred) |
void |
GridCachePreloader.preloadPredicate(IgnitePredicate<GridCacheEntryInfo> p) |
void |
GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes,
GridCacheMessage msg,
byte plc,
IgnitePredicate<ClusterNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p) |
| Constructor and Description |
|---|
GridCacheIterator(GridCacheContext<K,V> cctx,
Iterable<? extends javax.cache.Cache.Entry<K,V>> c,
IgniteClosure<javax.cache.Cache.Entry<K,V>,T> trans,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridCacheValueCollection(GridCacheContext<K,V> ctx,
Collection<? extends javax.cache.Cache.Entry<K,V>> c,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPreloader.preloadPredicate(IgnitePredicate<GridCacheEntryInfo> preloadPred) |
| Constructor and Description |
|---|
IgniteTxMap(Map<IgniteTxKey,IgniteTxEntry> txMap,
IgnitePredicate<IgniteTxEntry> filter) |
| Modifier and Type | Method and Description |
|---|---|
UUID |
GridContinuousProcessor.registerStaticRoutine(String cacheName,
javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr,
CacheEntryEventSerializableFilter rmtFilter,
IgnitePredicate<ClusterNode> prjPred)
Registers routine info to be sent in discovery data during this node join
(to be used for internal queries started from client nodes).
|
IgniteInternalFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
boolean locOnly,
int bufSize,
long interval,
boolean autoUnsubscribe,
IgnitePredicate<ClusterNode> prjPred) |
| Modifier and Type | Class and Description |
|---|---|
class |
IgfsNodePredicate
IGFS node predicate.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformEventFilterListener
Platform event filter and listener.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformClusterNodeFilter
Platform cluster node filter marker interface.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformClusterNodeFilterImpl
Interop cluster node filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformEventFilterListenerImpl
Platform event filter.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> void |
PlatformUtils.writeCollection(BinaryRawWriterEx writer,
Collection<T> col,
PlatformWriterClosure<T> writeClo,
IgnitePredicate<T> filter)
Write collection to the writer.
|
static <T> void |
PlatformUtils.writeNullableCollection(BinaryRawWriterEx writer,
Collection<T> col,
PlatformWriterClosure<T> writeClo,
IgnitePredicate<T> filter)
Write collection to the writer.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridServiceAssignments.nodeFilter() |
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T> p,
IgnitePredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.contains(Collection<T> c)
Provides predicate (not peer-deployable) which returns
true if it receives an element
that is contained in the passed in collection. |
static <T> IgnitePredicate<T> |
F0.equalTo(T target)
Gets predicate (not perr-deployable) that evaluates to
true if its free variable is equal
to target or both are null. |
static <T> IgnitePredicate<T> |
F0.in(Collection<? extends T> c)
Gets predicate (not peer-deployable) that returns
true if its free variable is contained
in given collection. |
static <T> IgnitePredicate<T> |
F0.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static <T> IgnitePredicate<T> |
F0.notContains(Collection<T> c)
Provides predicate (not peer-deployable) which returns
true if it receives an element
that is not contained in the passed in collection. |
static <T> IgnitePredicate<T> |
F0.notEqualTo(T target)
Gets predicate (not peer-deployable) that evaluates to
true if its free variable is not equal
to target or both are null. |
static <T> IgnitePredicate<T> |
F0.notIn(Collection<? extends T> c)
Gets predicate (not peer-deployable) that returns
true if its free variable
is not contained in given collection. |
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T> p,
IgnitePredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T> p,
IgnitePredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T extends R,R> |
IgniteUtils.arrayList(Collection<T> c,
IgnitePredicate<? super T>... p) |
static <T extends R,R> |
IgniteUtils.arrayList(Iterable<T> c,
int cap,
IgnitePredicate<? super T>... p) |
boolean |
GridAtomicInteger.checkAndSet(IgnitePredicate<Integer> p,
int update)
Atomically updates value only if passed in predicate returns
true. |
boolean |
GridAtomicLong.checkAndSet(IgnitePredicate<Long> p,
long update)
Atomically updates value only if passed in predicate returns
true. |
static String |
GridDebug.dumpWithReset(ConcurrentLinkedQueue<GridDebug.Item> q2,
IgnitePredicate<GridDebug.Item> filter)
Dump existing queue to stdout and atomically replace it with given.
|
static boolean |
F0.isAllNodePredicates(IgnitePredicate<?>... ps)
Tests if all passed in predicates are instances of
GridNodePredicate class. |
N |
GridConsistentHash.node(Object key,
IgnitePredicate<N>... p)
Gets node for a given key.
|
List<N> |
GridConsistentHash.nodes(Object key,
int cnt,
IgnitePredicate<N>... p)
Gets specified count of adjacent nodes for a given key.
|
static <T> IgnitePredicate<T> |
F0.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static ClusterNode |
IgniteUtils.oldest(Collection<ClusterNode> c,
IgnitePredicate<ClusterNode> p)
Gets oldest node out of collection of nodes.
|
static List<Integer> |
IgniteUtils.toIntList(int[] arr,
IgnitePredicate<Integer>... p)
Converts array of integers into list.
|
static ClusterNode |
IgniteUtils.youngest(Collection<ClusterNode> c,
IgnitePredicate<ClusterNode> p)
Gets youngest node out of collection of nodes.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
F0.isAllNodePredicates(Iterable<? extends IgnitePredicate<?>> ps)
Tests if all passed in predicates are instances of
GridNodePredicate class. |
| Constructor and Description |
|---|
GridReflectionCache(IgnitePredicate<Field> fp,
IgnitePredicate<Method> mp)
Reflection cache with specified field and method predicates.
|
GridReflectionCache(IgnitePredicate<Field> fp,
IgnitePredicate<Method> mp)
Reflection cache with specified field and method predicates.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNodePredicate
Convenient node predicate as a separate class.
|
class |
IgnitePredicateX<E1>
Convenient predicate subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
GridFunc.alwaysFalse()
Gets predicate that always returns
false. |
static <T> IgnitePredicate<T> |
GridFunc.alwaysTrue()
Gets predicate that always returns
true. |
static <T> IgnitePredicate<T> |
GridFunc.and(IgnitePredicate<? super T>... ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheHasPeekValue()
Gets predicate which returns
true if entry has peek value. |
static <T> IgnitePredicate<T> |
GridFunc.contains(Collection<T> c)
Provides predicate which returns
true if it receives an element
that is contained in the passed in collection. |
static <T> IgnitePredicate<T> |
GridFunc.equalTo(T target)
Deprecated.
|
static IgnitePredicate<UUID> |
GridFunc.idForNodeId(UUID nodeId)
Creates
UUID predicate evaluating on the given node ID. |
static <T> IgnitePredicate<T> |
GridFunc.instanceOf(Class<?> cls)
Deprecated.
|
static <T> IgnitePredicate<T> |
GridFunc.isNull()
Deprecated.
|
static <T extends ClusterNode> |
GridFunc.localNode(UUID locNodeId)
Gets predicate that evaluates to
true only for given local node ID. |
static <T extends ClusterNode> |
GridFunc.nodeForNodeId(UUID nodeId)
Creates grid node predicate evaluating on the given node ID.
|
static <T extends ClusterNode> |
GridFunc.nodeForNodeIds(Collection<UUID> nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static IgnitePredicate<ClusterNode> |
GridFunc.nodeForNodes(ClusterNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static <T> IgnitePredicate<T> |
GridFunc.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static <T> IgnitePredicate<T> |
GridFunc.notContains(Collection<T> c)
Provides predicate which returns
true if it receives an element
that is not contained in the passed in collection. |
static <T> IgnitePredicate<T> |
GridFunc.notEqualTo(T target)
Gets predicate that evaluates to
true if its free variable is not equal
to target or both are null. |
static <T> IgnitePredicate<T> |
GridFunc.notIn(Collection<? extends T> c)
Gets predicate that returns
true if its free variable is not
contained in given collection. |
static <T> IgnitePredicate<T> |
GridFunc.notNull()
Gets predicate that evaluates to
true if its free variable is not null. |
static <T extends ClusterNode> |
GridFunc.remoteNodes(UUID locNodeId)
Gets predicate that evaluates to
false for given local node ID. |
static IgnitePredicate<IgniteInternalFuture<?>> |
GridFunc.unfinishedFutures()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
GridFunc.and(IgnitePredicate<? super T>... ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> Collection<T> |
GridFunc.copy(Collection<T> to,
Iterable<? extends T> from,
IgnitePredicate<? super T>... p)
Deprecated.
|
static <V> boolean |
GridFunc.exist(Iterable<? extends V> c,
IgnitePredicate<? super V>... p)
Checks for existence of the element in input collection for which all provided predicates
evaluate to
true. |
static <T> List<T> |
GridFunc.filterList(List<T> c,
boolean cp,
IgnitePredicate<T>... p)
Deprecated.
|
static <V> V |
GridFunc.find(Iterable<? extends V> c,
V dfltVal,
IgnitePredicate<? super V>... p)
Finds and returns first element in given collection for which any of the
provided predicates evaluates to
true. |
static <V,Y> Y |
GridFunc.find(Iterable<? extends V> c,
Y dfltVal,
IgniteClosure<? super V,Y> f,
IgnitePredicate<? super V>... p)
Deprecated.
|
static <V> boolean |
GridFunc.forAll(Iterable<? extends V> c,
IgnitePredicate<? super V>... p)
Deprecated.
|
static <K1,K extends K1,V1,V extends V1> |
GridFunc.forAll(Map<K,V> m,
IgnitePredicate<? super Map.Entry<K,V>>... p)
Deprecated.
|
static <V> boolean |
GridFunc.forAny(Iterable<? extends V> c,
IgnitePredicate<? super V>... p)
Deprecated.
|
static <X> void |
GridFunc.forEach(Iterable<? extends X> c,
IgniteInClosure<? super X> f,
IgnitePredicate<? super X>... p)
Deprecated.
|
static <X> void |
GridFunc.forEach(X[] c,
IgniteInClosure<? super X> f,
IgnitePredicate<? super X>... p)
Deprecated.
|
static <T> boolean |
GridFunc.isAll(T t,
IgnitePredicate<? super T>... p)
Tests if all provided predicates evaluate to
true for given value. |
static boolean |
GridFunc.isAlwaysFalse(IgnitePredicate p)
Deprecated.
|
static boolean |
GridFunc.isAlwaysFalse(IgnitePredicate[] p)
Deprecated.
|
static boolean |
GridFunc.isAlwaysTrue(IgnitePredicate p)
Deprecated.
|
static boolean |
GridFunc.isAlwaysTrue(IgnitePredicate[] p)
Tests whether or not given set of predicates consists only of one predicate returned from
GridFunc.alwaysTrue() method. |
static <T> boolean |
GridFunc.isAny(T t,
IgnitePredicate<? super T>... p)
Deprecated.
|
static <T1,T2> GridIterator<T2> |
GridFunc.iterator(Iterable<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
boolean readOnly,
IgnitePredicate<? super T1>... p)
Creates and returns transforming iterator from given collection and optional
filtering predicates.
|
static <T1,T2> Iterator<T2> |
GridFunc.iterator(Iterator<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
boolean readOnly,
IgnitePredicate<? super T1>... p) |
static <T> GridIterator<T> |
GridFunc.iterator0(Iterable<? extends T> c,
boolean readOnly,
IgnitePredicate<? super T>... p)
Creates and returns iterator from given collection and optional filtering predicates.
|
static <T> Collection<T> |
GridFunc.lose(Collection<T> c,
boolean cp,
IgnitePredicate<? super T>... p)
Deprecated.
|
static <K,V> Map<K,V> |
GridFunc.lose(Map<K,V> m,
boolean cp,
IgnitePredicate<? super Map.Entry<K,V>>... p)
Deprecated.
|
static <K,V> Map<K,V> |
GridFunc.loseKeys(Map<K,V> m,
boolean cp,
IgnitePredicate<? super K>... p)
Deprecated.
|
static <K,V> Map<K,V> |
GridFunc.loseValues(Map<K,V> m,
boolean cp,
IgnitePredicate<? super V>... p)
Deprecated.
|
static <T> IgnitePredicate<T> |
GridFunc.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static <V> IgniteBiTuple<Collection<V>,Collection<V>> |
GridFunc.partition(Iterable<? extends V> c,
IgnitePredicate<? super V> p)
Deprecated.
|
static <T> Collection<T> |
GridFunc.retain(Collection<T> c,
boolean cp,
IgnitePredicate<? super T>... p)
Retains all elements in input collection that are evaluated to
true
by all given predicates. |
static <T> int |
GridFunc.size(Collection<? extends T> c,
IgnitePredicate<? super T>... p)
Gets size of the given collection with provided optional predicates.
|
static <T> int |
GridFunc.size(Iterator<? extends T> it,
IgnitePredicate<? super T>... p)
Gets size of the given iterator with provided optional predicates.
|
static <T1,T2> List<T2> |
GridFunc.transformList(Collection<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
IgnitePredicate<? super T1>... p)
Deprecated.
|
static <T> Collection<T> |
GridFunc.view(Collection<T> c,
IgnitePredicate<? super T>... p)
Creates write-through light-weight view on given collection with provided predicates.
|
static <K0,K extends K0,V0,V extends V0> |
GridFunc.view(Map<K,V> m,
IgnitePredicate<? super K>... p)
Creates light-weight view on given map with provided predicates.
|
static <K0,K extends K0,V0,V extends V0> |
GridFunc.viewAsMap(Set<K> c,
IgniteClosure<? super K,V> mapClo,
IgnitePredicate<? super K>... p)
Read-only map view of a collection.
|
static <T1,T2> Collection<T2> |
GridFunc.viewReadOnly(Collection<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
IgnitePredicate<? super T1>... p)
Creates read-only light-weight view on given collection with transformation and provided
predicates.
|
static <K0,K extends K0,V0,V extends V0,V1> |
GridFunc.viewReadOnly(Map<K,V> m,
IgniteBiClosure<K,V,V1> trans,
IgnitePredicate<? super K>... p)
Deprecated.
|
static <K0,K extends K0,V0,V extends V0,V1> |
GridFunc.viewReadOnly(Map<K,V> m,
IgniteClosure<V,V1> trans,
IgnitePredicate<? super K>... p)
Read-only view on map that supports transformation of values and key filtering.
|
| Modifier and Type | Method and Description |
|---|---|
GridNioServer.Builder<T> |
GridNioServer.Builder.skipRecoveryPredicate(IgnitePredicate<Message> skipRecoveryPred) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
P1<E1>
Defines
alias for IgnitePredicate by extending it. |
interface |
PCE<K,V>
Defines
alias for GridPredicate<Entry<K, V>> by extending
IgnitePredicate. |
interface |
PE
Defines
alias for GridPredicate<GridEvent> by extending
IgnitePredicate. |
interface |
PN
Defines
alias for GridPredicate<ClusterNode> by extending
IgnitePredicate. |
| Modifier and Type | Class and Description |
|---|---|
class |
PX1<E1>
Defines
alias for IgnitePredicateX by extending it. |
| Modifier and Type | Field and Description |
|---|---|
protected IgnitePredicate<ClusterNode> |
ServiceConfiguration.nodeFilter
Node filter.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
ServiceConfiguration.getNodeFilter()
Gets node filter used to filter nodes on which the service will be deployed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ServiceConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
Sets node filter used to filter nodes on which the service will be deployed.
|
| Modifier and Type | Field and Description |
|---|---|
static IgnitePredicate<TcpDiscoveryNode> |
TcpDiscoveryNodesRing.VISIBLE_NODES
Visible nodes filter.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
EventStorageSpi.localEvents(IgnitePredicate<T> p)
Queries locally-stored events only.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<Event> |
MemoryEventStorageSpi.getFilter()
Gets filter for events to be recorded.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
MemoryEventStorageSpi.localEvents(IgnitePredicate<T> p)
Queries locally-stored events only.
|
void |
MemoryEventStorageSpi.setFilter(IgnitePredicate<Event> filter)
Sets filter for events to be recorded.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.7.0 Release Date : August 1 2016