Package | Description |
---|---|
com.hazelcast.client |
Contains classes/interfaces related to Client
|
com.hazelcast.cluster |
This package contains the cluster functionality.
|
com.hazelcast.collection |
This package contains classes to support the collection API.
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.logging |
This package contains logging functionality for Hazelcast.
Since Hazelcast has a zero dependency policy, Hazelcast provides a logging abstraction like commons logging, so that different logging frameworks like log4j, can be hooked in. |
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.partition |
Contains the partition logic for Hazelcast.
|
com.hazelcast.scheduledexecutor |
This package contains ScheduledExecutorService functionality for Hazelcast.
|
com.hazelcast.spi.exception |
Contains exceptions for Hazelcast SPI.
|
com.hazelcast.spi.partitiongroup |
This package contains the basic SPI for the Partition Group SPI to define
or configure how Hazelcast will configure and distribute backups in the
cluster.
|
com.hazelcast.splitbrainprotection |
Contains classes related to cluster split brain protection.
|
com.hazelcast.topic |
Contains the API for the
ITopic . |
Modifier and Type | Method and Description |
---|---|
Member |
LoadBalancer.next()
Returns the next member to route to.
|
default Member |
LoadBalancer.nextDataMember()
Returns the next data member to route to.
|
Modifier and Type | Field and Description |
---|---|
protected Member |
MembershipEvent.member |
Modifier and Type | Field and Description |
---|---|
protected Set<Member> |
MembershipEvent.members |
Modifier and Type | Method and Description |
---|---|
Member |
Cluster.getLocalMember()
Returns this Hazelcast instance member.
|
Member |
MembershipEvent.getMember()
Returns the removed or added member.
|
Modifier and Type | Method and Description |
---|---|
Set<Member> |
InitialMembershipEvent.getMembers()
Returns an immutable set of ordered members at the moment this
InitialMembershipListener is
registered. |
Set<Member> |
MembershipEvent.getMembers()
Returns a consistent view of the the members immediately after this MembershipEvent has been processed.
|
Set<Member> |
Cluster.getMembers()
Set of the current members in the cluster.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MemberSelector.select(Member member)
Decides if the given member will be part of an operation or not.
|
Constructor and Description |
---|
MembershipEvent(Cluster cluster,
Member member,
int eventType,
Set<Member> members) |
Constructor and Description |
---|
InitialMembershipEvent(Cluster cluster,
Set<Member> members) |
MembershipEvent(Cluster cluster,
Member member,
int eventType,
Set<Member> members) |
Modifier and Type | Method and Description |
---|---|
Member |
ItemEvent.getMember()
Returns the member that fired this event.
|
Constructor and Description |
---|
ItemEvent(String name,
ItemEventType itemEventType,
E item,
Member member) |
Modifier and Type | Method and Description |
---|---|
Member |
MemberLeftException.getMember()
Returns the member that left the cluster
|
Modifier and Type | Method and Description |
---|---|
<T> Map<Member,Future<T>> |
IExecutorService.submitToAllMembers(Callable<T> task)
Submits task to all cluster members and returns a
map of Member-Future pairs representing pending completion of the task on each member.
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToMembers(Callable<T> task,
Collection<Member> members)
Submits a task to given members and returns
map of Member-Future pairs representing pending completion of the task on each member
|
<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.
|
Modifier and Type | Method and Description |
---|---|
void |
IExecutorService.executeOnMember(Runnable command,
Member member)
Executes a task on the specified member.
|
void |
MultiExecutionCallback.onResponse(Member member,
Object value)
Called when an execution is completed on a member.
|
<T> Future<T> |
IExecutorService.submitToMember(Callable<T> task,
Member member)
Submits a task to the specified member and returns a Future
representing that task.
|
<T> void |
IExecutorService.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback)
Submits a task to the specified member.
|
<T> void |
IExecutorService.submitToMember(Runnable task,
Member member,
ExecutionCallback<T> callback)
Submits a task to the specified member.
|
Modifier and Type | Method and Description |
---|---|
void |
IExecutorService.executeOnMembers(Runnable command,
Collection<Member> members)
Executes a task on each of the specified members.
|
void |
MultiExecutionCallback.onComplete(Map<Member,Object> values)
Called after all executions are completed.
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToMembers(Callable<T> task,
Collection<Member> members)
Submits a task to given members and returns
map of Member-Future pairs representing pending completion of the task on each member
|
<T> void |
IExecutorService.submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits a task to the specified members.
|
void |
IExecutorService.submitToMembers(Runnable task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits a task to the specified members.
|
Constructor and Description |
---|
EntryEvent(Object source,
Member member,
int eventType,
K key,
V value)
Constructs an entry event.
|
EntryEvent(Object source,
Member member,
int eventType,
K key,
V oldValue,
V value)
Constructs an entry event.
|
EntryEvent(Object source,
Member member,
int eventType,
K key,
V oldValue,
V value,
V mergingValue)
Constructs an entry event.
|
MemberLeftException(Member member) |
Modifier and Type | Method and Description |
---|---|
Member |
LogEvent.getMember() |
Constructor and Description |
---|
LogEvent(LogRecord logRecord,
Member member) |
Modifier and Type | Method and Description |
---|---|
Member |
EventLostEvent.getMember() |
Member |
IMapEvent.getMember()
Returns the member that fired this event.
|
Member |
AbstractIMapEvent.getMember()
Returns the member that fired this event.
|
Constructor and Description |
---|
AbstractIMapEvent(Object source,
Member member,
int eventType)
Constructs a prototypical map Event.
|
EventLostEvent(String source,
Member member,
int partitionId) |
MapEvent(Object source,
Member member,
int eventType,
int numberOfEntriesAffected) |
MapPartitionLostEvent(Object source,
Member member,
int eventType,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
Member |
ReplicaMigrationEvent.getDestination()
Returns the new owner of the migrating partition replica.
|
Member |
Partition.getOwner()
Returns the current member that owns this partition.
|
Member |
ReplicaMigrationEvent.getSource()
Returns the old owner of the migrating partition replica.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PartitionService.isMemberSafe(Member member)
Checks whether the given member is in safe state.
|
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,List<IScheduledFuture<V>>> |
IScheduledExecutorService.getAllScheduledFutures()
Fetches and returns all scheduled (not disposed yet) futures from all
members in the cluster.
|
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnAllMembers(Callable<V> command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay on all cluster
Member s. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnAllMembers(Runnable command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay on all cluster
Member s. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnAllMembersAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after
the given initial delay, and subsequently with the given period on all
cluster
Member s. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay on all
Member s given. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay on all
Member s given. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after
the given initial delay, and subsequently with the given period on all
Member s given. |
Modifier and Type | Method and Description |
---|---|
<V> IScheduledFuture<V> |
IScheduledExecutorService.scheduleOnMember(Callable<V> command,
Member member,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay at the given
Member . |
<V> IScheduledFuture<V> |
IScheduledExecutorService.scheduleOnMember(Runnable command,
Member member,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay at the given
Member . |
<V> IScheduledFuture<V> |
IScheduledExecutorService.scheduleOnMemberAtFixedRate(Runnable command,
Member member,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after
the given initial delay, and subsequently with the given period at the
given
Member . |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay on all
Member s given. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the
given delay on all
Member s given. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after
the given initial delay, and subsequently with the given period on all
Member s given. |
Modifier and Type | Method and Description |
---|---|
Member |
WrongTargetException.getTarget() |
Constructor and Description |
---|
WrongTargetException(Member localMember,
Member target,
int partitionId,
int replicaIndex,
String operationName) |
WrongTargetException(Member localMember,
Member target,
int partitionId,
int replicaIndex,
String operationName,
String serviceName) |
Modifier and Type | Method and Description |
---|---|
Iterator<Member> |
MemberGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
MemberGroup.addMember(Member member) |
boolean |
MemberGroup.hasMember(Member member) |
void |
MemberGroup.removeMember(Member member) |
Modifier and Type | Method and Description |
---|---|
void |
MemberGroup.addMembers(Collection<Member> members) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
SplitBrainProtectionEvent.getCurrentMembers()
Returns the snapshot of member list at the time split brain protection happened
|
Modifier and Type | Method and Description |
---|---|
void |
HeartbeatAware.onHeartbeat(Member member,
long timestamp)
Notifies of a received heartbeat.
|
void |
PingAware.onPingLost(Member member)
Notifies the
SplitBrainProtectionFunction of ping loss. |
void |
PingAware.onPingRestored(Member member)
Notifies the
SplitBrainProtectionFunction of a successful ping after one or more pings to that member were lost. |
Modifier and Type | Method and Description |
---|---|
boolean |
SplitBrainProtectionFunction.apply(Collection<Member> members)
Determines whether the minimum cluster size property is satisfied based on the current list of members
in the cluster.
|
Constructor and Description |
---|
SplitBrainProtectionEvent(Object source,
int threshold,
Collection<Member> currentMembers,
boolean presence) |
Modifier and Type | Method and Description |
---|---|
Member |
Message.getPublishingMember()
Returns the member that published the message.
|
Constructor and Description |
---|
Message(String topicName,
E messageObject,
long publishTime,
Member publishingMember) |
Copyright © 2020 Hazelcast, Inc.. All rights reserved.