| 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(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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.
|
<T extends Event> |
IgniteEvents.remoteQueryAsync(IgnitePredicate<T> p,
long timeout,
int... types)
Asynchronously 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(@Nullable IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
<T extends Event> |
IgniteEvents.waitForLocalAsync(@Nullable IgnitePredicate<T> filter,
int... types)
Create future to wait 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 |
|---|---|
CollectionConfiguration |
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 | Class and Description |
|---|---|
class |
SecurityAwarePredicate<E>
Security aware IgnitePredicate.
|
class |
SecurityCredentialsAttrFilterPredicate
Predicate to filter out security credentials attribute by its name.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<String> |
MarshallerContextImpl.classNameFilter()
Returns class name filter.
|
@Nullable IgnitePredicate<ClusterNode> |
GridTaskSessionImpl.getTopologyPredicate() |
IgnitePredicate<ClusterNode> |
GridJobExecuteRequest.getTopologyPredicate() |
| 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(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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.
|
<T extends Event> |
IgniteEventsImpl.remoteQueryAsync(IgnitePredicate<T> p,
long timeout,
int... types)
Asynchronously 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(@Nullable IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
<T extends Event> |
IgniteEventsImpl.waitForLocalAsync(@Nullable IgnitePredicate<T> filter,
int... types)
Create future to wait for the specified events.
|
| Constructor and Description |
|---|
GridJobExecuteRequest(IgniteUuid sesId,
IgniteUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
ComputeJob job,
long startTaskTime,
long timeout,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
byte[] topPredBytes,
byte[] siblingsBytes,
Collection<ComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
IgniteUuid clsLdrId,
DeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,IgniteUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal,
UUID subjId,
@Nullable int[] cacheIds,
int part,
@Nullable AffinityTopologyVersion topVer,
@Nullable String execName) |
GridKernalContextImpl(GridLoggerProxy log,
IgniteEx grid,
IgniteConfiguration cfg,
GridKernalGateway gw,
ExecutorService utilityCachePool,
ExecutorService execSvc,
ExecutorService svcExecSvc,
ExecutorService sysExecSvc,
StripedExecutor stripedExecSvc,
ExecutorService p2pExecSvc,
ExecutorService mgmtExecSvc,
StripedExecutor dataStreamExecSvc,
ExecutorService restExecSvc,
ExecutorService affExecSvc,
@Nullable ExecutorService idxExecSvc,
@Nullable ExecutorService buildIdxExecSvc,
IgniteStripedThreadPoolExecutor callbackExecSvc,
ExecutorService qryExecSvc,
ExecutorService schemaExecSvc,
ExecutorService rebalanceExecSvc,
IgniteStripedThreadPoolExecutor rebalanceStripedExecSvc,
@Nullable Map<String,? extends ExecutorService> customExecSvcs,
List<PluginProvider> plugins,
IgnitePredicate<String> clsFilter,
WorkersRegistry workerRegistry,
Thread.UncaughtExceptionHandler hnd,
LongJVMPauseDetector pauseDetector)
Creates new kernal context.
|
GridTaskSessionImpl(UUID taskNodeId,
String taskName,
@Nullable GridDeployment dep,
String taskClsName,
IgniteUuid sesId,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
@Nullable Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup,
boolean internal,
UUID subjId,
@Nullable String execName) |
MarshallerContextImpl(@Nullable Collection<PluginProvider> plugins,
IgnitePredicate<String> clsFilter)
Initializes context.
|
SecurityAwarePredicate(UUID subjectId,
IgnitePredicate<E> original) |
| Constructor and Description |
|---|
GridClientJdkMarshaller(IgnitePredicate<String> clsFilter) |
| 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(@Nullable GridKernalContext ctx,
@Nullable UUID subjId,
@Nullable IgnitePredicate<ClusterNode> p) |
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridDeploymentMetadata.nodeFilter() |
| Modifier and Type | Method and Description |
|---|---|
Map<String,Class<? extends ComputeTask<?,?>>> |
GridDeploymentManager.findAllTasks(IgnitePredicate<? super Class<? extends ComputeTask<?,?>>>... p) |
@Nullable GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
@Nullable IgnitePredicate<ClusterNode> nodeFilter) |
void |
GridDeploymentMetadata.nodeFilter(IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.addCacheGroup(CacheGroupDescriptor grpDesc,
IgnitePredicate<ClusterNode> filter,
CacheMode cacheMode) |
Collection<ClusterNode> |
GridDiscoveryManager.nodes(@Nullable Collection<UUID> ids,
IgnitePredicate<UUID>... p)
Gets collection of node for given node IDs and predicates.
|
| 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(@Nullable IgnitePredicate<T> p,
int... types) |
| Modifier and Type | Method and Description |
|---|---|
Object |
GridAffinityProcessor.similaryAffinityKey(AffinityFunction aff,
IgnitePredicate<ClusterNode> nodeFilter,
int backups,
int parts) |
| Constructor and Description |
|---|
GridAffinityAssignmentCache(GridKernalContext ctx,
String cacheOrGrpName,
int grpId,
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 |
|---|---|
static IgnitePredicate |
GridCacheUtils.FILTER_NEAR_CACHE_ENTRY
Write filter.
|
static IgnitePredicate |
GridCacheUtils.READ_FILTER
Read filter.
|
static IgnitePredicate |
GridCacheUtils.READ_FILTER_COLOCATED
Read filter.
|
static IgnitePredicate |
GridCacheUtils.READ_FILTER_NEAR
Read filter.
|
static IgnitePredicate |
GridCacheUtils.WRITE_FILTER
Write filter.
|
static IgnitePredicate |
GridCacheUtils.WRITE_FILTER_COLOCATED
Write filter.
|
static IgnitePredicate |
GridCacheUtils.WRITE_FILTER_NEAR
Write filter.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheUtils.empty() |
IgnitePredicate<ClusterNode> |
CacheGroupContext.nodeFilter() |
static IgnitePredicate<IgniteTxEntry> |
GridCacheUtils.reads() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p) |
static 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,
@Nullable IgnitePredicate<? super E>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
IgniteInternalFuture<?> |
GridCacheSharedContext.partitionRecoveryFuture(AffinityTopologyVersion topVer,
ClusterNode node,
IgnitePredicate<IgniteInternalTx> filter)
Captures all prepared operations that we need to wait before we able to perform PME-free switch.
|
protected boolean |
GridCacheMapEntry.storeValue(@Nullable CacheObject val,
long expireTime,
GridCacheVersion ver,
@Nullable IgnitePredicate<CacheDataRow> predicate,
@Nullable CacheDataRow row)
Stores value in off-heap.
|
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,
@Nullable IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(@Nullable WALIterator it,
IgniteBiPredicate<WALPointer,WALRecord> recPredicate,
IgnitePredicate<DataEntry> entryPredicate)
Apply update from some iterator and with specific filters.
|
| Constructor and Description |
|---|
RestoreBinaryState(CheckpointStatus status,
WALIterator iterator,
long lastArchivedSegment,
IgnitePredicate<Integer> cacheGroupsPredicate) |
RestoreLogicalState(CheckpointStatus status,
WALIterator iterator,
long lastArchivedSegment,
IgnitePredicate<Integer> cacheGroupsPredicate,
Map<GroupPartitionId,Integer> partitionRecoveryStates) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
IgniteTxManager.recoverLocalTxs(AffinityTopologyVersion topVer,
ClusterNode node,
IgnitePredicate<IgniteInternalTx> filter)
Creates a future that will wait for all transactions with failed primary recovery.
|
| Constructor and Description |
|---|
IgniteTxMap(Map<IgniteTxKey,IgniteTxEntry> txMap,
IgnitePredicate<IgniteTxEntry> filter) |
| Modifier and Type | Method and Description |
|---|---|
List<ClusterNode> |
BaselineTopology.createBaselineView(Collection<ClusterNode> aliveNodes,
@Nullable IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
UUID |
GridContinuousProcessor.registerStaticRoutine(String cacheName,
javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr,
CacheEntryEventSerializableFilter rmtFilter,
@Nullable 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,
@Nullable IgnitePredicate<ClusterNode> prjPred) |
| 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.
|
class |
PlatformLocalEventListener
Platform local event filter.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> void |
PlatformUtils.writeCollection(BinaryRawWriterEx writer,
Collection<T> col,
@Nullable PlatformWriterClosure<T> writeClo,
@Nullable IgnitePredicate<T> filter)
Write collection to the writer.
|
static <T> void |
PlatformUtils.writeNullableCollection(BinaryRawWriterEx writer,
@Nullable Collection<T> col,
@Nullable PlatformWriterClosure<T> writeClo,
@Nullable IgnitePredicate<T> filter)
Write collection to the writer.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridServiceAssignments.nodeFilter()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
GridTaskSessionImpl |
GridTaskSessionProcessor.createTaskSession(IgniteUuid sesId,
UUID taskNodeId,
String taskName,
@Nullable GridDeployment dep,
String taskClsName,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup,
boolean internal,
UUID subjId,
@Nullable String execName) |
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
F0.and(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(Iterator<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(@Nullable ConcurrentLinkedQueue<GridDebug.Item> q2,
@Nullable IgnitePredicate<GridDebug.Item> filter)
Dump existing queue to stdout and atomically replace it with given.
|
static Class<?> |
IgniteUtils.forName(String clsName,
@Nullable ClassLoader ldr,
IgnitePredicate<String> clsFilter)
Gets class for provided name.
|
static Class<?> |
IgniteUtils.forName(String clsName,
@Nullable ClassLoader ldr,
IgnitePredicate<String> clsFilter,
boolean useCache)
Gets class for provided name.
|
static boolean |
F0.isAllNodePredicates(IgnitePredicate<?>... ps)
Tests if all passed in predicates are instances of
GridNodePredicate class. |
N |
GridConsistentHash.node(@Nullable Object key,
IgnitePredicate<N>... p)
Gets node for a given key.
|
List<N> |
GridConsistentHash.nodes(@Nullable 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,
@Nullable IgnitePredicate<ClusterNode> p)
Gets oldest node out of collection of nodes.
|
static List<Integer> |
IgniteUtils.toIntList(@Nullable int[] arr,
IgnitePredicate<Integer>... p)
Converts array of integers into list.
|
static ClusterNode |
IgniteUtils.youngest(Collection<ClusterNode> c,
@Nullable IgnitePredicate<ClusterNode> p)
Gets youngest node out of collection of nodes.
|
| Constructor and Description |
|---|
GridReflectionCache(@Nullable IgnitePredicate<Field> fp,
@Nullable IgnitePredicate<Method> mp)
Reflection cache with specified field and method predicates.
|
GridReflectionCache(@Nullable IgnitePredicate<Field> fp,
@Nullable 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(@Nullable 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 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(@Nullable 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(@Nullable 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(@Nullable 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. |
| 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(@Nullable IgnitePredicate[] p)
Deprecated.
|
static boolean |
GridFunc.isAlwaysTrue(IgnitePredicate p)
Deprecated.
|
static boolean |
GridFunc.isAlwaysTrue(@Nullable 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 <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(@Nullable Collection<? extends T> c,
IgnitePredicate<? super T>... p)
Gets size of the given collection with provided optional predicates.
|
static <T> int |
GridFunc.size(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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(@Nullable 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 | Class and Description |
|---|---|
class |
AlwaysFalsePredicate<E>
Defines a predicate which accepts a parameter and always returns
false |
class |
AlwaysTruePredicate<E>
Defines a predicate which accepts a parameter and always returns
true |
class |
CacheEntryHasPeekPredicate
Cache entry has-peek-value predicate.
|
class |
ContainsNodeIdsPredicate<T extends ClusterNode>
Grid node predicate evaluating on the given node IDs.
|
class |
ContainsPredicate<T>
Predicate which returns
true if it receives an element that is contained in the passed in
collection. |
class |
EntryByKeyEvaluationPredicate<K,V>
Predicate evaluates to true for given value.
|
class |
EqualsClusterNodeIdPredicate<T extends ClusterNode>
Creates grid node predicate evaluating on the given node ID.
|
class |
EqualsUuidPredicate
UUID equals predicate.
|
class |
HasEqualIdPredicate<T extends ClusterNode>
ClusterNode has equal id predicate. |
class |
HasNotEqualIdPredicate<T extends ClusterNode>
ClusterNode node has NOT equal id predicate. |
class |
IsAllPredicate<T>
Predicate that evaluates to
true if each of its component preds evaluates to true. |
class |
IsNotAllPredicate<T>
Negated predicate.
|
class |
IsNotNullPredicate<E>
Defines a predicate which checks a parameter on
null. |
class |
NotContainsPredicate<T>
Predicate that returns
true if its free variable is not contained in given collection. |
class |
NotEqualPredicate<T>
Predicate that evaluates to
true if its free variable is equal to target or both are
null. |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<String> |
GridNioServer.dumpNodeStats(String msg,
IgnitePredicate<GridNioSession> p) |
IgniteInternalFuture<String> |
GridNioServer.dumpStats(String msg,
IgnitePredicate<GridNioSession> p) |
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 | Method and Description |
|---|---|
IgnitePredicate<String> |
MarshallerContext.classNameFilter()
Returns class name filter.
|
static IgnitePredicate<String> |
MarshallerUtils.classNameFilter(ClassLoader clsLdr)
Returns class name filter for marshaller.
|
| Constructor and Description |
|---|
JdkMarshaller(IgnitePredicate<String> clsFilter) |
| 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 |
|---|---|
ServiceConfiguration |
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.
|
<T extends Event> |
NoopEventStorageSpi.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.
|
MemoryEventStorageSpi |
MemoryEventStorageSpi.setFilter(IgnitePredicate<Event> filter)
Sets filter for events to be recorded.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AttributeNodeFilter
Implementation of
IgnitePredicate<ClusterNode> based on
user attributes. |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021