Package | Description |
---|---|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
com.hazelcast.client.spi.impl |
Provides util classes for the Hazelcast client SPI.
|
com.hazelcast.cluster.memberselector |
This package contains several
MemberSelector implementations. |
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.executor.impl |
This package contains IExecutorService functionality for Hazelcast.
The IExecutorService extends the ExecutorService and provides all kinds
of additional methods related to distributed systems. |
com.hazelcast.internal.cluster |
Contains the internals for cluster management like discovery, joining etc.
|
com.hazelcast.internal.cluster.impl |
This package contains the implementation of the cluster functionality.
|
com.hazelcast.mapreduce.impl.operation |
This package contains all remote operations that are needed to control work on
supervising or worker nodes.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientExecutorServiceProxy.execute(Runnable command,
MemberSelector memberSelector) |
void |
ClientExecutorServiceProxy.executeOnMembers(Runnable command,
MemberSelector memberSelector) |
<T> Future<T> |
ClientExecutorServiceProxy.submit(Callable<T> task,
MemberSelector memberSelector) |
<T> void |
ClientExecutorServiceProxy.submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback) |
void |
ClientExecutorServiceProxy.submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback callback) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector) |
<T> void |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector,
MultiExecutionCallback callback) |
void |
ClientExecutorServiceProxy.submitToMembers(Runnable task,
MemberSelector memberSelector,
MultiExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClientClusterService.getMembers(MemberSelector selector)
Returns a collection of the members that satisfy the given
MemberSelector . |
int |
ClientClusterService.getSize(MemberSelector selector)
Gets the number of members that satisfy the given
MemberSelector instance. |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClientClusterServiceImpl.getMembers(MemberSelector selector) |
int |
ClientClusterServiceImpl.getSize(MemberSelector selector) |
Modifier and Type | Field and Description |
---|---|
static MemberSelector |
MemberSelectors.DATA_MEMBER_SELECTOR
A
MemberSelector instance that selects only data members that own a partition |
static MemberSelector |
MemberSelectors.LITE_MEMBER_SELECTOR
A
MemberSelector instance that selects only lite members that own no partition |
static MemberSelector |
MemberSelectors.LOCAL_MEMBER_SELECTOR
A
MemberSelector instance that selects only local members |
static MemberSelector |
MemberSelectors.NON_LOCAL_MEMBER_SELECTOR
A
MemberSelector instance that selects only remote members |
Modifier and Type | Method and Description |
---|---|
static MemberSelector |
MemberSelectors.and(MemberSelector... selectors)
Selects a member when all of the selectors succeed
|
static MemberSelector |
MemberSelectors.or(MemberSelector... selectors)
Selects a member when one of the selectors succeed
|
Modifier and Type | Method and Description |
---|---|
static MemberSelector |
MemberSelectors.and(MemberSelector... selectors)
Selects a member when all of the selectors succeed
|
static MemberSelector |
MemberSelectors.or(MemberSelector... selectors)
Selects a member when one of the selectors succeed
|
Modifier and Type | Method and Description |
---|---|
void |
IExecutorService.execute(Runnable command,
MemberSelector memberSelector)
Executes a task on a randomly selected member.
|
void |
IExecutorService.executeOnMembers(Runnable command,
MemberSelector memberSelector)
Executes a task on each of the selected members.
|
<T> Future<T> |
IExecutorService.submit(Callable<T> task,
MemberSelector memberSelector)
Submits a task to a randomly selected member and returns a Future
representing that task.
|
<T> void |
IExecutorService.submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback)
Submits task to a randomly selected member.
|
<T> void |
IExecutorService.submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback<T> callback)
Submits a task to randomly selected members.
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToMembers(Callable<T> task,
MemberSelector memberSelector)
Submits a task to selected members and returns a
map of Member-Future pairs representing pending completion of the task on each member.
|
<T> void |
IExecutorService.submitToMembers(Callable<T> task,
MemberSelector memberSelector,
MultiExecutionCallback callback)
Submits task to the selected members.
|
void |
IExecutorService.submitToMembers(Runnable task,
MemberSelector memberSelector,
MultiExecutionCallback callback)
Submits task to the selected members.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutorServiceProxy.execute(Runnable command,
MemberSelector memberSelector) |
void |
ExecutorServiceProxy.executeOnMembers(Runnable command,
MemberSelector memberSelector) |
<T> Future<T> |
ExecutorServiceProxy.submit(Callable<T> task,
MemberSelector memberSelector) |
<T> void |
ExecutorServiceProxy.submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback) |
void |
ExecutorServiceProxy.submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback callback) |
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector) |
<T> void |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector,
MultiExecutionCallback callback) |
void |
ExecutorServiceProxy.submitToMembers(Runnable task,
MemberSelector memberSelector,
MultiExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClusterService.getMembers(MemberSelector selector)
Returns a collection of the members that satisfy the given
MemberSelector . |
int |
ClusterService.getSize(MemberSelector selector)
Gets the number of members that satisfy the given
MemberSelector instance. |
Modifier and Type | Method and Description |
---|---|
static <M extends Member> |
MemberSelectingCollection.count(Collection<M> members,
MemberSelector memberSelector) |
Collection<Member> |
ClusterServiceImpl.getMembers(MemberSelector selector) |
int |
ClusterServiceImpl.getSize(MemberSelector selector) |
Constructor and Description |
---|
MemberSelectingCollection(Collection<M> members,
MemberSelector selector) |
Modifier and Type | Field and Description |
---|---|
static MemberSelector |
KeyValueJobOperation.MEMBER_SELECTOR
Selects members that will run this operation
|
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.