com.hazelcast.spi.impl

Interface PartitionSpecificRunnable

All Superinterfaces:

Runnable

All Known Subinterfaces:

MessageTask

All Known Implementing Classes:

AbstractAddConfigMessageTask, AbstractAddressMessageTask, AbstractAllPartitionsMessageTask, AbstractCacheMessageTask, AbstractCallableMessageTask, AbstractCPMessageTask, AbstractInvocationMessageTask, AbstractMapAddEntryListenerMessageTask, AbstractMapPutMessageTask, AbstractMapPutWithMaxIdleMessageTask, AbstractMapQueryMessageTask, AbstractMapReduceTask, AbstractMessageTask, AbstractMultiMapAddEntryListenerMessageTask, AbstractMultiPartitionMessageTask, AbstractMultiTargetMessageTask, AbstractPartitionMessageTask, AbstractPartitionPrimaryReplicaAntiEntropyTask, AbstractRemoveListenerMessageTask, AbstractReplicatedMapAddEntryListenerMessageTask, AbstractStableClusterMessageTask, AbstractTransactionalMessageTask, AcquirePermitsMessageTask, AddAndGetMessageTask, AddCacheConfigMessageTask, AddCardinalityEstimatorConfigMessageTask, AddDistributedObjectListenerMessageTask, AddDurableExecutorConfigMessageTask, AddEventJournalConfigMessageTask, AddExecutorConfigMessageTask, AddFlakeIdGeneratorConfigMessageTask, AddListConfigMessageTask, AddLockConfigMessageTask, AddMapConfigMessageTask, AddMembershipListenerMessageTask, AddMerkleTreeConfigMessageTask, AddMultiMapConfigMessageTask, AddPartitionListenerMessageTask, AddPartitionLostListenerMessageTask, AddPNCounterConfigMessageTask, AddQueueConfigMessageTask, AddReliableTopicConfigMessageTask, AddReplicatedMapConfigMessageTask, AddRingbufferConfigMessageTask, AddScheduledExecutorConfigMessageTask, AddSemaphoreConfigMessageTask, AddSetConfigMessageTask, AddTopicConfigMessageTask, AlterMessageTask, ApplyMessageTask, ApplyMessageTask, AtomicLongAddAndGetMessageTask, AtomicLongAlterAndGetMessageTask, AtomicLongAlterMessageTask, AtomicLongApplyMessageTask, AtomicLongCompareAndSetMessageTask, AtomicLongDecrementAndGetMessageTask, AtomicLongGetAndAddMessageTask, AtomicLongGetAndAlterMessageTask, AtomicLongGetAndIncrementMessageTask, AtomicLongGetAndSetMessageTask, AtomicLongGetMessageTask, AtomicLongIncrementAndGetMessageTask, AtomicLongSetMessageTask, AtomicReferenceAlterAndGetMessageTask, AtomicReferenceAlterMessageTask, AtomicReferenceApplyMessageTask, AtomicReferenceClearMessageTask, AtomicReferenceCompareAndSetMessageTask, AtomicReferenceContainsMessageTask, AtomicReferenceGetAndAlterMessageTask, AtomicReferenceGetAndSetMessageTask, AtomicReferenceGetMessageTask, AtomicReferenceIsNullMessageTask, AtomicReferenceSetAndGetMessageTask, AtomicReferenceSetMessageTask, AuthenticationBaseMessageTask, AuthenticationCustomCredentialsMessageTask, AuthenticationMessageTask, AvailablePermitsMessageTask, AwaitMessageTask, CacheAddEntryListenerMessageTask, CacheAddNearCacheInvalidationListenerTask, CacheAddPartitionLostListenerMessageTask, CacheAssignAndGetUuidsMessageTask, CacheClearMessageTask, CacheContainsKeyMessageTask, CacheCreateConfigMessageTask, CacheDestroyMessageTask, CacheEntryProcessorMessageTask, CacheEventJournalReadTask, CacheEventJournalSubscribeTask, CacheFetchNearCacheInvalidationMetadataTask, CacheGetAllMessageTask, CacheGetAndRemoveMessageTask, CacheGetAndReplaceMessageTask, CacheGetConfigMessageTask, CacheGetMessageTask, CacheIterateEntriesMessageTask, CacheIterateMessageTask, CacheListenerRegistrationMessageTask, CacheLoadAllMessageTask, CacheManagementConfigMessageTask, CachePutAllMessageTask, CachePutIfAbsentMessageTask, CachePutMessageTask, CacheRemoveAllKeysMessageTask, CacheRemoveAllMessageTask, CacheRemoveEntryListenerMessageTask, CacheRemoveInvalidationListenerMessageTask, CacheRemoveMessageTask, CacheRemovePartitionLostListenerMessageTask, CacheReplaceMessageTask, CacheSetExpiryPolicyMessageTask, CacheSizeMessageTask, CardinalityEstimatorAddMessageTask, CardinalityEstimatorEstimateMessageTask, ChangePermitsMessageTask, ClientStatisticsMessageTask, CloseSessionMessageTask, CompareAndSetMessageTask, CompareAndSetMessageTask, ConditionAwaitMessageTask, ConditionBeforeAwaitMessageTask, ConditionSignalAllMessageTask, ConditionSignalMessageTask, ContainsMessageTask, CountDownLatchAwaitMessageTask, CountDownLatchCountDownMessageTask, CountDownLatchGetCountMessageTask, CountDownLatchTrySetCountMessageTask, CountDownMessageTask, CreateProxiesMessageTask, CreateProxyMessageTask, CreateRaftGroupMessageTask, CreateSessionMessageTask, DefaultMapAggregateMessageTask, DefaultMapProjectMessageTask, DefaultMapQueryMessageTask, DeployClassesMessageTask, DestroyProxyMessageTask, DestroyRaftObjectMessageTask, DrainPermitsMessageTask, DurableExecutorDisposeResultMessageTask, DurableExecutorIsShutdownMessageTask, DurableExecutorRetrieveAndDisposeResultMessageTask, DurableExecutorRetrieveResultMessageTask, DurableExecutorShutdownMessageTask, DurableExecutorSubmitToPartitionMessageTask, ExecutorServiceCancelOnAddressMessageTask, ExecutorServiceCancelOnPartitionMessageTask, ExecutorServiceIsShutdownMessageTask, ExecutorServiceShutdownMessageTask, ExecutorServiceSubmitToAddressMessageTask, ExecutorServiceSubmitToPartitionMessageTask, GenerateThreadIdMessageTask, GetAndAddMessageTask, GetAndSetMessageTask, GetCountMessageTask, GetDistributedObjectsMessageTask, GetLockOwnershipStateMessageTask, GetMessageTask, GetMessageTask, GetPartitionsMessageTask, GetRoundMessageTask, GetSemaphoreTypeMessageTask, HeartbeatSessionMessageTask, InitSemaphoreMessageTask, IsFailoverSupportedMessageTask, ListAddAllMessageTask, ListAddAllWithIndexMessageTask, ListAddListenerMessageTask, ListAddMessageTask, ListAddWithIndexMessageTask, ListClearMessageTask, ListCompareAndRemoveAllMessageTask, ListCompareAndRetainAllMessageTask, ListContainsAllMessageTask, ListContainsMessageTask, ListGetAllMessageTask, ListGetMessageTask, ListIndexOfMessageTask, ListIsEmptyMessageTask, ListIteratorMessageTask, ListLastIndexOfMessageTask, ListListIteratorMessageTask, ListRemoveListenerMessageTask, ListRemoveMessageTask, ListRemoveWithIndexMessageTask, ListSetMessageTask, ListSizeMessageTask, ListSubMessageTask, LockForceUnlockMessageTask, LockGetLockCountMessageTask, LockGetRemainingLeaseTimeMessageTask, LockIsLockedByCurrentThreadMessageTask, LockIsLockedMessageTask, LockLockMessageTask, LockMessageTask, LockTryLockMessageTask, LockUnlockMessageTask, MapAddEntryListenerMessageTask, MapAddEntryListenerToKeyMessageTask, MapAddEntryListenerToKeyWithPredicateMessageTask, MapAddEntryListenerWithPredicateMessageTask, MapAddIndexMessageTask, MapAddInterceptorMessageTask, MapAddListenerMessageTask, MapAddNearCacheInvalidationListenerMessageTask, MapAddPartitionLostListenerMessageTask, MapAggregateMessageTask, MapAggregateWithPredicateMessageTask, MapAssignAndGetUuidsMessageTask, MapClearMessageTask, MapClearNearCacheMessageTask, MapContainsKeyMessageTask, MapContainsValueMessageTask, MapDeleteMessageTask, MapDestroyCacheMessageTask, MapEntriesWithPagingPredicateMessageTask, MapEntriesWithPredicateMessageTask, MapEntrySetMessageTask, MapEventJournalReadTask, MapEventJournalSubscribeTask, MapEvictAllMessageTask, MapEvictMessageTask, MapExecuteOnAllKeysMessageTask, MapExecuteOnKeyMessageTask, MapExecuteOnKeysMessageTask, MapExecuteWithPredicateMessageTask, MapFetchEntriesMessageTask, MapFetchKeysMessageTask, MapFetchNearCacheInvalidationMetadataTask, MapFetchWithQueryMessageTask, MapFlushMessageTask, MapForceUnlockMessageTask, MapGetAllMessageTask, MapGetEntryViewMessageTask, MapGetMessageTask, MapIsEmptyMessageTask, MapIsLockedMessageTask, MapKeySetMessageTask, MapKeySetWithPagingPredicateMessageTask, MapKeySetWithPredicateMessageTask, MapLoadAllMessageTask, MapLoadGivenKeysMessageTask, MapLockMessageTask, MapMadePublishableMessageTask, MapProjectionMessageTask, MapProjectionWithPredicateMessageTask, MapPublisherCreateMessageTask, MapPublisherCreateWithValueMessageTask, MapPutAllMessageTask, MapPutIfAbsentMessageTask, MapPutIfAbsentWithMaxIdleMessageTask, MapPutMessageTask, MapPutTransientMessageTask, MapPutTransientWithMaxIdleMessageTask, MapPutWithMaxIdleMessageTask, MapReduceCancelMessageTask, MapReduceForCustomMessageTask, MapReduceForListMessageTask, MapReduceForMapMessageTask, MapReduceForMultiMapMessageTask, MapReduceForSetMessageTask, MapReduceJobProcessInformationMessageTask, MapRemoveAllMessageTask, MapRemoveEntryListenerMessageTask, MapRemoveIfSameMessageTask, MapRemoveInterceptorMessageTask, MapRemoveMessageTask, MapRemovePartitionLostListenerMessageTask, MapReplaceIfSameMessageTask, MapReplaceMessageTask, MapSetMessageTask, MapSetReadCursorMessageTask, MapSetTtlMessageTask, MapSetWithMaxIdleMessageTask, MapSizeMessageTask, MapSubmitToKeyMessageTask, MapTryLockMessageTask, MapTryPutMessageTask, MapTryRemoveMessageTask, MapUnlockMessageTask, MapValuesMessageTask, MapValuesWithPagingPredicateMessageTask, MapValuesWithPredicateMessageTask, MultiMapAddEntryListenerMessageTask, MultiMapAddEntryListenerToKeyMessageTask, MultiMapClearMessageTask, MultiMapContainsEntryMessageTask, MultiMapContainsKeyMessageTask, MultiMapContainsValueMessageTask, MultiMapDeleteMessageTask, MultiMapEntrySetMessageTask, MultiMapForceUnlockMessageTask, MultiMapGetMessageTask, MultiMapIsLockedMessageTask, MultiMapKeySetMessageTask, MultiMapLockMessageTask, MultiMapPutMessageTask, MultiMapRemoveEntryListenerMessageTask, MultiMapRemoveEntryMessageTask, MultiMapRemoveMessageTask, MultiMapSizeMessageTask, MultiMapTryLockMessageTask, MultiMapUnlockMessageTask, MultiMapValueCountMessageTask, MultiMapValuesMessageTask, NewIdBatchMessageTask, NoSuchMessageTask, PartitionSpecificRunnableAdaptor, PingMessageTask, PNCounterAddMessageTask, PNCounterGetConfiguredReplicaCountMessageTask, PNCounterGetMessageTask, Pre38CacheAddInvalidationListenerTask, Pre38MapAddNearCacheEntryListenerMessageTask, QueueAddAllMessageTask, QueueAddListenerMessageTask, QueueClearMessageTask, QueueCompareAndRemoveAllMessageTask, QueueCompareAndRetainAllMessageTask, QueueContainsAllMessageTask, QueueContainsMessageTask, QueueDrainMaxSizeMessageTask, QueueDrainMessageTask, QueueIsEmptyMessageTask, QueueIteratorMessageTask, QueueOfferMessageTask, QueuePeekMessageTask, QueuePollMessageTask, QueuePutMessageTask, QueueRemainingCapacityMessageTask, QueueRemoveListenerMessageTask, QueueRemoveMessageTask, QueueSizeMessageTask, QueueTakeMessageTask, ReleasePermitsMessageTask, RemoveAllListenersMessageTask, RemoveDistributedObjectListenerMessageTask, RemovePartitionLostListenerMessageTask, ReplicatedMapAddEntryListenerMessageTask, ReplicatedMapAddEntryListenerToKeyMessageTask, ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask, ReplicatedMapAddEntryListenerWithPredicateMessageTask, ReplicatedMapAddNearCacheListenerMessageTask, ReplicatedMapClearMessageTask, ReplicatedMapContainsKeyMessageTask, ReplicatedMapContainsValueMessageTask, ReplicatedMapEntrySetMessageTask, ReplicatedMapGetMessageTask, ReplicatedMapIsEmptyMessageTask, ReplicatedMapKeySetMessageTask, ReplicatedMapPutAllMessageTask, ReplicatedMapPutMessageTask, ReplicatedMapRemoveEntryListenerMessageTask, ReplicatedMapRemoveMessageTask, ReplicatedMapSizeMessageTask, ReplicatedMapValuesMessageTask, RingbufferAddAllMessageTask, RingbufferAddMessageTask, RingbufferCapacityMessageTask, RingbufferHeadSequenceMessageTask, RingbufferReadManyMessageTask, RingbufferReadOneMessageTask, RingbufferRemainingCapacityMessageTask, RingbufferSizeMessageTask, RingbufferTailSequenceMessageTask, ScheduledExecutorGetAllScheduledMessageTask, ScheduledExecutorShutdownMessageTask, ScheduledExecutorSubmitToAddressMessageTask, ScheduledExecutorSubmitToPartitionMessageTask, ScheduledExecutorTaskCancelFromAddressMessageTask, ScheduledExecutorTaskCancelFromPartitionMessageTask, ScheduledExecutorTaskDisposeFromAddressMessageTask, ScheduledExecutorTaskDisposeFromPartitionMessageTask, ScheduledExecutorTaskGetDelayFromAddressMessageTask, ScheduledExecutorTaskGetDelayFromPartitionMessageTask, ScheduledExecutorTaskGetResultFromAddressMessageTask, ScheduledExecutorTaskGetResultFromPartitionMessageTask, ScheduledExecutorTaskGetStatisticsFromAddressMessageTask, ScheduledExecutorTaskGetStatisticsFromPartitionMessageTask, ScheduledExecutorTaskIsCancelledFromAddressMessageTask, ScheduledExecutorTaskIsCancelledFromPartitionMessageTask, ScheduledExecutorTaskIsDoneFromAddressMessageTask, ScheduledExecutorTaskIsDoneFromPartitionMessageTask, SemaphoreAcquireMessageTask, SemaphoreAvailablePermitsMessageTasks, SemaphoreDrainPermitsMessageTask, SemaphoreIncreasePermitsMessageTask, SemaphoreInitMessageTask, SemaphoreReducePermitsMessageTask, SemaphoreReleaseMessageTask, SemaphoreTryAcquireMessageTask, SetAddAllMessageTask, SetAddListenerMessageTask, SetAddMessageTask, SetClearMessageTask, SetCompareAndRemoveAllMessageTask, SetCompareAndRetainAllMessageTask, SetContainsAllMessageTask, SetContainsMessageTask, SetGetAllMessageTask, SetIsEmptyMessageTask, SetMessageTask, SetRemoveListenerMessageTask, SetRemoveMessageTask, SetSizeMessageTask, TopicAddMessageListenerMessageTask, TopicPublishMessageTask, TopicRemoveMessageListenerMessageTask, TransactionalListAddMessageTask, TransactionalListRemoveMessageTask, TransactionalListSizeMessageTask, TransactionalMapContainsKeyMessageTask, TransactionalMapDeleteMessageTask, TransactionalMapGetForUpdateMessageTask, TransactionalMapGetMessageTask, TransactionalMapIsEmptyMessageTask, TransactionalMapKeySetMessageTask, TransactionalMapKeySetWithPredicateMessageTask, TransactionalMapPutIfAbsentMessageTask, TransactionalMapPutMessageTask, TransactionalMapRemoveIfSameMessageTask, TransactionalMapRemoveMessageTask, TransactionalMapReplaceIfSameMessageTask, TransactionalMapReplaceMessageTask, TransactionalMapSetMessageTask, TransactionalMapSizeMessageTask, TransactionalMapValuesMessageTask, TransactionalMapValuesWithPredicateMessageTask, TransactionalMultiMapGetMessageTask, TransactionalMultiMapPutMessageTask, TransactionalMultiMapRemoveEntryMessageTask, TransactionalMultiMapRemoveMessageTask, TransactionalMultiMapSizeMessageTask, TransactionalMultiMapValueCountMessageTask, TransactionalQueueOfferMessageTask, TransactionalQueuePeekMessageTask, TransactionalQueuePollMessageTask, TransactionalQueueSizeMessageTask, TransactionalQueueTakeMessageTask, TransactionalSetAddMessageTask, TransactionalSetRemoveMessageTask, TransactionalSetSizeMessageTask, TransactionCommitMessageTask, TransactionCreateMessageTask, TransactionRollbackMessageTask, TryLockMessageTask, TrySetCountMessageTask, UnlockMessageTask, XAClearRemoteTransactionMessageTask, XACollectTransactionsMessageTask, XAFinalizeTransactionMessageTask, XATransactionCommitMessageTask, XATransactionCreateMessageTask, XATransactionPrepareMessageTask, XATransactionRollbackMessageTask

public interface PartitionSpecificRunnable
extends Runnable

A Runnable for a specific partition.

Method Summary

Modifier and Type	Method and Description
int	getPartitionId() Returns the partition ID.

Methods inherited from interface java.lang.Runnable

run

Method Detail

getPartitionId

int getPartitionId()

Returns the partition ID. If the partition ID is smaller than 0, than it isn't specific to a partition.

Returns:

the partition ID