Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.journal | |
com.hazelcast.cache.impl.operation |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.concurrent.lock | |
com.hazelcast.concurrent.lock.operations |
This package contains the operations on the ILock.
|
com.hazelcast.internal.journal |
This package contains supporting classes for data structure specific event journals.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.journal | |
com.hazelcast.map.impl.operation |
Package for map operations.
|
com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
com.hazelcast.multimap.impl.operations |
Contains operations for Hazelcast MultiMap module.
|
com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
com.hazelcast.ringbuffer.impl.operations | |
com.hazelcast.spi |
Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
|
Modifier and Type | Field and Description |
---|---|
protected ObjectNamespace |
AbstractCacheRecordStore.objectNamespace |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
ICacheRecordStore.getObjectNamespace()
Returns
ObjectNamespace associated with this record store. |
ObjectNamespace |
AbstractCacheRecordStore.getObjectNamespace() |
static ObjectNamespace |
CacheService.getObjectNamespace(String cacheName) |
Modifier and Type | Method and Description |
---|---|
void |
RingbufferCacheEventJournalImpl.cleanup(ObjectNamespace namespace,
int partitionId) |
void |
RingbufferCacheEventJournalImpl.destroy(ObjectNamespace namespace,
int partitionId) |
EventJournalConfig |
RingbufferCacheEventJournalImpl.getEventJournalConfig(ObjectNamespace namespace)
Returns the event journal configuration or
null if there is none or the journal is disabled
for the given namespace . |
WaitNotifyKey |
RingbufferCacheEventJournalImpl.getWaitNotifyKey(ObjectNamespace namespace,
int partitionId) |
boolean |
RingbufferCacheEventJournalImpl.hasEventJournal(ObjectNamespace namespace)
Returns
true if the object has a configured and enabled event journal. |
void |
RingbufferCacheEventJournalImpl.isAvailableOrNextSequence(ObjectNamespace namespace,
int partitionId,
long sequence) |
boolean |
RingbufferCacheEventJournalImpl.isNextAvailableSequence(ObjectNamespace namespace,
int partitionId,
long sequence) |
boolean |
RingbufferCacheEventJournalImpl.isPersistenceEnabled(ObjectNamespace namespace,
int partitionId) |
long |
RingbufferCacheEventJournalImpl.newestSequence(ObjectNamespace namespace,
int partitionId) |
long |
RingbufferCacheEventJournalImpl.oldestSequence(ObjectNamespace namespace,
int partitionId) |
<T> long |
RingbufferCacheEventJournalImpl.readMany(ObjectNamespace namespace,
int partitionId,
long beginSequence,
ReadResultSetImpl<InternalEventJournalCacheEvent,T> resultSet) |
RingbufferConfig |
RingbufferCacheEventJournalImpl.toRingbufferConfig(EventJournalConfig config,
ObjectNamespace namespace)
Creates a new
RingbufferConfig for a ringbuffer that will keep
event journal events for a single partition. |
void |
RingbufferCacheEventJournalImpl.writeCreatedEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeCreatedEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.CREATED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.EVICTED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeExpiredEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeExpiredEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.EXPIRED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.REMOVED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue) |
void |
CacheEventJournal.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue)
Writes an
CacheEventType.UPDATED to the event journal. |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
CacheClearBackupOperation.getServiceNamespace() |
ObjectNamespace |
CacheOperation.getServiceNamespace() |
ObjectNamespace |
CacheLoadAllOperation.getServiceNamespace() |
ObjectNamespace |
CacheClearOperation.getServiceNamespace() |
ObjectNamespace |
CacheRemoveAllOperation.getServiceNamespace() |
ObjectNamespace |
CacheRemoveAllBackupOperation.getServiceNamespace() |
Modifier and Type | Class and Description |
---|---|
class |
InternalLockNamespace
A specialization of
ObjectNamespace intended to be used by ILock proxies. |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
LockProxySupport.getNamespace() |
ObjectNamespace |
LockStoreImpl.getNamespace() |
static ObjectNamespace |
ObjectNamespaceSerializationHelper.readNamespaceCompatibly(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
LockService.clearLockStore(int partitionId,
ObjectNamespace namespace) |
void |
LockServiceImpl.clearLockStore(int partitionId,
ObjectNamespace namespace) |
LockStore |
LockService.createLockStore(int partitionId,
ObjectNamespace namespace) |
LockStore |
LockServiceImpl.createLockStore(int partitionId,
ObjectNamespace namespace) |
LockStoreImpl |
LockServiceImpl.getLockStore(int partitionId,
ObjectNamespace namespace) |
LockStoreImpl |
LockStoreContainer.getLockStore(ObjectNamespace namespace) |
static void |
ObjectNamespaceSerializationHelper.writeNamespaceCompatibly(ObjectNamespace namespace,
ObjectDataOutput out) |
Modifier and Type | Method and Description |
---|---|
void |
LockService.registerLockStoreConstructor(String serviceName,
ConstructorFunction<ObjectNamespace,LockStoreInfo> constructorFunction) |
void |
LockServiceImpl.registerLockStoreConstructor(String serviceName,
ConstructorFunction<ObjectNamespace,LockStoreInfo> constructorFunction) |
Constructor and Description |
---|
LockEvictionProcessor(NodeEngine nodeEngine,
ObjectNamespace namespace) |
LockProxySupport(ObjectNamespace namespace,
long maxLeaseTimeInMillis) |
LockStoreImpl(LockService lockService,
ObjectNamespace name,
EntryTaskScheduler<Data,Integer> entryTaskScheduler,
int backupCount,
int asyncBackupCount) |
LockStoreProxy(LockStoreContainer container,
ObjectNamespace namespace) |
LockWaitNotifyKey(ObjectNamespace namespace,
Data key) |
Modifier and Type | Field and Description |
---|---|
protected ObjectNamespace |
AbstractLockOperation.namespace |
Constructor and Description |
---|
AbstractLockOperation(ObjectNamespace namespace,
Data key,
long threadId) |
AbstractLockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long timeout) |
AbstractLockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout) |
AwaitBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
String originalCaller) |
AwaitOperation(ObjectNamespace namespace,
Data key,
long threadId,
long timeout,
String conditionId) |
AwaitOperation(ObjectNamespace namespace,
Data key,
long threadId,
long timeout,
String conditionId,
long referenceId) |
BeforeAwaitBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
String originalCaller) |
BeforeAwaitOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId) |
BeforeAwaitOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
long referenceId) |
GetLockCountOperation(ObjectNamespace namespace,
Data key) |
GetRemainingLeaseTimeOperation(ObjectNamespace namespace,
Data key) |
IsLockedOperation(ObjectNamespace namespace,
Data key) |
IsLockedOperation(ObjectNamespace namespace,
Data key,
long threadId) |
LocalLockCleanupOperation(ObjectNamespace namespace,
Data key,
String uuid) |
LockBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
String originalCallerUuid) |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout) |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout,
long referenceId) |
SignalBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
boolean all) |
SignalOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
boolean all) |
UnlockBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String originalCallerUuid,
boolean force) |
UnlockIfLeaseExpiredOperation(ObjectNamespace namespace,
Data key,
int version) |
UnlockOperation(ObjectNamespace namespace,
Data key,
long threadId) |
UnlockOperation(ObjectNamespace namespace,
Data key,
long threadId,
boolean force) |
UnlockOperation(ObjectNamespace namespace,
Data key,
long threadId,
boolean force,
long referenceId) |
Modifier and Type | Method and Description |
---|---|
void |
EventJournal.cleanup(ObjectNamespace namespace,
int partitionId)
Cleans up the event journal by removing any expired items.
|
void |
EventJournal.destroy(ObjectNamespace namespace,
int partitionId)
Destroys the event journal for the given object and partition ID.
|
EventJournalConfig |
EventJournal.getEventJournalConfig(ObjectNamespace namespace)
Returns the event journal configuration or
null if there is none or the journal is disabled
for the given namespace . |
WaitNotifyKey |
EventJournal.getWaitNotifyKey(ObjectNamespace namespace,
int partitionId)
Return the
WaitNotifyKey for objects waiting and notifying on the event journal. |
boolean |
EventJournal.hasEventJournal(ObjectNamespace namespace)
Returns
true if the object has a configured and enabled event journal. |
void |
EventJournal.isAvailableOrNextSequence(ObjectNamespace namespace,
int partitionId,
long sequence)
Checks if the sequence is of an item that can be read immediately
or is the sequence of the next item to be added into the event journal.
|
boolean |
EventJournal.isNextAvailableSequence(ObjectNamespace namespace,
int partitionId,
long sequence)
Checks if the
sequence is the sequence of the next event to
be added to the event journal. |
boolean |
EventJournal.isPersistenceEnabled(ObjectNamespace namespace,
int partitionId)
Returns
true if the event journal has persistence enabled and
can be queried for events older than the
EventJournal.oldestSequence(ObjectNamespace, int) . |
long |
EventJournal.newestSequence(ObjectNamespace namespace,
int partitionId)
Returns the sequence of the newest event stored in the event journal.
|
long |
EventJournal.oldestSequence(ObjectNamespace namespace,
int partitionId)
Returns the sequence of the oldest event stored in the event journal.
|
<T> long |
EventJournal.readMany(ObjectNamespace namespace,
int partitionId,
long beginSequence,
ReadResultSetImpl<E,T> resultSet)
Reads events from the journal in batches.
|
RingbufferConfig |
EventJournal.toRingbufferConfig(EventJournalConfig config,
ObjectNamespace namespace)
Creates a new
RingbufferConfig for a ringbuffer that will keep
event journal events for a single partition. |
Modifier and Type | Field and Description |
---|---|
protected ObjectNamespace |
MapContainer.objectNamespace |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
MapContainer.getObjectNamespace() |
static ObjectNamespace |
MapService.getObjectNamespace(String mapName) |
Modifier and Type | Method and Description |
---|---|
void |
RingbufferMapEventJournalImpl.cleanup(ObjectNamespace namespace,
int partitionId) |
void |
RingbufferMapEventJournalImpl.destroy(ObjectNamespace namespace,
int partitionId) |
EventJournalConfig |
RingbufferMapEventJournalImpl.getEventJournalConfig(ObjectNamespace namespace) |
WaitNotifyKey |
RingbufferMapEventJournalImpl.getWaitNotifyKey(ObjectNamespace namespace,
int partitionId) |
boolean |
RingbufferMapEventJournalImpl.hasEventJournal(ObjectNamespace namespace) |
boolean |
MapEventJournal.hasEventJournal(ObjectNamespace namespace)
Returns
true if the object has a configured and enabled event journal. |
void |
RingbufferMapEventJournalImpl.isAvailableOrNextSequence(ObjectNamespace namespace,
int partitionId,
long sequence) |
boolean |
RingbufferMapEventJournalImpl.isNextAvailableSequence(ObjectNamespace namespace,
int partitionId,
long sequence) |
boolean |
RingbufferMapEventJournalImpl.isPersistenceEnabled(ObjectNamespace namespace,
int partitionId) |
long |
RingbufferMapEventJournalImpl.newestSequence(ObjectNamespace namespace,
int partitionId) |
long |
RingbufferMapEventJournalImpl.oldestSequence(ObjectNamespace namespace,
int partitionId) |
<T> long |
RingbufferMapEventJournalImpl.readMany(ObjectNamespace namespace,
int partitionId,
long beginSequence,
ReadResultSetImpl<InternalEventJournalMapEvent,T> resultSet) |
RingbufferConfig |
RingbufferMapEventJournalImpl.toRingbufferConfig(EventJournalConfig config,
ObjectNamespace namespace) |
void |
RingbufferMapEventJournalImpl.writeAddEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeAddEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.ADDED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.EVICTED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeLoadEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeLoadEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.LOADED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.REMOVED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue) |
void |
MapEventJournal.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue)
Writes an
EntryEventType.UPDATED to the event journal. |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
MapOperation.getServiceNamespace() |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
MultiMapContainer.getObjectNamespace() |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
AbstractMultiMapOperation.getServiceNamespace() |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
RingbufferContainer.getNamespace() |
static ObjectNamespace |
RingbufferService.getRingbufferNamespace(String name) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<Integer,Map<ObjectNamespace,RingbufferContainer>> |
RingbufferService.getContainers() |
Modifier and Type | Method and Description |
---|---|
static RingbufferStoreWrapper |
RingbufferStoreWrapper.create(ObjectNamespace namespace,
RingbufferStoreConfig storeConfig,
InMemoryFormat inMemoryFormat,
SerializationService serializationService,
ClassLoader classLoader)
Factory method that creates a
RingbufferStoreWrapper . |
void |
RingbufferService.destroyContainer(int partitionId,
ObjectNamespace namespace) |
<T,E> RingbufferContainer<T,E> |
RingbufferService.getContainerOrNull(int partitionId,
ObjectNamespace namespace)
Returns the ringbuffer container if it already exists for the
given
partitionId and namespace . |
<T,E> RingbufferContainer<T,E> |
RingbufferService.getOrCreateContainer(int partitionId,
ObjectNamespace namespace,
RingbufferConfig config)
Return the ringbuffer containter for the specified
namespace . |
Constructor and Description |
---|
RingbufferContainer(ObjectNamespace namespace,
int partitionId)
Constructs the ring buffer container with only the name and the key for
blocking operations.
|
RingbufferContainer(ObjectNamespace namespace,
RingbufferConfig config,
NodeEngine nodeEngine,
int partitionId)
Constructs a fully initialized ringbuffer that can be used immediately.
|
RingbufferWaitNotifyKey(ObjectNamespace namespace,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
ObjectNamespace |
AbstractRingBufferOperation.getServiceNamespace() |
Constructor and Description |
---|
MergeOperation(ObjectNamespace namespace,
SplitBrainMergePolicy<RingbufferMergeData,SplitBrainMergeTypes.RingbufferMergeTypes> mergePolicy,
Ringbuffer<Object> mergingRingbuffer) |
Constructor and Description |
---|
ReplicationOperation(Map<ObjectNamespace,RingbufferContainer> migrationData,
int partitionId,
int replicaIndex) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultObjectNamespace
Deprecated.
please use
DistributedObjectNamespace |
class |
DistributedObjectNamespace
Default
ObjectNamespace implementation for DistributedObject . |
Constructor and Description |
---|
DefaultObjectNamespace(ObjectNamespace namespace)
Deprecated.
|
DistributedObjectNamespace(ObjectNamespace namespace) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.