Package | Description |
---|---|
com.hazelcast.client |
Contains classes/interfaces related to Client
|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
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.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.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.management |
Contains classes to provide data/operation interface for Management Center.
|
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.partition |
Contains the partition logic for Hazelcast.
|
com.hazelcast.partition.membergroup |
todo
|
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 |
---|---|
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 |
---|---|
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 |
---|---|
Member |
ClusterProxy.getLocalMember() |
Member |
ClusterServiceImpl.getLocalMember() |
Modifier and Type | Method and Description |
---|---|
Set<Member> |
ClusterProxy.getMembers() |
Set<Member> |
ClusterServiceImpl.getMembers() |
Collection<Member> |
ClusterService.getMembers() |
Modifier and Type | Method and Description |
---|---|
Member |
ClientMembershipEvent.getMember()
Returns the removed or added member.
|
Constructor and Description |
---|
ClientMembershipEvent(Member member,
int eventType) |
ClientMembershipEvent(Member member,
MemberAttributeChange memberAttributeChange) |
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 fired this event.
|
Member |
MembershipEvent.getMember()
Returns the removed or added member.
|
Member |
MemberAttributeEvent.getMember() |
Member |
AbstractIMapEvent.getMember()
Returns the member fired this event.
|
Member |
MemberLeftException.getMember()
Returns the member which left the cluster
|
Member |
IMapEvent.getMember()
Returns the member 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 owner member of the 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 exactly 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 current members of the cluster.
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToAllMembers(Callable<T> task)
Submits task to all cluster 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,
Collection<Member> members)
Submits 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 task to selected members and returns
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 task on the specified member
|
boolean |
PartitionService.isMemberSafe(Member member)
Check if the given member is safe to shutdown, means check if 1st backups of partitions
those owned by given member are 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 for the given member to be part of an operation or not.
|
<T> Future<T> |
IExecutorService.submitToMember(Callable<T> task,
Member member)
Submits task to specified member and returns a Future
representing that task.
|
<T> void |
IExecutorService.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback)
Submits task to the specified member.
|
void |
IExecutorService.submitToMember(Runnable task,
Member member,
ExecutionCallback callback)
Submits task to the specified member.
|
Modifier and Type | Method and Description |
---|---|
void |
IExecutorService.executeOnMembers(Runnable command,
Collection<Member> members)
Executes 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 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 task to the specified members.
|
void |
IExecutorService.submitToMembers(Runnable task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits task to the specified members.
|
Constructor and Description |
---|
AbstractIMapEvent(Object source,
Member member,
int eventType)
Constructs a prototypical Event.
|
EntryEvent(Object source,
Member member,
int eventType,
K key,
V value) |
EntryEvent(Object source,
Member member,
int eventType,
K key,
V oldValue,
V value) |
ItemEvent(String name,
ItemEventType itemEventType,
E item,
Member member) |
MapEvent(Object source,
Member member,
int eventType,
int numberOfEntriesAffected) |
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 |
MemberImpl |
Modifier and Type | Method and Description |
---|---|
Member |
HazelcastInstanceImpl.getLocalEndpoint() |
Member |
HazelcastInstanceProxy.getLocalEndpoint() |
Modifier and Type | Method and Description |
---|---|
Member |
LogEvent.getMember() |
Constructor and Description |
---|
LogEvent(LogRecord logRecord,
String groupName,
Member member) |
Modifier and Type | Method and Description |
---|---|
Object |
ManagementCenterService.callOnMember(Member member,
Operation operation) |
Constructor and Description |
---|
DataAwareEntryEvent(Member from,
int eventType,
String source,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
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.