Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.cluster |
Contains cluster-related classes.
|
org.apache.ignite.configuration |
Contains configuration-related classes.
|
org.apache.ignite.marshaller |
Contains various supported marshallers.
|
org.apache.ignite.marshaller.jdk |
Contains JDK java.io based marshaller.
|
org.apache.ignite.ml.util.generators.primitives.vector |
Contains generators of pseudo-random vectors in according to specific disctribution.
|
org.apache.ignite.services |
Contains main Managed Services APIs.
|
org.apache.ignite.spi.discovery.isolated |
Contains implementation of special "isolated" mode for single-node cluster.
|
org.apache.ignite.spi.discovery.tcp |
Contains default TCP/IP implementation for discovery SPI.
|
org.apache.ignite.spi.discovery.zk |
Contains Zookeeper Discovery Spi classes and interfaces.
|
org.apache.ignite.spi.eventstorage |
Contains APIs for event storage SPI.
|
org.apache.ignite.spi.eventstorage.memory |
Contains default in-memory implementation for event storage SPI.
|
org.gridgain.grid.security.certificate |
Contains X.509 Certificate Authenticator classes.
|
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.remoteListenAsync(IgniteBiPredicate<UUID,T> locLsnr,
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,
IgniteBiPredicate<UUID,T> locLsnr,
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(IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
<T extends Event> |
IgniteEvents.waitForLocalAsync(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 | 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 | Method and Description |
---|---|
default VectorGenerator |
VectorGenerator.filter(IgnitePredicate<Vector> predicate)
Filters values of vector generator using predicate.
|
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 | Method and Description |
---|---|
boolean |
IsolatedDiscoverySpi.allNodesSupport(org.apache.ignite.internal.IgniteFeatures feature,
IgnitePredicate<ClusterNode> nodesPred) |
Modifier and Type | Method and Description |
---|---|
boolean |
TcpDiscoverySpi.allNodesSupport(org.apache.ignite.internal.IgniteFeatures feature,
IgnitePredicate<ClusterNode> nodesPred) |
Modifier and Type | Method and Description |
---|---|
boolean |
ZookeeperDiscoverySpi.allNodesSupport(org.apache.ignite.internal.IgniteFeatures feature,
IgnitePredicate<ClusterNode> nodesPred) |
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 |
IssuerRegexPredicate
This predicate checks X.509 certificates' Issuer Distinguished Names to match supplied
regular expression
Pattern . |
class |
SubjectRegexPredicate
This predicate checks X.509 certificates' Subject Distinguished Names to match supplied
regular expression
Pattern . |
Modifier and Type | Method and Description |
---|---|
<P extends IgnitePredicate<Certificate[]>> |
CertificateAuthenticator.setPermissionsJson(Map<P,String> permsMapJson)
Sets mapping of certificate predicates to permissions.
|
Modifier and Type | Method and Description |
---|---|
void |
CertificateAuthenticator.setPermissions(Map<? extends IgnitePredicate<Certificate[]>,SecurityPermissionSet> permsMap)
Sets mapping of certificate predicates to permissions.
|
GridGain In-Memory Computing Platform : ver. 8.9.15 Release Date : December 3 2024