Package | Description |
---|---|
com.hazelcast.client |
Contains classes/interfaces related to Client
|
com.hazelcast.client.impl.protocol.codec |
Client protocol custom codec implementations
|
com.hazelcast.client.impl.protocol.template | |
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 Service Provider Interface
such as ClientProxy , ClientClusterService
|
com.hazelcast.client.spi.impl |
Provides util classes for com.hazelcast.client
|
com.hazelcast.client.util |
This package contains some utility classes and the base implementations of the
loadbalancer implementations
|
com.hazelcast.cluster |
This package contains the cluster functionality.
|
com.hazelcast.cluster.client |
This package contains the client cluster functionality.
|
com.hazelcast.cluster.impl |
This package contains the implementation of the cluster functionality.
|
com.hazelcast.collection.common |
This package contains common classes related to all collections
|
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.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.internal.management |
Contains classes to provide data/operation interface for Management Center.
|
com.hazelcast.logging |
This package contains logging functionality for Hazelcast.
Since Hazelcast has a zero dependency policy, Hazelcast provides a logging abstraction like commongs logging, so that different logging frameworks like log4j, can be hooked in. |
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.partition |
Contains the partition logic for Hazelcast.
|
com.hazelcast.partition.membergroup |
todo
|
com.hazelcast.quorum |
Contains classes related to cluster quorum.
|
com.hazelcast.quorum.impl |
Contains cluster quorum implementation classes.
|
com.hazelcast.replicatedmap.impl.messages |
This package contains replication event classes to communicate replications to other nodes
|
com.hazelcast.replicatedmap.impl.operation |
This package contains some remote operations to execute on remote nodes
|
com.hazelcast.replicatedmap.impl.record |
This package contains the implementation of the backing data storage for the replicated map implementation
|
com.hazelcast.topic.impl |
This package contains ITopic functionality for Hazelcast.
With the ITopic it is possible to create publish subscribe solutions similar to JMS Topics. |
Modifier and Type | Method and Description |
---|---|
Member |
LoadBalancer.next()
Returns the next member to route to.
|
Modifier and Type | Method and Description |
---|---|
static Member |
MemberCodec.decode(ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
static int |
MemberCodec.calculateDataSize(Member member) |
static void |
MemberCodec.encode(Member member,
ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
void |
EventResponseTemplate.Member(Member member,
int eventType) |
Modifier and Type | Method and Description |
---|---|
void |
EventResponseTemplate.MemberList(Collection<Member> members) |
Modifier and Type | Method and Description |
---|---|
Member |
ClientClusterProxy.getLocalMember() |
Modifier and Type | Method and Description |
---|---|
Set<Member> |
ClientClusterProxy.getMembers() |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToAllMembers(Callable<T> task) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector) |
Modifier and Type | Method and Description |
---|---|
void |
ClientExecutorServiceProxy.executeOnMember(Runnable command,
Member member) |
boolean |
PartitionServiceProxy.isMemberSafe(Member member) |
<T> Future<T> |
ClientExecutorServiceProxy.submitToMember(Callable<T> task,
Member member) |
<T> void |
ClientExecutorServiceProxy.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback) |
void |
ClientExecutorServiceProxy.submitToMember(Runnable command,
Member member,
ExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
ClientExecutorServiceProxy.executeOnMembers(Runnable command,
Collection<Member> members) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> void |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback) |
void |
ClientExecutorServiceProxy.submitToMembers(Runnable command,
Collection<Member> members,
MultiExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
Member |
ClientClusterService.getMember(Address address)
Gets the member for the given address.
|
Member |
ClientClusterService.getMember(String uuid)
Gets the member with the given uuid.
|
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClientClusterService.getMemberList()
Gets the collection of members.
|
Modifier and Type | Method and Description |
---|---|
Member |
ClientClusterServiceImpl.getMember(Address address) |
Member |
ClientClusterServiceImpl.getMember(String uuid) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClientClusterServiceImpl.getMemberList() |
Modifier and Type | Method and Description |
---|---|
protected Member[] |
AbstractLoadBalancer.getMembers() |
Member |
RoundRobinLB.next() |
Member |
RandomLB.next() |
Member |
StaticLB.next() |
Constructor and Description |
---|
StaticLB(Member member) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClusterService.getMembers()
Returns a collection of all members part of the cluster.
|
Modifier and Type | Method and Description |
---|---|
Member |
ClientMembershipEvent.getMember()
Returns the removed or added member.
|
Member |
ClientInitialMembershipEvent.getMember()
Returns the removed or added member.
|
Constructor and Description |
---|
ClientInitialMembershipEvent(Member member,
int eventType) |
ClientInitialMembershipEvent(Member member,
MemberAttributeChange memberAttributeChange) |
ClientMembershipEvent(Member member,
int eventType) |
ClientMembershipEvent(Member member,
MemberAttributeChange memberAttributeChange) |
Modifier and Type | Method and Description |
---|---|
Member |
ClusterProxy.getLocalMember() |
Member |
ClusterServiceImpl.getLocalMember() |
Modifier and Type | Method and Description |
---|---|
Set<Member> |
ClusterProxy.getMembers() |
Set<Member> |
ClusterServiceImpl.getMembers() |
Constructor and Description |
---|
DataAwareItemEvent(String name,
ItemEventType itemEventType,
Data dataItem,
Member member,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
Member |
Cluster.getLocalMember()
Returns this Hazelcast instance member.
|
Member |
ItemEvent.getMember()
Returns the member that fired this event.
|
Member |
MembershipEvent.getMember()
Returns the removed or added member.
|
Member |
MemberAttributeEvent.getMember() |
Member |
AbstractIMapEvent.getMember()
Returns the member that fired this event.
|
Member |
MemberLeftException.getMember()
Returns the member that left the cluster
|
Member |
IMapEvent.getMember()
Returns the member that fired this event.
|
Member |
MigrationEvent.getNewOwner()
Returns the new owner of the migrating partition
|
Member |
MigrationEvent.getOldOwner()
Returns the old owner of the migrating partition
|
Member |
Partition.getOwner()
Returns the current member that owns this partition.
|
Member |
Message.getPublishingMember()
Returns the member that published the message
|
Modifier and Type | Method and Description |
---|---|
Set<Member> |
MembershipEvent.getMembers()
Returns a consistent view of the the members immediately after this MembershipEvent has been processed.
|
Set<Member> |
InitialMembershipEvent.getMembers()
Returns an immutable set of ordered members at the moment this
InitialMembershipListener is
registered. |
Set<Member> |
Cluster.getMembers()
Set of the current members in the cluster.
|
<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.
|
boolean |
PartitionService.isMemberSafe(Member member)
Check if the given member is safe to shutdown, meaning check if at least one backup of the partitions
owned by the given member are in sync with primary.
|
void |
MultiExecutionCallback.onResponse(Member member,
Object value)
Called when an execution is completed on a member.
|
boolean |
MemberSelector.select(Member member)
Decides if the given member will be part of an operation or not.
|
<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 |
---|
AbstractIMapEvent(Object source,
Member member,
int eventType)
Constructs a prototypical map Event.
|
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.
|
ItemEvent(String name,
ItemEventType itemEventType,
E item,
Member member) |
MapEvent(Object source,
Member member,
int eventType,
int numberOfEntriesAffected) |
MemberAttributeEvent(Cluster cluster,
Member member,
MemberAttributeOperationType operationType,
String key,
Object value) |
MemberLeftException(Member member) |
MembershipEvent(Cluster cluster,
Member member,
int eventType,
Set<Member> members) |
Message(String topicName,
E messageObject,
long publishTime,
Member publishingMember) |
MigrationEvent(int partitionId,
Member oldOwner,
Member newOwner,
MigrationEvent.MigrationStatus status) |
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 |
---|---|
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToAllMembers(Callable<T> task) |
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorServiceProxy.executeOnMember(Runnable command,
Member member) |
<T> Future<T> |
ExecutorServiceProxy.submitToMember(Callable<T> task,
Member member) |
<T> void |
ExecutorServiceProxy.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback) |
void |
ExecutorServiceProxy.submitToMember(Runnable task,
Member member,
ExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorServiceProxy.executeOnMembers(Runnable command,
Collection<Member> members) |
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> void |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback) |
void |
ExecutorServiceProxy.submitToMembers(Runnable task,
Collection<Member> members,
MultiExecutionCallback callback) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMember |
class |
MemberImpl |
Modifier and Type | Method and Description |
---|---|
Member |
HazelcastInstanceImpl.getLocalEndpoint() |
Member |
HazelcastInstanceProxy.getLocalEndpoint() |
Modifier and Type | Method and Description |
---|---|
Object |
ManagementCenterService.callOnMember(Member member,
Operation operation) |
Modifier and Type | Method and Description |
---|---|
Member |
LogEvent.getMember() |
Constructor and Description |
---|
LogEvent(LogRecord logRecord,
Member member) |
Constructor and Description |
---|
MapPartitionLostEvent(Object source,
Member member,
int eventType,
int partitionId) |
Constructor and Description |
---|
DataAwareEntryEvent(Member from,
int eventType,
String source,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
Data dataMergingValue,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
Member |
InternalPartitionService.getMember(Address address) |
Member |
PartitionServiceProxy.PartitionProxy.getOwner() |
Modifier and Type | Method and Description |
---|---|
boolean |
PartitionServiceProxy.isMemberSafe(Member member) |
Modifier and Type | Method and Description |
---|---|
Set<Member> |
DefaultMemberGroup.getMembers() |
Iterator<Member> |
DefaultMemberGroup.iterator() |
Iterator<Member> |
MemberGroup.iterator() |
Iterator<Member> |
SingleMemberGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMemberGroup.addMember(Member member) |
void |
MemberGroup.addMember(Member member) |
void |
SingleMemberGroup.addMember(Member member) |
boolean |
DefaultMemberGroup.hasMember(Member member) |
boolean |
MemberGroup.hasMember(Member member) |
boolean |
SingleMemberGroup.hasMember(Member member) |
void |
DefaultMemberGroup.removeMember(Member member) |
void |
MemberGroup.removeMember(Member member) |
void |
SingleMemberGroup.removeMember(Member member) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMemberGroup.addMembers(Collection<Member> members) |
void |
MemberGroup.addMembers(Collection<Member> members) |
void |
SingleMemberGroup.addMembers(Collection<Member> members) |
protected Set<MemberGroup> |
HostAwareMemberGroupFactory.createInternalMemberGroups(Collection<? extends Member> allMembers) |
protected Set<MemberGroup> |
ConfigMemberGroupFactory.createInternalMemberGroups(Collection<? extends Member> members) |
Collection<MemberGroup> |
MemberGroupFactory.createMemberGroups(Collection<? extends Member> members) |
Set<MemberGroup> |
SingleMemberGroupFactory.createMemberGroups(Collection<? extends Member> members) |
Constructor and Description |
---|
SingleMemberGroup(Member member) |
Constructor and Description |
---|
DefaultMemberGroup(Collection<Member> members) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
QuorumEvent.getCurrentMembers()
Returns the snapshot of member list at the time quorum happened
|
Modifier and Type | Method and Description |
---|---|
boolean |
QuorumFunction.apply(Collection<Member> members)
Determines if quorum is present based on the member-list.
|
Constructor and Description |
---|
QuorumEvent(Object source,
int threshold,
Collection<Member> currentMembers,
boolean presence) |
Modifier and Type | Method and Description |
---|---|
void |
QuorumImpl.update(Collection<Member> members) |
Modifier and Type | Method and Description |
---|---|
Member |
ReplicationMessage.getOrigin() |
Constructor and Description |
---|
ReplicationMessage(String name,
K key,
V v,
VectorClockTimestamp timestamp,
Member origin,
int hash,
long ttlMillis) |
Modifier and Type | Method and Description |
---|---|
Member |
ReplicatedMapPostJoinOperation.MemberMapPair.getMember() |
Constructor and Description |
---|
ReplicatedMapInitChunkOperation(String name,
Member origin) |
ReplicatedMapInitChunkOperation(String name,
Member origin,
ReplicatedRecord[] replicatedRecords,
int recordCount,
boolean finalChunk) |
ReplicatedMapPostJoinOperation.MemberMapPair(Member member,
String name) |
Modifier and Type | Method and Description |
---|---|
VectorClockTimestamp |
ReplicatedRecord.applyAndIncrementVectorClock(VectorClockTimestamp otherVectorClockTimestamp,
Member member) |
VectorClockTimestamp |
ReplicatedRecord.incrementVectorClock(Member member) |
void |
ReplicationPublisher.retryWithDifferentReplicationNode(Member member) |
Constructor and Description |
---|
DataAwareMessage(String topicName,
Data messageData,
long publishTime,
Member publishingMember,
SerializationService serializationService) |
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.