| Package | Description |
|---|---|
| com.hazelcast.client |
This package contains the serverside client functionality
|
| com.hazelcast.cluster | |
| com.hazelcast.collection | |
| com.hazelcast.collection.client | |
| com.hazelcast.collection.list | |
| com.hazelcast.collection.set | |
| com.hazelcast.collection.txn | |
| com.hazelcast.concurrent.atomiclong |
This package contains IAtomicLong functionality for Hazelcast.
The IAtomicLong is the distributed version of the AtomicLong. |
| com.hazelcast.concurrent.atomiclong.client |
This package contains client requests for the IAtomicLong.
This package contains all the client requests object to operate on the IAtomicLong that are send by the client. |
| com.hazelcast.concurrent.atomiclong.operations |
This package contains the operations on the IAtomicLong.
|
| com.hazelcast.concurrent.atomicreference |
This package contains IAtomicReferece functionality for Hazelcast.
The IAtomicReference is the distributed version of the AtomicReference. |
| com.hazelcast.concurrent.atomicreference.client |
This package contains client requests for the IAtomicLong.
This package contains all the client requests object to operate on the IAtomicLong that are send by the client. |
| com.hazelcast.concurrent.atomicreference.operations |
This package contains the operations on the IAtomicReference.
|
| com.hazelcast.concurrent.countdownlatch |
This package contains ICountDownLatch functionality for Hazelcast.
The ICountDownLatch is the distributed version of the CountDownLatch. |
| com.hazelcast.concurrent.countdownlatch.client |
This package contains client requests for the ICountDownLatch.
This package contains all the client requests object to operate on the ICountDownLatch that are send by the client. |
| com.hazelcast.concurrent.countdownlatch.operations |
This package contains the operations on the ICountDownLatch.
|
| com.hazelcast.concurrent.lock | |
| com.hazelcast.concurrent.lock.client |
This package contains client requests for the ILock.
This package contains all the client requests object to operate on the ILock that are send by the client. |
| com.hazelcast.concurrent.lock.operations |
This package contains the operations on the ILock.
|
| com.hazelcast.concurrent.semaphore |
This package contains ISemaphore functionality for Hazelcast.
The ISemaphore is the distributed version of the Semaphore. |
| com.hazelcast.concurrent.semaphore.client |
This package contains client requests for the ISemaphore.
|
| com.hazelcast.concurrent.semaphore.operations |
This package contains the operations on the ISemaphore.
|
| com.hazelcast.executor |
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.executor.client |
This package contains client requests for the IExecutorService.
|
| com.hazelcast.management | |
| com.hazelcast.management.operation | |
| com.hazelcast.map |
Contains Hazelcast map module classes.
|
| com.hazelcast.map.client | |
| com.hazelcast.map.operation | |
| com.hazelcast.map.proxy | |
| com.hazelcast.map.tx | |
| com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
| com.hazelcast.mapreduce.impl.operation |
This package contains all remote operations that are needed to control work on
supervising or worker nodes.
|
| com.hazelcast.multimap | |
| com.hazelcast.multimap.operations | |
| com.hazelcast.multimap.operations.client | |
| com.hazelcast.multimap.txn | |
| com.hazelcast.partition.impl |
Contains the actual implementation of the
InternalPartitionService. |
| com.hazelcast.queue | |
| com.hazelcast.queue.client | |
| com.hazelcast.queue.tx | |
| com.hazelcast.spi |
Provides interfaces/classes for Hazelcast SPI.
|
| com.hazelcast.spi.impl | |
| com.hazelcast.topic |
This package contains ITopic functionality for Hazelcast.
With the ITopic it is possible to create publish subscribe solutions similar to JMS Topics. |
| com.hazelcast.topic.client |
This package contains client requests for the ITopic.
|
| com.hazelcast.transaction.impl |
| Modifier and Type | Class and Description |
|---|---|
class |
ClientDisconnectionOperation |
class |
ClientReAuthOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
OperationFactoryWrapper.createOperation() |
protected abstract Operation |
PartitionClientRequest.prepareOperation() |
protected abstract Operation |
TargetClientRequest.prepareOperation() |
| Modifier and Type | Method and Description |
|---|---|
protected InvocationBuilder |
InvocationClientRequest.createInvocationBuilder(String serviceName,
Operation op,
Address target) |
protected InvocationBuilder |
InvocationClientRequest.createInvocationBuilder(String serviceName,
Operation op,
int partitionId) |
| Modifier and Type | Class and Description |
|---|---|
class |
AuthenticationFailureOperation |
class |
AuthorizationOperation |
class |
BindOperation |
class |
FinalizeJoinOperation |
class |
HeartbeatOperation |
class |
JoinCheckOperation |
class |
JoinRequestOperation |
class |
MasterConfirmationOperation |
class |
MemberAttributeChangedOperation |
class |
MemberInfoUpdateOperation |
class |
MemberRemoveOperation |
class |
MergeClustersOperation |
class |
PostJoinOperation |
class |
PrepareMergeOperation |
class |
SetMasterOperation |
static class |
TcpIpJoiner.MasterClaim |
| Constructor and Description |
|---|
PostJoinOperation(Operation... ops) |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionAddAllBackupOperation |
class |
CollectionAddAllOperation |
class |
CollectionAddBackupOperation |
class |
CollectionAddOperation |
class |
CollectionBackupAwareOperation |
class |
CollectionClearBackupOperation |
class |
CollectionClearOperation |
class |
CollectionCompareAndRemoveOperation |
class |
CollectionContainsOperation |
class |
CollectionGetAllOperation |
class |
CollectionOperation |
class |
CollectionRemoveBackupOperation |
class |
CollectionRemoveOperation |
class |
CollectionReplicationOperation |
class |
CollectionSizeOperation |
class |
CollectionTransactionRollbackOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
CollectionAddAllOperation.getBackupOperation() |
Operation |
CollectionCompareAndRemoveOperation.getBackupOperation() |
Operation |
CollectionAddOperation.getBackupOperation() |
Operation |
CollectionRemoveOperation.getBackupOperation() |
Operation |
CollectionClearOperation.getBackupOperation() |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
CollectionContainsRequest.prepareOperation() |
protected Operation |
CollectionGetAllRequest.prepareOperation() |
protected Operation |
CollectionCompareAndRemoveRequest.prepareOperation() |
protected Operation |
CollectionClearRequest.prepareOperation() |
protected Operation |
ListSetRequest.prepareOperation() |
protected Operation |
ListIndexOfRequest.prepareOperation() |
protected Operation |
ListRemoveRequest.prepareOperation() |
protected Operation |
ListAddRequest.prepareOperation() |
protected Operation |
CollectionAddRequest.prepareOperation() |
protected Operation |
CollectionSizeRequest.prepareOperation() |
protected Operation |
CollectionAddAllRequest.prepareOperation() |
protected Operation |
ListGetRequest.prepareOperation() |
protected Operation |
CollectionRemoveRequest.prepareOperation() |
protected Operation |
ListSubRequest.prepareOperation() |
protected Operation |
ListAddAllRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
ListAddAllOperation |
class |
ListAddOperation |
class |
ListGetOperation |
class |
ListIndexOfOperation |
class |
ListRemoveOperation |
class |
ListReplicationOperation |
class |
ListSetBackupOperation |
class |
ListSetOperation |
class |
ListSubOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
ListSetOperation.getBackupOperation() |
Operation |
ListRemoveOperation.getBackupOperation() |
Operation |
ListAddOperation.getBackupOperation() |
Operation |
ListService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Class and Description |
|---|---|
class |
SetReplicationOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
SetService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionPrepareBackupOperation |
class |
CollectionPrepareOperation |
class |
CollectionReserveAddOperation |
class |
CollectionReserveRemoveOperation |
class |
CollectionRollbackBackupOperation |
class |
CollectionRollbackOperation |
class |
CollectionTxnAddBackupOperation |
class |
CollectionTxnAddOperation |
class |
CollectionTxnRemoveBackupOperation |
class |
CollectionTxnRemoveOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
CollectionRollbackOperation.getBackupOperation() |
Operation |
CollectionTxnAddOperation.getBackupOperation() |
Operation |
CollectionPrepareOperation.getBackupOperation() |
Operation |
CollectionTxnRemoveOperation.getBackupOperation() |
| Constructor and Description |
|---|
CollectionTransactionLog(long itemId,
String name,
int partitionId,
String serviceName,
String transactionId,
Operation op) |
| Modifier and Type | Method and Description |
|---|---|
Operation |
AtomicLongService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
SetRequest.prepareOperation() |
protected Operation |
AddAndGetRequest.prepareOperation() |
protected Operation |
ApplyRequest.prepareOperation() |
protected Operation |
CompareAndSetRequest.prepareOperation() |
protected Operation |
GetAndAddRequest.prepareOperation() |
protected Operation |
AlterAndGetRequest.prepareOperation() |
protected Operation |
GetAndSetRequest.prepareOperation() |
protected Operation |
AlterRequest.prepareOperation() |
protected Operation |
GetAndAlterRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAlterOperation |
class |
AddAndGetOperation |
class |
AddBackupOperation |
class |
AlterAndGetOperation |
class |
AlterOperation |
class |
ApplyOperation<R> |
class |
AtomicLongBackupAwareOperation |
class |
AtomicLongBaseOperation |
class |
AtomicLongReplicationOperation |
class |
CompareAndSetOperation |
class |
GetAndAddOperation |
class |
GetAndAlterOperation |
class |
GetAndSetOperation |
class |
GetOperation |
class |
SetBackupOperation |
class |
SetOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
GetAndSetOperation.getBackupOperation() |
Operation |
SetOperation.getBackupOperation() |
Operation |
AbstractAlterOperation.getBackupOperation() |
Operation |
CompareAndSetOperation.getBackupOperation() |
Operation |
AddAndGetOperation.getBackupOperation() |
Operation |
GetAndAddOperation.getBackupOperation() |
| Modifier and Type | Method and Description |
|---|---|
Operation |
AtomicReferenceService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
GetAndAlterRequest.prepareOperation() |
protected Operation |
AlterAndGetRequest.prepareOperation() |
protected Operation |
ApplyRequest.prepareOperation() |
protected Operation |
CompareAndSetRequest.prepareOperation() |
protected Operation |
ContainsRequest.prepareOperation() |
protected Operation |
GetAndSetRequest.prepareOperation() |
protected Operation |
SetRequest.prepareOperation() |
protected Operation |
GetRequest.prepareOperation() |
protected Operation |
IsNullRequest.prepareOperation() |
protected Operation |
AlterRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
AtomicReferenceBackupAwareOperation |
class |
AtomicReferenceBaseOperation |
class |
AtomicReferenceReplicationOperation |
class |
ContainsOperation |
class |
IsNullOperation |
class |
SetAndGetOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
AbstractAlterOperation.getBackupOperation() |
Operation |
SetAndGetOperation.getBackupOperation() |
Operation |
CompareAndSetOperation.getBackupOperation() |
Operation |
SetOperation.getBackupOperation() |
Operation |
GetAndSetOperation.getBackupOperation() |
| Modifier and Type | Method and Description |
|---|---|
Operation |
CountDownLatchService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
SetCountRequest.prepareOperation() |
protected Operation |
CountDownRequest.prepareOperation() |
protected Operation |
GetCountRequest.prepareOperation() |
protected Operation |
AwaitRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
CountDownLatchBackupOperation |
class |
CountDownLatchReplicationOperation |
class |
CountDownOperation |
class |
GetCountOperation |
class |
SetCountOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
LockServiceImpl.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
GetLockCountRequest.prepareOperation() |
protected Operation |
AbstractUnlockRequest.prepareOperation() |
protected Operation |
AbstractIsLockedRequest.prepareOperation() |
protected Operation |
GetRemainingLeaseRequest.prepareOperation() |
protected Operation |
SignalRequest.prepareOperation() |
protected Operation |
AbstractLockRequest.prepareOperation() |
protected Operation |
AwaitRequest.prepareOperation() |
protected Operation |
BeforeAwaitRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
AwaitBackupOperation |
class |
AwaitOperation |
class |
BeforeAwaitBackupOperation |
class |
BeforeAwaitOperation |
class |
GetLockCountOperation |
class |
GetRemainingLeaseTimeOperation |
class |
IsLockedOperation |
class |
LockBackupOperation |
class |
LockOperation |
class |
LockReplicationOperation |
class |
SignalBackupOperation |
class |
SignalOperation |
class |
UnlockBackupOperation |
class |
UnlockOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
AwaitOperation.getBackupOperation() |
Operation |
UnlockOperation.getBackupOperation() |
Operation |
SignalOperation.getBackupOperation() |
Operation |
LockOperation.getBackupOperation() |
Operation |
BeforeAwaitOperation.getBackupOperation() |
| Modifier and Type | Method and Description |
|---|---|
Operation |
SemaphoreService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
AcquireRequest.prepareOperation() |
protected Operation |
ReduceRequest.prepareOperation() |
protected Operation |
AvailableRequest.prepareOperation() |
protected Operation |
InitRequest.prepareOperation() |
protected Operation |
DrainRequest.prepareOperation() |
protected Operation |
ReleaseRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
AcquireBackupOperation |
class |
AcquireOperation |
class |
AvailableOperation |
class |
DeadMemberBackupOperation |
class |
DrainBackupOperation |
class |
DrainOperation |
class |
InitBackupOperation |
class |
InitOperation |
class |
ReduceBackupOperation |
class |
ReduceOperation |
class |
ReleaseBackupOperation |
class |
ReleaseOperation |
class |
SemaphoreBackupAwareOperation |
class |
SemaphoreBackupOperation |
class |
SemaphoreDeadMemberOperation |
class |
SemaphoreOperation |
class |
SemaphoreReplicationOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
InitOperation.getBackupOperation() |
Operation |
DrainOperation.getBackupOperation() |
Operation |
AcquireOperation.getBackupOperation() |
Operation |
SemaphoreDeadMemberOperation.getBackupOperation() |
Operation |
ReduceOperation.getBackupOperation() |
Operation |
ReleaseOperation.getBackupOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
CallableTaskOperation |
class |
CancellationOperation |
class |
MemberCallableTaskOperation |
class |
ShutdownOperation |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
TargetCallableRequest.prepareOperation() |
protected Operation |
PartitionCallableRequest.prepareOperation() |
| Modifier and Type | Method and Description |
|---|---|
Object |
ManagementCenterService.callOnAddress(Address address,
Operation operation) |
Object |
ManagementCenterService.callOnMember(Member member,
Operation operation) |
void |
ManagementCenterService.send(Address address,
Operation operation) |
| Modifier and Type | Class and Description |
|---|---|
class |
GetMapConfigOperation |
class |
ScriptExecutorOperation |
class |
ThreadDumpOperation |
class |
UpdateManagementCenterUrlOperation |
class |
UpdateMapConfigOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
MapService.getPostJoinOperation() |
Operation |
MapService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
MapPutIfAbsentRequest.prepareOperation() |
protected Operation |
MapPutRequest.prepareOperation() |
protected Operation |
MapGetRequest.prepareOperation() |
protected Operation |
MapReplaceIfSameRequest.prepareOperation() |
protected Operation |
MapRemoveRequest.prepareOperation() |
protected Operation |
MapTryPutRequest.prepareOperation() |
protected Operation |
MapRemoveIfSameRequest.prepareOperation() |
protected Operation |
MapReplaceRequest.prepareOperation() |
protected Operation |
MapGetEntryViewRequest.prepareOperation() |
protected Operation |
MapSetRequest.prepareOperation() |
protected Operation |
MapEvictRequest.prepareOperation() |
protected Operation |
MapExecuteOnKeyRequest.prepareOperation() |
protected Operation |
MapDeleteRequest.prepareOperation() |
protected Operation |
MapContainsKeyRequest.prepareOperation() |
protected Operation |
MapTryRemoveRequest.prepareOperation() |
protected Operation |
MapPutTransientRequest.prepareOperation() |
| Modifier and Type | Method and Description |
|---|---|
Operation |
ClearOperationFactory.createOperation() |
Operation |
MapGetAllOperationFactory.createOperation() |
Operation |
EntrySetOperationFactory.createOperation() |
Operation |
PartitionWideEntryWithPredicateOperationFactory.createOperation() |
Operation |
PartitionCheckIfLoadedOperationFactory.createOperation() |
Operation |
RemoveInterceptorOperationFactory.createOperation() |
Operation |
MapPutAllOperationFactory.createOperation() |
Operation |
MapFlushOperationFactory.createOperation() |
Operation |
PartitionWideEntryOperationFactory.createOperation() |
Operation |
AddInterceptorOperationFactory.createOperation() |
Operation |
MapValuesOperationFactory.createOperation() |
Operation |
ContainsValueOperationFactory.createOperation() |
Operation |
AddIndexOperationFactory.createOperation() |
Operation |
SizeOperationFactory.createOperation() |
Operation |
MultipleEntryOperationFactory.createOperation() |
Operation |
MapKeySetOperationFactory.createOperation() |
Operation |
BaseRemoveOperation.getBackupOperation() |
Operation |
PartitionWideEntryWithPredicateOperation.getBackupOperation() |
Operation |
PartitionWideEntryOperation.getBackupOperation() |
Operation |
BasePutOperation.getBackupOperation() |
Operation |
EvictKeysOperation.getBackupOperation() |
Operation |
MultipleEntryOperation.getBackupOperation() |
Operation |
PutAllOperation.getBackupOperation() |
Operation |
EntryOperation.getBackupOperation() |
Operation |
ClearOperation.getBackupOperation() |
Operation |
EvictOperation.getBackupOperation() |
Operation |
MergeOperation.getBackupOperation() |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
MapProxyImpl.invoke(Operation operation,
int partitionId) |
| Modifier and Type | Class and Description |
|---|---|
class |
TxnDeleteOperation |
class |
TxnLockAndGetOperation |
class |
TxnPrepareBackupOperation |
class |
TxnPrepareOperation |
class |
TxnRollbackBackupOperation |
class |
TxnRollbackOperation |
class |
TxnSetOperation |
class |
TxnUnlockBackupOperation |
class |
TxnUnlockOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
TxnUnlockOperation.getBackupOperation() |
Operation |
TxnSetOperation.getBackupOperation() |
Operation |
TxnDeleteOperation.getBackupOperation() |
Operation |
TxnRollbackOperation.getBackupOperation() |
Operation |
TxnPrepareOperation.getBackupOperation() |
| Constructor and Description |
|---|
MapTransactionLog(String name,
Data key,
Operation op,
long version,
String ownerUuid) |
| Modifier and Type | Method and Description |
|---|---|
static <V> V |
MapReduceUtil.executeOperation(Operation operation,
Address address,
MapReduceService mapReduceService,
NodeEngine nodeEngine) |
| Modifier and Type | Class and Description |
|---|---|
class |
CancelJobSupervisorOperation
This operation is fired by the jobs owner node to remotely cancel the defined jobId on all nodes.
|
class |
FireNotificationOperation
This operation is used to transport and execute a notification on a remote node since
the current event service is not capable of reliable transmission so this is a fallback
to sync operations which is hopefully only a temporary workaround!
|
class |
GetResultOperation
This operation is used to retrieve results from a remote node
|
class |
KeysAssignmentOperation
This operation is used to request assignment for keys on the job owners node.
|
class |
KeyValueJobOperation<K,V>
This operation is used to prepare a
KeyValueSource based
map reduce operation on all cluster members. |
class |
NotifyRemoteExceptionOperation
This operation is used to inform the job owner of a remote exception
|
class |
PostPonePartitionProcessing
This operation is used to tell the job owner to postpone a mapping phase for the defined
partitionId.
|
class |
ProcessingOperation
This is the base class for all map reduce framework operations, it always contains the name of
the JobTracker and the unique jobId
|
class |
ProcessStatsUpdateOperation
This operation is used to update the process statistics on the owner node
|
class |
RequestMemberIdAssignment
This operation is used to do some kind of partitionId based processing on non partition based implementations
of
KeyValueSource (not implementing PartitionIdAware)
which can happen for custom data sources like distributed filesystems that are up to the end user on how to
manage the distribution. |
class |
RequestPartitionMapping
This operation requests a new partition to process by the requester on the job owning node
|
class |
RequestPartitionProcessed
This operation tells the job owner to mark a partition as cully processed
|
class |
RequestPartitionReducing
This operation tells the job owner to start reducing phase of the defined partition on the first
occurrence of a full emitted chunk
|
class |
StartProcessingJobOperation<K>
This operation is used to start the actual processing after all node prepared to execute the map reduce job
|
| Modifier and Type | Method and Description |
|---|---|
Operation |
GetResultOperationFactory.createOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
MultiMapMigrationOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
MultiMapService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Class and Description |
|---|---|
class |
ContainsEntryOperation |
class |
CountOperation |
class |
EntrySetOperation |
class |
KeySetOperation |
class |
MultiMapBackupAwareOperation |
class |
MultiMapKeyBasedOperation |
class |
MultiMapOperation |
class |
RemoveAllBackupOperation |
class |
RemoveAllOperation |
class |
SizeOperation |
class |
ValuesOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
MultiMapOperationFactory.createOperation() |
Operation |
ClearOperation.getBackupOperation() |
Operation |
RemoveOperation.getBackupOperation() |
Operation |
PutOperation.getBackupOperation() |
Operation |
RemoveAllOperation.getBackupOperation() |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
CountRequest.prepareOperation() |
protected Operation |
RemoveRequest.prepareOperation() |
protected Operation |
PutRequest.prepareOperation() |
protected Operation |
RemoveAllRequest.prepareOperation() |
protected Operation |
GetAllRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
TxnCommitBackupOperation |
class |
TxnCommitOperation |
class |
TxnGenerateRecordIdOperation |
class |
TxnPutBackupOperation |
class |
TxnPutOperation |
class |
TxnRemoveAllBackupOperation |
class |
TxnRemoveAllOperation |
class |
TxnRemoveBackupOperation |
class |
TxnRemoveOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
TxnRemoveOperation.getBackupOperation() |
Operation |
TxnCommitOperation.getBackupOperation() |
Operation |
TxnRollbackOperation.getBackupOperation() |
Operation |
TxnPutOperation.getBackupOperation() |
Operation |
TxnPrepareOperation.getBackupOperation() |
Operation |
TxnRemoveAllOperation.getBackupOperation() |
| Modifier and Type | Method and Description |
|---|---|
void |
MultiMapTransactionLog.addOperation(Operation op) |
| Constructor and Description |
|---|
TxnCommitBackupOperation(String name,
Data dataKey,
List<Operation> opList,
String caller,
long threadId) |
TxnCommitOperation(String name,
Data dataKey,
long threadId,
long version,
List<Operation> opList) |
| Modifier and Type | Class and Description |
|---|---|
class |
AssignPartitions |
class |
BaseMigrationOperation |
class |
CheckReplicaVersion |
class |
HasOngoingMigration |
class |
MigrationOperation |
class |
MigrationRequestOperation |
class |
PartitionStateOperation |
class |
ReplicaSyncRequest |
class |
ReplicaSyncResponse |
class |
ReplicaSyncRetryResponse |
| Modifier and Type | Class and Description |
|---|---|
class |
AddAllBackupOperation |
class |
AddAllOperation |
class |
CheckAndEvictOperation |
class |
CompareAndRemoveBackupOperation |
class |
CompareAndRemoveOperation |
class |
IteratorOperation |
class |
OfferBackupOperation |
class |
OfferOperation
User: ali
Date: 11/14/12
Time: 12:14 AM
|
class |
PeekOperation
User: ali
Date: 11/23/12
Time: 3:56 AM
|
class |
PollBackupOperation |
class |
PollOperation |
class |
QueueBackupAwareOperation |
class |
QueueOperation |
class |
QueueReplicationOperation
User: ali
Date: 11/21/12
Time: 11:23 AM
|
| Modifier and Type | Method and Description |
|---|---|
Operation |
CompareAndRemoveOperation.getBackupOperation() |
Operation |
DrainOperation.getBackupOperation() |
Operation |
ClearOperation.getBackupOperation() |
Operation |
RemoveOperation.getBackupOperation() |
Operation |
OfferOperation.getBackupOperation() |
Operation |
PollOperation.getBackupOperation() |
Operation |
AddAllOperation.getBackupOperation() |
Operation |
QueueService.prepareReplicationOperation(PartitionReplicationEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
IteratorRequest.prepareOperation() |
protected Operation |
ContainsRequest.prepareOperation() |
protected Operation |
DrainRequest.prepareOperation() |
protected Operation |
PeekRequest.prepareOperation() |
protected Operation |
SizeRequest.prepareOperation() |
protected Operation |
ClearRequest.prepareOperation() |
protected Operation |
CompareAndRemoveRequest.prepareOperation() |
protected Operation |
OfferRequest.prepareOperation() |
protected Operation |
PollRequest.prepareOperation() |
protected Operation |
RemoveRequest.prepareOperation() |
protected Operation |
AddAllRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
QueueTransactionRollbackOperation |
class |
TxnOfferBackupOperation |
class |
TxnOfferOperation |
class |
TxnPeekOperation
User: ahmetmircik
Date: 9/30/13
Time: 2:19 PM
|
class |
TxnPollBackupOperation |
class |
TxnPollOperation |
class |
TxnReserveOfferOperation |
class |
TxnReservePollOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
TxnRollbackOperation.getBackupOperation() |
Operation |
TxnOfferOperation.getBackupOperation() |
Operation |
TxnPrepareOperation.getBackupOperation() |
Operation |
TxnPollOperation.getBackupOperation() |
| Constructor and Description |
|---|
QueueTransactionLog(String transactionId,
long itemId,
String name,
int partitionId,
Operation op) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractOperation |
| Modifier and Type | Field and Description |
|---|---|
protected Operation |
InvocationBuilder.op |
| Modifier and Type | Method and Description |
|---|---|
Operation |
OperationFactory.createOperation()
Creates the operation.
|
Operation |
BackupAwareOperation.getBackupOperation()
Creates the
BackupOperation responsible for making the backup. |
Operation |
InvocationBuilder.getOp() |
Operation |
PostJoinAwareService.getPostJoinOperation()
Post join operations must be lock free; means no locks at all;
no partition locks, no key-based locks, no service level locks!
Post join operations should return response, at least a null response.
|
Operation |
MigrationAwareService.prepareReplicationOperation(PartitionReplicationEvent event) |
Operation |
Operation.setCallerUuid(String callerUuid) |
Operation |
Operation.setNodeEngine(NodeEngine nodeEngine) |
Operation |
Operation.setPartitionId(int partitionId) |
Operation |
Operation.setReplicaIndex(int replicaIndex) |
Operation |
Operation.setResponseHandler(ResponseHandler responseHandler) |
Operation |
Operation.setService(Object service) |
Operation |
Operation.setServiceName(String serviceName) |
Operation |
Operation.setValidateTarget(boolean validateTarget) |
| Modifier and Type | Method and Description |
|---|---|
InvocationBuilder |
OperationService.createInvocationBuilder(String serviceName,
Operation op,
Address target) |
InvocationBuilder |
OperationService.createInvocationBuilder(String serviceName,
Operation op,
int partitionId) |
void |
OperationService.executeOperation(Operation op)
Executes operation in operation executor pool.
|
<E> InternalCompletableFuture<E> |
OperationService.invokeOnPartition(String serviceName,
Operation op,
int partitionId) |
<E> InternalCompletableFuture<E> |
OperationService.invokeOnTarget(String serviceName,
Operation op,
Address target) |
static boolean |
OperationAccessor.isJoinOperation(Operation op) |
static boolean |
OperationAccessor.isMigrationOperation(Operation op) |
void |
OperationService.runOperation(Operation op)
Runs operation in calling thread.
|
boolean |
OperationService.send(Operation op,
Address target)
Executes an operation remotely.
|
static void |
OperationAccessor.setCallerAddress(Operation op,
Address caller) |
static void |
OperationAccessor.setCallId(Operation op,
long callId) |
static void |
OperationAccessor.setCallTimeout(Operation op,
long callTimeout) |
static void |
OperationAccessor.setConnection(Operation op,
Connection connection) |
static void |
OperationAccessor.setInvocationTime(Operation op,
long invocationTime) |
static void |
OperationAccessor.setStartTime(Operation op,
long startTime) |
| Constructor and Description |
|---|
InvocationBuilder(NodeEngineImpl nodeEngine,
String serviceName,
Operation op,
int partitionId,
Address target) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractNamedOperation |
static class |
EventServiceImpl.DeregistrationOperation |
static class |
EventServiceImpl.PostJoinRegistrationOperation |
static class |
EventServiceImpl.RegistrationOperation |
static class |
EventServiceImpl.SendEventOperation |
class |
PartitionIteratingOperation |
static class |
ProxyServiceImpl.DistributedObjectDestroyOperation |
static class |
ProxyServiceImpl.PostJoinProxyOperation |
| Modifier and Type | Method and Description |
|---|---|
Operation |
BinaryOperationFactory.createOperation() |
Operation |
ProxyServiceImpl.getPostJoinOperation() |
Operation[] |
NodeEngineImpl.getPostJoinOperations()
Post join operations must be lock free; means no locks at all;
no partition locks, no key-based locks, no service level locks!
Post join operations should return response, at least a null response.
|
| Modifier and Type | Method and Description |
|---|---|
static ResponseHandler |
ResponseHandlerFactory.createLocalResponseHandler(Operation op,
Callback<Object> callback) |
static ResponseHandler |
ResponseHandlerFactory.createRemoteResponseHandler(NodeEngine nodeEngine,
Operation op) |
boolean |
InternalOperationService.isCallTimedOut(Operation op) |
static void |
ResponseHandlerFactory.setLocalResponseHandler(Operation op,
Callback<Object> callback) |
static void |
ResponseHandlerFactory.setRemoteResponseHandler(NodeEngine nodeEngine,
Operation op) |
| Constructor and Description |
|---|
BasicInvocationBuilder(NodeEngineImpl nodeEngine,
String serviceName,
Operation op,
Address target) |
BasicInvocationBuilder(NodeEngineImpl nodeEngine,
String serviceName,
Operation op,
int partitionId) |
BasicPartitionInvocation(NodeEngineImpl nodeEngine,
String serviceName,
Operation op,
int partitionId,
int replicaIndex,
int tryCount,
long tryPauseMillis,
long callTimeout,
Callback<Object> callback,
String executorName,
boolean resultDeserialized) |
BasicTargetInvocation(NodeEngineImpl nodeEngine,
String serviceName,
Operation op,
Address target,
int tryCount,
long tryPauseMillis,
long callTimeout,
Callback<Object> callback,
String executorName,
boolean resultDeserialized) |
BinaryOperationFactory(Operation operation,
NodeEngine nodeEngine) |
| Modifier and Type | Class and Description |
|---|---|
class |
PublishOperation |
| Modifier and Type | Method and Description |
|---|---|
protected Operation |
PublishRequest.prepareOperation() |
| Modifier and Type | Class and Description |
|---|---|
class |
BeginTxBackupOperation |
class |
BroadcastTxRollbackOperation |
class |
PurgeTxBackupOperation |
class |
RecoverTxnOperation |
class |
ReplicateTxOperation |
class |
RollbackTxBackupOperation |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.