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 |
Implementation classes of the com.hazelcast.client interfaces
|
com.hazelcast.client.impl.protocol.codec.holder | |
com.hazelcast.client.impl.protocol.task.dynamicconfig | |
com.hazelcast.client.impl.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
com.hazelcast.client.impl.spi.impl.listener | |
com.hazelcast.client.map.impl | |
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 |
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.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.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.merge |
This package contains split-brain related classes.
|
com.hazelcast.spi.impl.operationservice |
Contains the
com.hazelcast.spi.impl.operationservice.InternalOperationService API. |
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 |
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 . |
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) |
ClientInterceptingDelegatingFuture(ClientInvocationFuture clientInvocationFuture,
SerializationService serializationService,
ClientMessageDecoder clientMessageDecoder,
BiConsumer<V,Throwable> interceptor) |
Modifier and Type | Method and Description |
---|---|
<K,V> CacheConfig<K,V> |
CacheConfigHolder.asCacheConfig(SerializationService serializationService) |
static <K,V> CacheConfigHolder |
CacheConfigHolder.of(CacheConfig<K,V> config,
SerializationService serializationService) |
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 |
ClientProxy.getSerializationService() |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
AbstractClientListenerService.serializationService |
Modifier and Type | Method and Description |
---|---|
protected SerializationService |
ClientMapPartitionIterator.getSerializationService() |
protected SerializationService |
ClientMapQueryPartitionIterator.getSerializationService() |
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,
UUID localUuid,
String name,
NearCache nearCache,
SerializationService serializationService,
MinimalPartitionService partitionService) |
RepairingTask(HazelcastProperties properties,
InvalidationMetaDataFetcher invalidationMetaDataFetcher,
TaskScheduler scheduler,
SerializationService serializationService,
MinimalPartitionService partitionService,
UUID 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 | Method and Description |
---|---|
void |
SerializationServiceAware.setSerializationService(SerializationService serializationService)
Gets the SerializationService reference injected.
|
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 |
---|---|
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 . |
Modifier and Type | Method and Description |
---|---|
boolean |
ValueComparator.isEqual(Object value1,
Object value2,
SerializationService ss) |
Modifier and Type | Method and Description |
---|---|
<K,V> void |
MapEntries.putAllToMap(SerializationService serializationService,
Map<K,V> map) |
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 unique) |
QueryResultCollection(SerializationService serializationService,
IterationType iterationType,
boolean binary,
boolean unique,
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 | Method and Description |
---|---|
SerializationService |
NodeEngine.getSerializationService()
Gets the SerializationService.
|
SerializationService |
SerializationServiceSupport.getSerializationService() |
SerializationService |
NodeEngineImpl.getSerializationService() |
Modifier and Type | Method and Description |
---|---|
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newCompletedFuture(Object result,
SerializationService serializationService)
Creates a new
InternalCompletableFuture that is already completed with the value given
as argument as its completion value. |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newCompletedFuture(Object result,
SerializationService serializationService,
Executor defaultAsyncExecutor)
Creates a new
InternalCompletableFuture that is already completed with the value given
as argument as its completion value and the provided defaultAsyncExecutor as the default
executor for execution of next stages registered with default async methods (i.e. |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newDelegatingFuture(SerializationService serializationService,
InternalCompletableFuture<Data> future)
Creates a new
InternalCompletableFuture that delegates to the given future and
deserializes its completion value of type Data . |
Constructor and Description |
---|
DelegatingCompletableFuture(SerializationService serializationService,
CompletableFuture future) |
DelegatingCompletableFuture(SerializationService serializationService,
CompletableFuture future,
V result) |
DeserializingCompletableFuture(SerializationService serializationService,
boolean deserialize) |
DeserializingCompletableFuture(SerializationService serializationService,
Executor defaultAsyncExecutor,
boolean deserialize) |
UnmodifiableLazyList(List list,
SerializationService serializationService) |
Modifier and Type | Field and Description |
---|---|
protected SerializationService |
Offload.serializationService |
Constructor and Description |
---|
DataAwareMessage(String topicName,
Data messageData,
long publishTime,
Member publishingMember,
SerializationService serializationService) |
Constructor and Description |
---|
MessageRunner(UUID id,
ReliableMessageListener<E> listener,
Ringbuffer<ReliableTopicMessage> ringbuffer,
String topicName,
int batchSze,
SerializationService serializationService,
Executor executor,
ConcurrentMap<UUID,MessageRunner<E>> runnersMap,
ILogger logger) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.