Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.cluster | |
org.apache.ignite.configuration | |
org.apache.ignite.services |
Contains main Managed Services APIs.
|
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.apache.ignite.streamer.router |
Contains streamer event router implementations.
|
org.apache.ignite.streamer.window |
Contains streamer window implementations.
|
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 projection (possibly including
local node if it belongs to the projection 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 projection (possibly including
local node if it belongs to the projection as well).
|
<T extends Event> |
IgniteEvents.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this projection 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 projection.
|
Modifier and Type | Method and Description |
---|---|
ClusterGroup |
ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
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 |
IgniteConfiguration.setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)
Sets map of pre-configured local event listeners.
|
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 | 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.
|
Constructor and Description |
---|
StreamerRandomEventRouter(IgnitePredicate<ClusterNode>... predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
Constructor and Description |
---|
StreamerRandomEventRouter(Collection<IgnitePredicate<ClusterNode>> predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
Modifier and Type | Method and Description |
---|---|
IgnitePredicate<Object> |
StreamerWindowAdapter.getFilter()
Gets optional event filter.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamerWindowAdapter.setFilter(IgnitePredicate<Object> filter)
Sets event filter.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015