Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.journal | |
com.hazelcast.cache.impl.merge.entry |
This package contains merge entry internal interfaces and functionality for Hazelcast cache.
|
com.hazelcast.cache.impl.record |
Hazelcast JSR-107 aka JCache implementation
Internal record store
|
com.hazelcast.cardinality.impl | |
com.hazelcast.client.impl.protocol.task.dynamicconfig | |
com.hazelcast.client.map.impl | |
com.hazelcast.client.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
com.hazelcast.client.spi.impl.listener | |
com.hazelcast.client.util |
This package contains some utility classes and the base implementations of the
loadbalancer implementations
|
com.hazelcast.collection.impl.collection | |
com.hazelcast.collection.impl.common | |
com.hazelcast.collection.impl.queue | |
com.hazelcast.internal.nearcache.impl |
Near Cache implementations.
|
com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
com.hazelcast.internal.nearcache.impl.preloader |
Near Cache pre-loader implementation.
|
com.hazelcast.internal.nearcache.impl.store |
Near Cache store implementations.
|
com.hazelcast.internal.serialization |
Contains the private serialization API + implementation.
|
com.hazelcast.internal.serialization.impl | |
com.hazelcast.internal.util.comparators |
Provides various comparator implementations.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.iterator | |
com.hazelcast.map.impl.journal | |
com.hazelcast.map.impl.mapstore |
Contains map store operations.
|
com.hazelcast.map.impl.query | |
com.hazelcast.map.impl.querycache.event |
This package contains classes for query cache events.
|
com.hazelcast.map.impl.querycache.subscriber |
This package contains classes which are used for
QueryCache
event subscription side. |
com.hazelcast.map.impl.querycache.subscriber.record |
This package contains classes for
QueryCacheRecord . |
com.hazelcast.map.impl.record |
Contains record specific classes.
|
com.hazelcast.map.impl.recordstore | |
com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.query.impl |
Contains the implementation classes of the query functionality.
|
com.hazelcast.replicatedmap.impl.operation |
This package contains replicated map operations which are executed 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.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
com.hazelcast.ringbuffer.impl.client | |
com.hazelcast.spi |
Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.merge |
This package contains split-brain related classes.
|
com.hazelcast.spi.serialization |
Contains SPI related to serialization
|
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. |
com.hazelcast.topic.impl.reliable | |
com.hazelcast.util |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
com.hazelcast.util.executor |
This package contains classes related to Util.Executor
|
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
CacheRecordStore.serializationService |
protected SerializationService |
AbstractCacheRecordStore.ss |
Modifier and Type | Method and Description |
---|---|
static <V> Set<V> |
DeferredValue.asPassThroughSet(Set<DeferredValue<V>> deferredValues,
SerializationService serializationService)
Adapts a
Set<DeferredValue<V>> as a Set<V> . |
V |
DeferredValue.get(SerializationService serializationService) |
Data |
DeferredValue.getSerializedValue(SerializationService serializationService) |
Constructor and Description |
---|
CacheEventListenerAdaptor(ICache<K,V> source,
javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration,
SerializationService serializationService) |
Constructor and Description |
---|
DeserializingEventJournalCacheEvent(SerializationService serializationService,
InternalEventJournalCacheEvent je) |
Constructor and Description |
---|
LazyCacheEntryView(Object key,
Object value,
long creationTime,
long expirationTime,
long lastAccessTime,
long accessHit,
Object expiryPolicy,
SerializationService serializationService) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
CacheRecordFactory.serializationService |
Constructor and Description |
---|
CacheRecordFactory(InMemoryFormat inMemoryFormat,
SerializationService serializationService) |
CacheRecordHashMap(SerializationService serializationService,
int initialCapacity,
CacheContext cacheContext) |
Modifier and Type | Method and Description |
---|---|
HyperLogLog |
CardinalityEstimatorContainer.merge(SplitBrainMergeTypes.CardinalityEstimatorMergeTypes mergingEntry,
SplitBrainMergePolicy<HyperLogLog,SplitBrainMergeTypes.CardinalityEstimatorMergeTypes> mergePolicy,
SerializationService serializationService)
Merges the given
SplitBrainMergeTypes.CardinalityEstimatorMergeTypes via the given SplitBrainMergePolicy . |
Modifier and Type | Method and Description |
---|---|
EvictionConfig |
EvictionConfigHolder.asEvictionConfg(SerializationService serializationService) |
<T extends ListenerConfig> |
ListenerConfigHolder.asListenerConfig(SerializationService serializationService) |
MapStoreConfig |
MapStoreConfigHolder.asMapStoreConfig(SerializationService serializationService) |
NearCacheConfig |
NearCacheConfigHolder.asNearCacheConfig(SerializationService serializationService) |
PredicateConfig |
PredicateConfigHolder.asPredicateConfig(SerializationService serializationService) |
QueryCacheConfig |
QueryCacheConfigHolder.asQueryCacheConfig(SerializationService serializationService) |
QueueStoreConfig |
QueueStoreConfigHolder.asQueueStoreConfig(SerializationService serializationService) |
RingbufferStoreConfig |
RingbufferStoreConfigHolder.asRingbufferStoreConfig(SerializationService serializationService) |
static EvictionConfigHolder |
EvictionConfigHolder.of(EvictionConfig config,
SerializationService serializationService) |
static ListenerConfigHolder |
ListenerConfigHolder.of(ListenerConfig config,
SerializationService serializationService) |
static MapStoreConfigHolder |
MapStoreConfigHolder.of(MapStoreConfig config,
SerializationService serializationService) |
static NearCacheConfigHolder |
NearCacheConfigHolder.of(NearCacheConfig config,
SerializationService serializationService) |
static PredicateConfigHolder |
PredicateConfigHolder.of(PredicateConfig config,
SerializationService serializationService) |
static QueryCacheConfigHolder |
QueryCacheConfigHolder.of(QueryCacheConfig config,
SerializationService serializationService) |
static QueueStoreConfigHolder |
QueueStoreConfigHolder.of(QueueStoreConfig queueStoreConfig,
SerializationService serializationService) |
static RingbufferStoreConfigHolder |
RingbufferStoreConfigHolder.of(RingbufferStoreConfig ringbufferStoreConfig,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
protected SerializationService |
ClientMapPartitionIterator.getSerializationService() |
protected SerializationService |
ClientMapQueryPartitionIterator.getSerializationService() |
Modifier and Type | Method and Description |
---|---|
protected SerializationService |
ClientProxy.getSerializationService() |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
AbstractClientListenerService.serializationService |
Constructor and Description |
---|
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
SerializationService serializationService,
ClientMessageDecoder clientMessageDecoder) |
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
SerializationService serializationService,
ClientMessageDecoder clientMessageDecoder,
boolean deserializeResponse) |
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
SerializationService serializationService,
ClientMessageDecoder clientMessageDecoder,
V defaultValue) |
ClientDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
SerializationService serializationService,
ClientMessageDecoder clientMessageDecoder,
V defaultValue,
boolean deserializeResponse) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
CollectionService.serializationService |
Constructor and Description |
---|
DataAwareItemEvent(String name,
ItemEventType itemEventType,
Data dataItem,
Member member,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
static QueueStoreWrapper |
QueueStoreWrapper.create(String name,
QueueStoreConfig storeConfig,
SerializationService serializationService,
ClassLoader classLoader)
Factory method that creates a
QueueStoreWrapper |
Constructor and Description |
---|
QueueIterator(Iterator<Data> iterator,
SerializationService serializationService,
boolean binary) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
DefaultNearCacheManager.serializationService |
protected SerializationService |
DefaultNearCache.serializationService |
Modifier and Type | Method and Description |
---|---|
protected SerializationService |
DefaultNearCacheManager.getSerializationService() |
Constructor and Description |
---|
DefaultNearCache(String name,
NearCacheConfig nearCacheConfig,
NearCacheRecordStore<K,V> nearCacheRecordStore,
SerializationService serializationService,
TaskScheduler scheduler,
ClassLoader classLoader,
HazelcastProperties properties) |
DefaultNearCache(String name,
NearCacheConfig nearCacheConfig,
SerializationService serializationService,
TaskScheduler scheduler,
ClassLoader classLoader,
HazelcastProperties properties) |
DefaultNearCacheManager(SerializationService ss,
TaskScheduler es,
ClassLoader classLoader,
HazelcastProperties properties) |
Constructor and Description |
---|
RepairingHandler(ILogger logger,
String localUuid,
String name,
NearCache nearCache,
SerializationService serializationService,
MinimalPartitionService partitionService) |
RepairingTask(HazelcastProperties properties,
InvalidationMetaDataFetcher invalidationMetaDataFetcher,
TaskScheduler scheduler,
SerializationService serializationService,
MinimalPartitionService partitionService,
String localUuid,
ILogger logger) |
Constructor and Description |
---|
NearCachePreloader(String nearCacheName,
NearCachePreloaderConfig preloaderConfig,
NearCacheStatsImpl nearCacheStats,
SerializationService serializationService) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
AbstractNearCacheRecordStore.serializationService |
Constructor and Description |
---|
AbstractNearCacheRecordStore(NearCacheConfig nearCacheConfig,
NearCacheStatsImpl nearCacheStats,
SerializationService serializationService,
ClassLoader classLoader) |
AbstractNearCacheRecordStore(NearCacheConfig nearCacheConfig,
SerializationService serializationService,
ClassLoader classLoader) |
NearCacheDataRecordStore(String name,
NearCacheConfig nearCacheConfig,
SerializationService serializationService,
ClassLoader classLoader) |
NearCacheObjectRecordStore(String name,
NearCacheConfig nearCacheConfig,
SerializationService serializationService,
ClassLoader classLoader) |
Modifier and Type | Interface and Description |
---|---|
interface |
InternalSerializationService |
Modifier and Type | Method and Description |
---|---|
<T extends SerializationService> |
SerializationServiceBuilder.build() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSerializationService |
class |
SerializationServiceV1 |
Modifier and Type | Method and Description |
---|---|
SerializationService |
ObjectDataOutputStream.getSerializationService() |
Modifier and Type | Method and Description |
---|---|
boolean |
ValueComparator.isEqual(Object value1,
Object value2,
SerializationService ss) |
Modifier and Type | Method and Description |
---|---|
static <K,V> EntryView<K,V> |
EntryViews.createLazyEntryView(K key,
V value,
Record record,
SerializationService serializationService,
MapMergePolicy mergePolicy) |
<K,V> void |
MapEntries.putAllToMap(SerializationService serializationService,
Map<K,V> map) |
static <K,V> EntryView<K,V> |
EntryViews.toLazyEntryView(EntryView<K,V> entryView,
SerializationService serializationService,
MapMergePolicy mergePolicy) |
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 |
---|---|
protected SerializationService |
MapQueryPartitionIterator.getSerializationService() |
protected SerializationService |
MapPartitionIterator.getSerializationService() |
protected abstract SerializationService |
AbstractMapPartitionIterator.getSerializationService() |
protected abstract SerializationService |
AbstractMapQueryPartitionIterator.getSerializationService() |
Constructor and Description |
---|
DeserializingEventJournalMapEvent(SerializationService serializationService,
InternalEventJournalMapEvent je) |
Modifier and Type | Method and Description |
---|---|
SerializationService |
MapStoreContext.getSerializationService() |
Modifier and Type | Method and Description |
---|---|
Result |
Query.createResult(SerializationService serializationService,
long limit) |
static Set |
QueryResultUtils.transformToSet(SerializationService ss,
QueryResult queryResult,
Predicate predicate,
IterationType iterationType,
boolean unique,
boolean binary) |
Constructor and Description |
---|
AggregationResult(Aggregator aggregator,
SerializationService serializationService) |
AggregationResultProcessor(AccumulationExecutor accumulationExecutor,
SerializationService serializationService) |
CallerRunsAccumulationExecutor(SerializationService serializationService) |
ParallelAccumulationExecutor(ManagedExecutorService executor,
SerializationService serializationService,
int callTimeoutInMillis) |
QueryResult(IterationType iterationType,
Projection projection,
SerializationService serializationService,
long resultLimit,
boolean orderAndLimitExpected)
Constructs an empty result.
|
QueryResultCollection(SerializationService serializationService,
IterationType iterationType,
boolean binary,
boolean distinct,
QueryResult queryResult) |
QueryResultProcessor(SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultQueryCacheEventData.setSerializationService(SerializationService serializationService) |
void |
QueryCacheEventData.setSerializationService(SerializationService serializationService) |
Constructor and Description |
---|
LocalEntryEventData(SerializationService serializationService,
String source,
int eventType,
Object key,
Object oldValue,
Object value,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
static IMapEvent |
EventPublisherHelper.createIMapEvent(EventData eventData,
EventFilter filter,
Member member,
SerializationService serializationService) |
Constructor and Description |
---|
QueryCacheRecordHashMap(SerializationService serializationService,
int initialCapacity) |
Constructor and Description |
---|
DataQueryCacheRecordFactory(SerializationService serializationService) |
ObjectQueryCacheRecordFactory(SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
static Object |
Records.getValueOrCachedValue(Record record,
SerializationService serializationService)
Return cached value where appropriate, otherwise return the actual value.
|
Constructor and Description |
---|
DataRecordFactory(MapConfig config,
SerializationService serializationService,
PartitioningStrategy partitionStrategy) |
ObjectRecordFactory(MapConfig config,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
MapEntriesWithCursor |
StorageImpl.fetchEntries(int tableIndex,
int size,
SerializationService serializationService) |
MapEntriesWithCursor |
Storage.fetchEntries(int tableIndex,
int size,
SerializationService serializationService)
Fetch minimally
size items from the tableIndex position. |
Constructor and Description |
---|
LazyEntryViewFromRecord(R record,
SerializationService serializationService) |
StorageSCHM(SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
SerializationService |
MultiMapService.getSerializationService() |
Modifier and Type | Method and Description |
---|---|
SerializationService |
ObjectDataOutput.getSerializationService() |
Modifier and Type | Method and Description |
---|---|
static Indexes.Builder |
Indexes.newBuilder(SerializationService ss,
IndexCopyBehavior indexCopyBehavior) |
Constructor and Description |
---|
ReplicationOperation(SerializationService serializationService,
PartitionContainer container,
int partitionId) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
AbstractBaseReplicatedRecordStore.serializationService |
Constructor and Description |
---|
ReplicatedMapEntryView(SerializationService serializationService) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
ReadResultSetImpl.serializationService |
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 |
ReadResultSetImpl.setSerializationService(SerializationService serializationService) |
Constructor and Description |
---|
ReadResultSetImpl(int minSize,
int maxSize,
SerializationService serializationService,
IFunction<O,Boolean> filter) |
ReadResultSetImpl(int minSize,
int maxSize,
SerializationService serializationService,
Predicate<? super O> predicate,
Projection<? super O,E> projection) |
Modifier and Type | Method and Description |
---|---|
void |
PortableReadResultSet.setSerializationService(SerializationService serializationService) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
Offload.serializationService |
Modifier and Type | Method and Description |
---|---|
SerializationService |
NodeEngine.getSerializationService()
Gets the SerializationService.
|
Modifier and Type | Method and Description |
---|---|
SerializationService |
SerializationServiceSupport.getSerializationService() |
SerializationService |
NodeEngineImpl.getSerializationService() |
Constructor and Description |
---|
UnmodifiableLazyList(List list,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
void |
SerializationServiceAware.setSerializationService(SerializationService serializationService)
Gets the SerializationService reference injected.
|
Constructor and Description |
---|
DataAwareMessage(String topicName,
Data messageData,
long publishTime,
Member publishingMember,
SerializationService serializationService) |
Constructor and Description |
---|
MessageRunner(String id,
ReliableMessageListener<E> listener,
Ringbuffer<ReliableTopicMessage> ringbuffer,
String topicName,
int batchSze,
SerializationService serializationService,
Executor executor,
ConcurrentMap<String,MessageRunner<E>> runnersMap,
ILogger logger) |
Modifier and Type | Method and Description |
---|---|
static <C> void |
CollectionUtil.objectToDataCollection(Collection<C> objectCollection,
Collection<Data> dataCollection,
SerializationService serializationService,
String errorMessage)
Converts a collection of any type to a collection of
Data . |
static <C> Collection<Data> |
CollectionUtil.objectToDataCollection(Collection<C> collection,
SerializationService serializationService)
Converts a collection of any type to a collection of
Data . |
Constructor and Description |
---|
CompletedFuture(SerializationService serializationService,
Object value,
Executor userExecutor) |
DelegatingFuture(InternalCompletableFuture future,
SerializationService serializationService) |
DelegatingFuture(InternalCompletableFuture future,
SerializationService serializationService,
V result)
Creates a DelegatingFuture
|
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.