Package | Description |
---|---|
com.hazelcast.aggregation.impl | |
com.hazelcast.cache |
This package contains the public API extension for Hazelcast JCache,
the Hazelcast implementation of the JSR-107 commonly referred to as JCache.
|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.event |
Event classes to define listenters for JCache other than EntryListener
|
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.operation |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.record |
Hazelcast JSR-107 aka JCache implementation
Internal record store
|
com.hazelcast.cardinality.impl | |
com.hazelcast.cardinality.impl.hyperloglog.impl |
This package contains implementations of
HyperLogLog . |
com.hazelcast.cardinality.impl.operations |
This package contains the operations on the
CardinalityEstimator . |
com.hazelcast.client.impl.operations |
Contains client operations
|
com.hazelcast.client.impl.protocol.task.cache |
Client protocol tasks implementations for JCache
|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.collection.impl | |
com.hazelcast.collection.impl.collection | |
com.hazelcast.collection.impl.collection.operations | |
com.hazelcast.collection.impl.list.operations | |
com.hazelcast.collection.impl.queue | |
com.hazelcast.collection.impl.queue.operations |
This package contains the IQueue operations
|
com.hazelcast.collection.impl.set.operations | |
com.hazelcast.collection.impl.txncollection | |
com.hazelcast.collection.impl.txncollection.operations | |
com.hazelcast.collection.impl.txnqueue | |
com.hazelcast.collection.impl.txnqueue.operations | |
com.hazelcast.concurrent.atomiclong.operations |
This package contains the operations on the IAtomicLong.
|
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.operations |
This package contains the operations on the ICountDownLatch.
|
com.hazelcast.concurrent.lock | |
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.operations |
This package contains the operations on the ISemaphore.
|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
com.hazelcast.console |
This package contains classes related to ConsoleApp
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.durableexecutor.impl |
Contains the
DurableExecutorService implementation classes. |
com.hazelcast.durableexecutor.impl.operations |
This package contains operations for the DurableExecutorService.
|
com.hazelcast.executor.impl |
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.impl.operations |
This package contains operations for the IExecutorService.
|
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.internal.ascii.memcache |
This package contains MemoryCache functionality for Hazelcast.
|
com.hazelcast.internal.ascii.rest |
This package contains Reset functionality for Hazelcast.
|
com.hazelcast.internal.cluster |
Contains the internals for cluster management like discovery, joining etc.
|
com.hazelcast.internal.cluster.impl |
This package contains the implementation of the cluster functionality.
|
com.hazelcast.internal.cluster.impl.operations |
This package contains operations for the com.hazelcast.cluster.impl package.
|
com.hazelcast.internal.dynamicconfig |
Classes related to Dynamic Configuration.
|
com.hazelcast.internal.management.dto |
These contain the DTO object to exchange information with the management center.
|
com.hazelcast.internal.management.operation |
Contains operations that are called from Management Center.
|
com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
com.hazelcast.internal.partition |
Contains the internals for partition assignment/management, migration, replication etc.
|
com.hazelcast.internal.partition.operation |
Contains the operations for partition package.
|
com.hazelcast.internal.serialization |
Contains the private serialization API + implementation.
|
com.hazelcast.internal.serialization.impl | |
com.hazelcast.internal.usercodedeployment.impl | |
com.hazelcast.internal.usercodedeployment.impl.operation | |
com.hazelcast.journal |
This package contains supporting classes for data structure specific event journals.
|
com.hazelcast.map.eviction |
This package contains eviction specific classes.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.event | |
com.hazelcast.map.impl.iterator | |
com.hazelcast.map.impl.journal | |
com.hazelcast.map.impl.nearcache.invalidation | |
com.hazelcast.map.impl.operation |
Package for map 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.operation |
This package contains Enterprise specific operations for
QueryCache . |
com.hazelcast.map.impl.record |
Contains record specific classes.
|
com.hazelcast.map.impl.tx |
Contains implementation classes for
TransactionalMap |
com.hazelcast.map.impl.wan |
Contains wan replication event classes
|
com.hazelcast.map.merge |
Contains merge policies for
IMap |
com.hazelcast.mapreduce.aggregation.impl |
This package contains a set of predefined aggregation implementations
|
com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
com.hazelcast.mapreduce.impl.notification |
This package contains all remote node notifications
|
com.hazelcast.mapreduce.impl.operation |
This package contains all remote operations that are needed to control work on
supervising or worker nodes.
|
com.hazelcast.mapreduce.impl.task |
This package contains the base implementation for a standard map reduce job.
|
com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
com.hazelcast.multimap.impl.operations |
Contains operations for Hazelcast MultiMap module.
|
com.hazelcast.multimap.impl.txn |
This package contains the Transaction behavior for the Multimap.
|
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.nio.serialization |
Contains interfaces/classes related to serialization;
such as serializer interfaces, input/output streams.
|
com.hazelcast.partition |
Contains the partition logic for Hazelcast.
|
com.hazelcast.projection.impl | |
com.hazelcast.query |
Contains interfaces/classes related to Hazelcast query and indexing support.
|
com.hazelcast.query.impl |
Contains the implementation classes of the query functionality.
|
com.hazelcast.query.impl.predicates | |
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.replicatedmap.merge |
Contains merge policies for
ReplicatedMap |
com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
com.hazelcast.ringbuffer.impl.operations | |
com.hazelcast.scheduledexecutor.impl | |
com.hazelcast.scheduledexecutor.impl.operations | |
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.eventservice.impl |
Contains the code for the
InternalEventService implementation. |
com.hazelcast.spi.impl.eventservice.impl.operations |
Contains the operations for the
EventServiceImpl . |
com.hazelcast.spi.impl.operationservice.impl.operations |
Contains the Operations being used by the
OperationServiceImpl . |
com.hazelcast.spi.impl.operationservice.impl.responses |
Contains the different responses that can be send as a consequence of an Operation invocation.
|
com.hazelcast.spi.impl.proxyservice.impl |
Contains the implementation of the
InternalProxyService . |
com.hazelcast.spi.impl.proxyservice.impl.operations |
Contains the operations for the
ProxyServiceImpl . |
com.hazelcast.spi.partition |
Contains the SPI for partition logic for Hazelcast.
|
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.transaction |
Provides interfaces/classes for Hazelcast transaction support.
|
com.hazelcast.transaction.impl.operations | |
com.hazelcast.transaction.impl.xa |
Provides implementation for Hazelcast XA transaction support.
|
com.hazelcast.transaction.impl.xa.operations | |
com.hazelcast.version |
This package contains classes to support the versioning API.
|
com.hazelcast.wan |
This package contains the WAN replication API
|
Modifier and Type | Method and Description |
---|---|
void |
LongAverageAggregator.readData(ObjectDataInput in) |
void |
NumberAverageAggregator.readData(ObjectDataInput in) |
void |
FloatingPointSumAggregator.readData(ObjectDataInput in) |
void |
MinByAggregator.readData(ObjectDataInput in) |
void |
BigIntegerSumAggregator.readData(ObjectDataInput in) |
void |
MaxByAggregator.readData(ObjectDataInput in) |
void |
IntegerSumAggregator.readData(ObjectDataInput in) |
void |
BigDecimalAverageAggregator.readData(ObjectDataInput in) |
void |
DoubleSumAggregator.readData(ObjectDataInput in) |
void |
BigDecimalSumAggregator.readData(ObjectDataInput in) |
void |
BigIntegerAverageAggregator.readData(ObjectDataInput in) |
void |
CountAggregator.readData(ObjectDataInput in) |
void |
FixedSumAggregator.readData(ObjectDataInput in) |
void |
MaxAggregator.readData(ObjectDataInput in) |
void |
DistinctValuesAggregator.readData(ObjectDataInput in) |
void |
LongSumAggregator.readData(ObjectDataInput in) |
void |
MinAggregator.readData(ObjectDataInput in) |
void |
IntegerAverageAggregator.readData(ObjectDataInput in) |
void |
DoubleAverageAggregator.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
HazelcastExpiryPolicy.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CacheEntryIterationResult.readData(ObjectDataInput in) |
void |
CacheEventSet.readData(ObjectDataInput in) |
void |
CacheKeyIterationResult.readData(ObjectDataInput in) |
void |
CacheClearResponse.readData(ObjectDataInput in) |
void |
CachePartitionEventData.readData(ObjectDataInput in) |
void |
CacheEventDataImpl.readData(ObjectDataInput in) |
void |
CacheEventListenerAdaptor.readData(ObjectDataInput in) |
protected void |
PreJoinCacheConfig.readKeyValueTypes(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CachePartitionLostEventFilter.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalEventJournalCacheEvent.readData(ObjectDataInput in) |
protected void |
CacheEventJournalReadOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultCacheEntryView.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CacheClearOperationFactory.readData(ObjectDataInput in) |
void |
CacheGetInvalidationMetaDataOperation.MetaDataResponse.readData(ObjectDataInput in) |
void |
CacheNearCacheStateHolder.readData(ObjectDataInput in) |
void |
CacheGetAllOperationFactory.readData(ObjectDataInput in) |
void |
CacheSizeOperationFactory.readData(ObjectDataInput in) |
void |
CacheRemoveAllOperationFactory.readData(ObjectDataInput in) |
void |
CacheLoadAllOperationFactory.readData(ObjectDataInput in) |
protected void |
CacheGetOperation.readInternal(ObjectDataInput in) |
protected void |
CacheManagementConfigOperation.readInternal(ObjectDataInput in) |
protected void |
CacheGetConfigOperation.readInternal(ObjectDataInput in) |
void |
CacheGetInvalidationMetaDataOperation.readInternal(ObjectDataInput in) |
protected void |
CachePutAllOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractMutatingCacheOperation.readInternal(ObjectDataInput in) |
protected void |
CacheEntryIteratorOperation.readInternal(ObjectDataInput in) |
protected void |
CacheCreateConfigOperation.readInternal(ObjectDataInput in) |
protected void |
CacheLoadAllOperation.readInternal(ObjectDataInput in) |
protected void |
CachePutBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CachePutAllBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CacheReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
CacheBackupEntryProcessorOperation.readInternal(ObjectDataInput in) |
protected void |
OnJoinCacheOperation.readInternal(ObjectDataInput in) |
protected void |
CacheListenerRegistrationOperation.readInternal(ObjectDataInput in) |
protected void |
CacheRemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CacheDestroyOperation.readInternal(ObjectDataInput in) |
protected void |
CacheRemoveAllOperation.readInternal(ObjectDataInput in) |
protected void |
CachePutOperation.readInternal(ObjectDataInput in) |
protected void |
CacheReplaceOperation.readInternal(ObjectDataInput in) |
protected void |
CacheGetAllOperation.readInternal(ObjectDataInput in) |
protected void |
CacheRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
CacheEntryProcessorOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractCacheOperation.readInternal(ObjectDataInput in) |
protected void |
CacheGetAndReplaceOperation.readInternal(ObjectDataInput in) |
protected void |
CachePutIfAbsentOperation.readInternal(ObjectDataInput in) |
protected void |
CacheMergeOperation.readInternal(ObjectDataInput in) |
protected void |
CacheKeyIteratorOperation.readInternal(ObjectDataInput in) |
protected void |
CacheRemoveAllBackupOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractCacheRecord.readData(ObjectDataInput in) |
void |
CacheObjectRecord.readData(ObjectDataInput in) |
void |
CacheDataRecord.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CardinalityEstimatorContainer.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SparseHyperLogLogEncoder.readData(ObjectDataInput in) |
void |
HyperLogLogImpl.readData(ObjectDataInput in) |
void |
DenseHyperLogLogEncoder.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
AggregateOperation.readInternal(ObjectDataInput in) |
protected void |
AggregateBackupOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractCardinalityEstimatorOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
OperationFactoryWrapper.readData(ObjectDataInput in) |
protected void |
ClientReAuthOperation.readInternal(ObjectDataInput in) |
protected void |
ClientDisconnectionOperation.readInternal(ObjectDataInput in) |
protected void |
PostJoinClientOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CacheAssignAndGetUuidsOperationFactory.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MapAssignAndGetUuidsOperationFactory.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
static List<Operation> |
CollectionTxnUtil.read(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CollectionEventFilter.readData(ObjectDataInput in) |
void |
CollectionContainer.readData(ObjectDataInput in) |
void |
CollectionEvent.readData(ObjectDataInput in) |
void |
TxCollectionItem.readData(ObjectDataInput in) |
void |
CollectionItem.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
CollectionCompareAndRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionAddAllOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionClearBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionAddAllBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionContainsOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionRemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionAddBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionAddOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ListSetOperation.readInternal(ObjectDataInput in) |
protected void |
ListAddAllOperation.readInternal(ObjectDataInput in) |
protected void |
ListReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
ListSetBackupOperation.readInternal(ObjectDataInput in) |
protected void |
ListSubOperation.readInternal(ObjectDataInput in) |
protected void |
ListRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
ListGetOperation.readInternal(ObjectDataInput in) |
protected void |
ListAddOperation.readInternal(ObjectDataInput in) |
protected void |
ListIndexOfOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
QueueItem.readData(ObjectDataInput in) |
void |
QueueEvent.readData(ObjectDataInput in) |
void |
QueueEventFilter.readData(ObjectDataInput in) |
void |
QueueContainer.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClearBackupOperation.readInternal(ObjectDataInput in) |
protected void |
RemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
OfferOperation.readInternal(ObjectDataInput in) |
protected void |
ContainsOperation.readInternal(ObjectDataInput in) |
protected void |
RemoveOperation.readInternal(ObjectDataInput in) |
protected void |
PollBackupOperation.readInternal(ObjectDataInput in) |
protected void |
DrainBackupOperation.readInternal(ObjectDataInput in) |
protected void |
AddAllOperation.readInternal(ObjectDataInput in) |
protected void |
OfferBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CompareAndRemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
QueueReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
CompareAndRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
DrainOperation.readInternal(ObjectDataInput in) |
protected void |
AddAllBackupOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
SetReplicationOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CollectionTransactionLogRecord.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
CollectionPrepareOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionTxnRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionRollbackBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionTxnAddOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionReserveAddOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionPrepareBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionTxnAddBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionReserveRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionRollbackOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionTxnRemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionCommitOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionTransactionRollbackOperation.readInternal(ObjectDataInput in) |
protected void |
CollectionCommitBackupOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TxQueueItem.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
TxnPrepareOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRollbackOperation.readInternal(ObjectDataInput in) |
protected void |
QueueTransactionRollbackOperation.readInternal(ObjectDataInput in) |
protected void |
TxnOfferOperation.readInternal(ObjectDataInput in) |
protected void |
TxnPrepareBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnPollBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnCommitBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnReserveOfferOperation.readInternal(ObjectDataInput in) |
protected void |
BaseTxnQueueOperation.readInternal(ObjectDataInput in) |
protected void |
TxnReservePollBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRollbackBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnReserveOfferBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnOfferBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnCommitOperation.readInternal(ObjectDataInput in) |
protected void |
TxnPeekOperation.readInternal(ObjectDataInput in) |
protected void |
TxnReservePollOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
SetOperation.readInternal(ObjectDataInput in) |
protected void |
GetAndSetOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractAlterOperation.readInternal(ObjectDataInput in) |
protected void |
AtomicLongReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
SetBackupOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractAtomicLongOperation.readInternal(ObjectDataInput in) |
protected void |
CompareAndSetOperation.readInternal(ObjectDataInput in) |
protected void |
AddAndGetOperation.readInternal(ObjectDataInput in) |
protected void |
GetAndAddOperation.readInternal(ObjectDataInput in) |
protected void |
AddBackupOperation.readInternal(ObjectDataInput in) |
protected void |
ApplyOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
SetOperation.readInternal(ObjectDataInput in) |
protected void |
AtomicReferenceReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
ContainsOperation.readInternal(ObjectDataInput in) |
protected void |
GetAndSetOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractAlterOperation.readInternal(ObjectDataInput in) |
protected void |
SetAndGetOperation.readInternal(ObjectDataInput in) |
protected void |
SetBackupOperation.readInternal(ObjectDataInput in) |
protected void |
CompareAndSetOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractAtomicReferenceOperation.readInternal(ObjectDataInput in) |
protected void |
ApplyOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CountDownLatchContainer.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
SetCountOperation.readInternal(ObjectDataInput in) |
protected void |
CountDownLatchReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
CountDownLatchBackupOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalLockNamespace.readData(ObjectDataInput in) |
void |
LockStoreImpl.readData(ObjectDataInput in) |
static ObjectNamespace |
ObjectNamespaceSerializationHelper.readNamespaceCompatibly(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
BeforeAwaitBackupOperation.readInternal(ObjectDataInput in) |
protected void |
BeforeAwaitOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractLockOperation.readInternal(ObjectDataInput in) |
protected void |
UnlockBackupOperation.readInternal(ObjectDataInput in) |
protected void |
LockReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
UnlockOperation.readInternal(ObjectDataInput in) |
protected void |
LocalLockCleanupOperation.readInternal(ObjectDataInput in) |
protected void |
AwaitOperation.readInternal(ObjectDataInput in) |
protected void |
AwaitBackupOperation.readInternal(ObjectDataInput in) |
protected void |
LockBackupOperation.readInternal(ObjectDataInput in) |
protected void |
UnlockIfLeaseExpiredOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SemaphoreContainer.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SemaphoreDetachMemberOperation.readInternal(ObjectDataInput in) |
void |
SemaphoreBackupOperation.readInternal(ObjectDataInput in) |
protected void |
SemaphoreReplicationOperation.readInternal(ObjectDataInput in) |
void |
SemaphoreOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TopicConfig.readData(ObjectDataInput in) |
void |
LockConfig.readData(ObjectDataInput in) |
void |
QueueStoreConfig.readData(ObjectDataInput in) |
void |
WanConsumerConfig.readData(ObjectDataInput in) |
void |
ScheduledExecutorConfig.readData(ObjectDataInput in) |
void |
WanReplicationRef.readData(ObjectDataInput in) |
void |
PartitioningStrategyConfig.readData(ObjectDataInput in) |
void |
CacheSimpleConfig.readData(ObjectDataInput in) |
void |
CacheSimpleConfig.ExpiryPolicyFactoryConfig.readData(ObjectDataInput in) |
void |
CacheSimpleConfig.ExpiryPolicyFactoryConfig.TimedExpiryPolicyFactoryConfig.readData(ObjectDataInput in) |
void |
CacheSimpleConfig.ExpiryPolicyFactoryConfig.DurationConfig.readData(ObjectDataInput in) |
void |
MultiMapConfig.readData(ObjectDataInput in) |
void |
EventJournalConfig.readData(ObjectDataInput in) |
void |
MapConfig.readData(ObjectDataInput in) |
void |
WanReplicationConfig.readData(ObjectDataInput in) |
void |
WanPublisherConfig.readData(ObjectDataInput in) |
void |
ReliableTopicConfig.readData(ObjectDataInput in) |
void |
QueueConfig.readData(ObjectDataInput in) |
void |
MapStoreConfig.readData(ObjectDataInput in) |
void |
NearCacheConfig.readData(ObjectDataInput in) |
void |
CacheConfig.readData(ObjectDataInput in) |
void |
ExecutorConfig.readData(ObjectDataInput in) |
void |
ItemListenerConfig.readData(ObjectDataInput in) |
void |
LegacyCacheEvictionConfig.readData(ObjectDataInput in) |
void |
MapAttributeConfig.readData(ObjectDataInput in) |
void |
CacheSimpleEntryListenerConfig.readData(ObjectDataInput in) |
void |
CardinalityEstimatorConfig.readData(ObjectDataInput in) |
void |
EvictionConfig.readData(ObjectDataInput in) |
void |
RingbufferConfig.readData(ObjectDataInput in) |
void |
CollectionConfig.readData(ObjectDataInput in) |
void |
HotRestartConfig.readData(ObjectDataInput in) |
void |
QueryCacheConfig.readData(ObjectDataInput in) |
void |
ListenerConfig.readData(ObjectDataInput in) |
void |
NearCachePreloaderConfig.readData(ObjectDataInput in) |
void |
PredicateConfig.readData(ObjectDataInput in) |
void |
MapIndexConfig.readData(ObjectDataInput in) |
void |
ReplicatedMapConfig.readData(ObjectDataInput in) |
void |
MaxSizeConfig.readData(ObjectDataInput in) |
void |
EntryListenerConfig.readData(ObjectDataInput in) |
void |
EntryListenerConfig.MapListenerToEntryListenerAdapter.readData(ObjectDataInput in) |
void |
SemaphoreConfig.readData(ObjectDataInput in) |
void |
DurableExecutorConfig.readData(ObjectDataInput in) |
void |
LegacyCacheConfig.readData(ObjectDataInput in) |
void |
RingbufferStoreConfig.readData(ObjectDataInput in) |
void |
QuorumConfig.readData(ObjectDataInput in) |
protected void |
CacheConfig.readKeyValueTypes(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
Echo.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionAwareKey.readData(ObjectDataInput in) |
void |
MemberAttributeEvent.readData(ObjectDataInput in) |
void |
MigrationEvent.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TaskRingBuffer.read(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
PutResultBackupOperation.readInternal(ObjectDataInput in) |
protected void |
DisposeResultOperation.readInternal(ObjectDataInput in) |
protected void |
DisposeResultBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TaskBackupOperation.readInternal(ObjectDataInput in) |
protected void |
PutResultOperation.readInternal(ObjectDataInput in) |
protected void |
RetrieveResultOperation.readInternal(ObjectDataInput in) |
protected void |
TaskOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RunnableAdapter.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
CancellationOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMember.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MemcacheEntry.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RestValue.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MemberInfo.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ConfigCheck.readData(ObjectDataInput in) |
void |
BindMessage.readData(ObjectDataInput in) |
void |
ClusterStateTransactionLogRecord.readData(ObjectDataInput in) |
void |
SplitBrainJoinMessage.readData(ObjectDataInput in) |
void |
MembersView.readData(ObjectDataInput in) |
void |
JoinRequest.readData(ObjectDataInput in) |
void |
MembersViewMetadata.readData(ObjectDataInput in) |
void |
JoinMessage.readData(ObjectDataInput in) |
void |
ClusterStateChange.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
HeartbeatOp.readInternal(ObjectDataInput in) |
protected void |
LockClusterStateOp.readInternal(ObjectDataInput in) |
protected void |
BeforeJoinCheckFailureOp.readInternal(ObjectDataInput in) |
protected void |
TriggerExplicitSuspicionOp.readInternal(ObjectDataInput in) |
protected void |
RollbackClusterStateOp.readInternal(ObjectDataInput in) |
protected void |
CommitClusterStateOp.readInternal(ObjectDataInput in) |
protected void |
OnJoinOp.readInternal(ObjectDataInput in) |
protected void |
SplitBrainMergeValidationOp.readInternal(ObjectDataInput in) |
protected void |
ConfigMismatchOp.readInternal(ObjectDataInput in) |
protected void |
MasterResponseOp.readInternal(ObjectDataInput in) |
protected void |
JoinRequestOp.readInternal(ObjectDataInput in) |
protected void |
WhoisMasterOp.readInternal(ObjectDataInput in) |
protected void |
AuthorizationOp.readInternal(ObjectDataInput in) |
protected void |
FetchMembersViewOp.readInternal(ObjectDataInput in) |
protected void |
MemberRemoveOperation.readInternal(ObjectDataInput in)
Deprecated.
|
protected void |
ExplicitSuspicionOp.readInternal(ObjectDataInput in) |
protected void |
HeartbeatComplaintOp.readInternal(ObjectDataInput in) |
protected void |
MasterConfirmationOp.readInternal(ObjectDataInput in) |
protected void |
MemberAttributeChangedOp.readInternal(ObjectDataInput in) |
protected void |
MergeClustersOp.readInternal(ObjectDataInput in) |
protected void |
FinalizeJoinOp.readInternalImpl(ObjectDataInput in) |
protected void |
MembersUpdateOp.readInternalImpl(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
DynamicConfigPreJoinOperation.readInternal(ObjectDataInput in) |
protected void |
AddDynamicConfigOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MapConfigDTO.readData(ObjectDataInput in) |
void |
PermissionConfigDTO.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ScriptExecutorOperation.readInternal(ObjectDataInput in) |
protected void |
UpdateManagementCenterUrlOperation.readInternal(ObjectDataInput in) |
protected void |
AddWanConfigOperation.readInternal(ObjectDataInput in) |
protected void |
UpdateMapConfigOperation.readInternal(ObjectDataInput in) |
protected void |
UpdatePermissionConfigOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
BatchNearCacheInvalidation.readData(ObjectDataInput in) |
void |
Invalidation.readData(ObjectDataInput in) |
void |
SingleNearCacheInvalidation.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionRuntimeState.readData(ObjectDataInput in) |
void |
NonFragmentedServiceNamespace.readData(ObjectDataInput in) |
void |
ReplicaFragmentMigrationState.readData(ObjectDataInput in) |
void |
MigrationInfo.readData(ObjectDataInput in) |
static PartitionTableView |
PartitionTableView.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
MigrationRequestOperation.readInternal(ObjectDataInput in) |
protected void |
PromotionCommitOperation.readInternal(ObjectDataInput in) |
protected void |
MigrationCommitOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionReplicaSyncRequest.readInternal(ObjectDataInput in) |
protected void |
PartitionBackupReplicaAntiEntropyOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionReplicaSyncResponse.readInternal(ObjectDataInput in) |
protected void |
FinalizeMigrationOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionReplicaSyncRetryResponse.readInternal(ObjectDataInput in) |
protected void |
MigrationOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionStateOperation.readInternal(ObjectDataInput in) |
protected void |
LegacyMigrationOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
<T> T |
InternalSerializationService.readObject(ObjectDataInput in) |
<T> T |
InternalSerializationService.readObject(ObjectDataInput in,
Class aClass) |
Modifier and Type | Class and Description |
---|---|
class |
ObjectDataInputStream |
Modifier and Type | Method and Description |
---|---|
ObjectDataInput |
DefaultPortableReader.getRawDataInput() |
ObjectDataInput |
SerializationServiceV1.initDataSerializableInputAndSkipTheHeader(Data data)
Init the ObjectDataInput for the given Data skipping the serialization header-bytes and navigating to the position
from where the readData() starts reading the object fields.
|
Modifier and Type | Method and Description |
---|---|
LinkedList |
LinkedListStreamSerializer.read(ObjectDataInput in) |
ArrayList |
ArrayListStreamSerializer.read(ObjectDataInput in) |
Externalizable |
JavaDefaultSerializers.ExternalizableSerializer.read(ObjectDataInput in) |
BigInteger |
JavaDefaultSerializers.BigIntegerSerializer.read(ObjectDataInput in) |
BigDecimal |
JavaDefaultSerializers.BigDecimalSerializer.read(ObjectDataInput in) |
Date |
JavaDefaultSerializers.DateSerializer.read(ObjectDataInput in) |
Class |
JavaDefaultSerializers.ClassSerializer.read(ObjectDataInput in) |
Object |
JavaDefaultSerializers.JavaSerializer.read(ObjectDataInput in) |
Enum |
JavaDefaultSerializers.EnumSerializer.read(ObjectDataInput in) |
Object |
ConstantSerializers.NullSerializer.read(ObjectDataInput in) |
Byte |
ConstantSerializers.ByteSerializer.read(ObjectDataInput in) |
Boolean |
ConstantSerializers.BooleanSerializer.read(ObjectDataInput in) |
Character |
ConstantSerializers.CharSerializer.read(ObjectDataInput in) |
Short |
ConstantSerializers.ShortSerializer.read(ObjectDataInput in) |
Integer |
ConstantSerializers.IntegerSerializer.read(ObjectDataInput in) |
Long |
ConstantSerializers.LongSerializer.read(ObjectDataInput in) |
Float |
ConstantSerializers.FloatSerializer.read(ObjectDataInput in) |
Double |
ConstantSerializers.DoubleSerializer.read(ObjectDataInput in) |
String |
ConstantSerializers.StringSerializer.read(ObjectDataInput in) |
boolean[] |
ConstantSerializers.BooleanArraySerializer.read(ObjectDataInput in) |
char[] |
ConstantSerializers.CharArraySerializer.read(ObjectDataInput in) |
short[] |
ConstantSerializers.ShortArraySerializer.read(ObjectDataInput in) |
int[] |
ConstantSerializers.IntegerArraySerializer.read(ObjectDataInput in) |
long[] |
ConstantSerializers.LongArraySerializer.read(ObjectDataInput in) |
float[] |
ConstantSerializers.FloatArraySerializer.read(ObjectDataInput in) |
double[] |
ConstantSerializers.DoubleArraySerializer.read(ObjectDataInput in) |
String[] |
ConstantSerializers.StringArraySerializer.read(ObjectDataInput in) |
static <T> List<T> |
SerializationUtil.readNullableList(ObjectDataInput in)
Read a list written by
SerializationUtil.writeNullableList(List, ObjectDataOutput)
It does not gurantee to use the same implementation of a list as was written
into the stream. |
<T> T |
AbstractSerializationService.readObject(ObjectDataInput in) |
<T> T |
AbstractSerializationService.readObject(ObjectDataInput in,
Class aClass) |
Modifier and Type | Method and Description |
---|---|
void |
ClassData.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClassDataFinderOperation.readInternal(ObjectDataInput in) |
protected void |
DeployClassesOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
EventJournalInitialSubscriberState.readData(ObjectDataInput in) |
protected void |
EventJournalReadOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
LRUEvictionPolicy.readData(ObjectDataInput in) |
void |
LFUEvictionPolicy.readData(ObjectDataInput in) |
void |
RandomEvictionPolicy.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MapValueCollection.readData(ObjectDataInput in) |
void |
MapKeySet.readData(ObjectDataInput in) |
void |
EventListenerFilter.readData(ObjectDataInput in) |
void |
MapPartitionLostEventFilter.readData(ObjectDataInput in) |
void |
EntryRemovingProcessor.readData(ObjectDataInput in) |
void |
SimpleEntryView.readData(ObjectDataInput in) |
void |
EntryEventFilter.readData(ObjectDataInput in) |
void |
MapEntries.readData(ObjectDataInput in) |
void |
LazyMapEntry.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
EntryEventData.readData(ObjectDataInput in) |
void |
MapPartitionEventData.readData(ObjectDataInput in) |
void |
MapEventData.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractCursor.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalEventJournalMapEvent.readData(ObjectDataInput in) |
protected void |
MapEventJournalReadOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
UuidFilter.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ContainsValueOperationFactory.readData(ObjectDataInput in) |
void |
MapLoadAllOperationFactory.readData(ObjectDataInput in) |
void |
KeyLoadStatusOperationFactory.readData(ObjectDataInput in) |
void |
PutAllPartitionAwareOperationFactory.readData(ObjectDataInput in) |
void |
PartitionWideEntryOperationFactory.readData(ObjectDataInput in) |
void |
MapFlushOperationFactory.readData(ObjectDataInput in) |
void |
MapGetInvalidationMetaDataOperation.MetaDataResponse.readData(ObjectDataInput in) |
void |
PostJoinMapOperation.InterceptorInfo.readData(ObjectDataInput in) |
void |
WriteBehindStateHolder.readData(ObjectDataInput in) |
void |
MultipleEntryOperationFactory.readData(ObjectDataInput in) |
void |
EvictAllOperationFactory.readData(ObjectDataInput in) |
void |
SizeOperationFactory.readData(ObjectDataInput in) |
void |
MapNearCacheStateHolder.readData(ObjectDataInput in) |
void |
ClearOperationFactory.readData(ObjectDataInput in) |
void |
PartitionWideEntryWithPredicateOperationFactory.readData(ObjectDataInput in) |
void |
AddIndexOperationFactory.readData(ObjectDataInput in) |
void |
MapReplicationStateHolder.readData(ObjectDataInput in) |
void |
IsEmptyOperationFactory.readData(ObjectDataInput in) |
void |
MapGetAllOperationFactory.readData(ObjectDataInput in) |
void |
IsPartitionLoadedOperationFactory.readData(ObjectDataInput in) |
protected void |
RemoveIfSameOperation.readInternal(ObjectDataInput in) |
protected void |
MultipleEntryOperation.readInternal(ObjectDataInput in) |
protected void |
KeyLoadStatusOperation.readInternal(ObjectDataInput in) |
protected void |
MapReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
MapFlushBackupOperation.readInternal(ObjectDataInput in) |
protected void |
RemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
LoadMapOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionWideEntryBackupOperation.readInternal(ObjectDataInput in) |
protected void |
EvictAllOperation.readInternal(ObjectDataInput in) |
protected void |
MapFetchWithQueryOperation.readInternal(ObjectDataInput in) |
protected void |
EvictBatchBackupOperation.readInternal(ObjectDataInput in) |
protected void |
NotifyMapFlushOperation.readInternal(ObjectDataInput in) |
protected void |
EntryOffloadableSetUnlockOperation.readInternal(ObjectDataInput in) |
protected void |
ReplaceIfSameOperation.readInternal(ObjectDataInput in) |
void |
MapGetInvalidationMetaDataOperation.readInternal(ObjectDataInput in) |
protected void |
AwaitMapFlushOperation.readInternal(ObjectDataInput in) |
void |
RemoveInterceptorOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionWideEntryWithPredicateOperation.readInternal(ObjectDataInput in) |
protected void |
PutBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TryRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionWideEntryOperation.readInternal(ObjectDataInput in) |
protected void |
MapFetchEntriesOperation.readInternal(ObjectDataInput in) |
protected void |
PostJoinMapOperation.readInternal(ObjectDataInput in) |
protected void |
ContainsValueOperation.readInternal(ObjectDataInput in) |
protected void |
GetAllOperation.readInternal(ObjectDataInput in) |
protected void |
PutAllBackupOperation.readInternal(ObjectDataInput in) |
void |
AddInterceptorOperation.readInternal(ObjectDataInput in) |
protected void |
MultipleEntryWithPredicateBackupOperation.readInternal(ObjectDataInput in) |
protected void |
EvictBackupOperation.readInternal(ObjectDataInput in) |
protected void |
EntryBackupOperation.readInternal(ObjectDataInput in) |
protected void |
EntryOperation.readInternal(ObjectDataInput in) |
protected void |
MergeOperation.readInternal(ObjectDataInput in) |
protected void |
MultipleEntryBackupOperation.readInternal(ObjectDataInput in) |
protected void |
MutatingKeyBasedMapOperation.readInternal(ObjectDataInput in) |
protected void |
MultipleEntryWithPredicateOperation.readInternal(ObjectDataInput in) |
protected void |
PartitionWideEntryWithPredicateBackupOperation.readInternal(ObjectDataInput in) |
protected void |
ReadonlyKeyBasedMapOperation.readInternal(ObjectDataInput in) |
protected void |
MapFetchKeysOperation.readInternal(ObjectDataInput in) |
protected void |
LoadAllOperation.readInternal(ObjectDataInput in) |
protected void |
RemoveFromLoadAllOperation.readInternal(ObjectDataInput in) |
protected void |
PutAllOperation.readInternal(ObjectDataInput in) |
protected void |
EvictOperation.readInternal(ObjectDataInput in) |
protected void |
AddIndexOperation.readInternal(ObjectDataInput in) |
protected void |
PutFromLoadAllOperation.readInternal(ObjectDataInput in) |
protected void |
PutFromLoadAllBackupOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSegment.readData(ObjectDataInput in) |
void |
Target.readData(ObjectDataInput in) |
void |
QueryEventFilter.readData(ObjectDataInput in) |
void |
AggregationResult.readData(ObjectDataInput in) |
void |
Query.readData(ObjectDataInput in) |
void |
QueryResult.readData(ObjectDataInput in) |
void |
QueryResultRow.readData(ObjectDataInput in) |
protected void |
QueryOperation.readInternal(ObjectDataInput in) |
protected void |
QueryPartitionOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
LocalEntryEventData.readData(ObjectDataInput in) |
void |
DefaultQueryCacheEventData.readData(ObjectDataInput in) |
void |
LocalCacheWideEventData.readData(ObjectDataInput in) |
void |
BatchEventData.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MadePublishableOperationFactory.readData(ObjectDataInput in) |
protected void |
ReadAndResetAccumulatorOperation.readInternal(ObjectDataInput in) |
protected void |
PublisherCreateOperation.readInternal(ObjectDataInput in) |
protected void |
DestroyQueryCacheOperation.readInternal(ObjectDataInput in) |
protected void |
SetReadCursorOperation.readInternal(ObjectDataInput in) |
protected void |
MadePublishableOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RecordReplicationInfo.readData(ObjectDataInput in) |
void |
RecordInfo.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
VersionedValue.readData(ObjectDataInput in) |
void |
MapTransactionLogRecord.readData(ObjectDataInput in) |
protected void |
TxnPrepareOperation.readInternal(ObjectDataInput in) |
protected void |
TxnSetOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRollbackOperation.readInternal(ObjectDataInput in) |
protected void |
TxnPrepareBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnUnlockBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRollbackBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnLockAndGetOperation.readInternal(ObjectDataInput in) |
protected void |
TxnUnlockOperation.readInternal(ObjectDataInput in) |
protected void |
TxnDeleteOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MapReplicationUpdate.readData(ObjectDataInput in) |
void |
MapReplicationRemove.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PassThroughMergePolicy.readData(ObjectDataInput in) |
void |
PutIfAbsentMapMergePolicy.readData(ObjectDataInput in) |
void |
HigherHitsMapMergePolicy.readData(ObjectDataInput in) |
void |
IgnoreMergingEntryMapMergePolicy.readData(ObjectDataInput in) |
void |
LatestUpdateMapMergePolicy.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PredicateSupplier.readData(ObjectDataInput in) |
void |
SetAdapter.readData(ObjectDataInput in) |
void |
KeyPredicateSupplier.readData(ObjectDataInput in) |
void |
AvgTuple.readData(ObjectDataInput in) |
void |
AcceptAllSupplier.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MultiMapKeyValueSource.readData(ObjectDataInput in) |
void |
MapKeyValueSource.readData(ObjectDataInput in) |
void |
SetKeyValueSource.readData(ObjectDataInput in) |
void |
CombinerResultList.readData(ObjectDataInput in) |
void |
HashMapAdapter.readData(ObjectDataInput in) |
void |
ListKeyValueSource.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IntermediateChunkNotification.readData(ObjectDataInput in) |
void |
ReducingFinishedNotification.readData(ObjectDataInput in) |
void |
MapReduceNotification.readData(ObjectDataInput in) |
void |
MemberAwareMapReduceNotification.readData(ObjectDataInput in) |
void |
LastChunkNotification.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
KeysAssignmentResult.readData(ObjectDataInput in) |
void |
GetResultOperationFactory.readData(ObjectDataInput in) |
void |
RequestPartitionResult.readData(ObjectDataInput in) |
protected void |
KeysAssignmentOperation.readInternal(ObjectDataInput in) |
protected void |
PostPonePartitionProcessing.readInternal(ObjectDataInput in) |
protected void |
RequestPartitionReducing.readInternal(ObjectDataInput in) |
void |
StartProcessingJobOperation.readInternal(ObjectDataInput in) |
protected void |
FireNotificationOperation.readInternal(ObjectDataInput in) |
protected void |
ProcessingOperation.readInternal(ObjectDataInput in) |
protected void |
CancelJobSupervisorOperation.readInternal(ObjectDataInput in) |
protected void |
RequestPartitionProcessed.readInternal(ObjectDataInput in) |
protected void |
ProcessStatsUpdateOperation.readInternal(ObjectDataInput in) |
protected void |
NotifyRemoteExceptionOperation.readInternal(ObjectDataInput in) |
void |
KeyValueJobOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
JobPartitionStateImpl.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MultiMapRecord.readData(ObjectDataInput in) |
void |
MultiMapEventFilter.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MultiMapOperationFactory.readData(ObjectDataInput in) |
void |
MultiMapResponse.readData(ObjectDataInput in) |
void |
EntrySetResponse.readData(ObjectDataInput in) |
protected void |
RemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
MultiMapKeyBasedOperation.readInternal(ObjectDataInput in) |
protected void |
RemoveOperation.readInternal(ObjectDataInput in) |
protected void |
PutBackupOperation.readInternal(ObjectDataInput in) |
protected void |
MultiMapBackupAwareOperation.readInternal(ObjectDataInput in) |
protected void |
MultiMapOperation.readInternal(ObjectDataInput in) |
protected void |
ContainsEntryOperation.readInternal(ObjectDataInput in) |
protected void |
MultiMapReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
PutOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MultiMapTransactionLogRecord.readData(ObjectDataInput in) |
protected void |
TxnPrepareOperation.readInternal(ObjectDataInput in) |
protected void |
TxnPutBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnPutOperation.readInternal(ObjectDataInput in) |
protected void |
TxnPrepareBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRemoveBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRemoveOperation.readInternal(ObjectDataInput in) |
protected void |
TxnCommitBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRollbackBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnLockAndGetOperation.readInternal(ObjectDataInput in) |
protected void |
TxnCommitOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRemoveAllBackupOperation.readInternal(ObjectDataInput in) |
protected void |
TxnRemoveAllOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Interface and Description |
---|---|
interface |
BufferObjectDataInput |
Modifier and Type | Method and Description |
---|---|
static Object |
IOUtil.readAttributeValue(ObjectDataInput in) |
static byte[] |
IOUtil.readByteArray(ObjectDataInput in) |
void |
Address.readData(ObjectDataInput in) |
static <T> T |
IOUtil.readObject(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
ObjectDataInput |
PortableReader.getRawDataInput()
|
Modifier and Type | Method and Description |
---|---|
T |
StreamSerializer.read(ObjectDataInput in)
Reads object from objectDataInputStream
|
T |
TypedStreamDeserializer.read(ObjectDataInput in,
Class aClass)
Reads object from objectDataInputStream
|
void |
DataSerializable.readData(ObjectDataInput in)
Reads fields from the input stream
|
Modifier and Type | Method and Description |
---|---|
void |
PartitionLostEvent.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MultiAttributeProjection.readData(ObjectDataInput in) |
void |
SingleAttributeProjection.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PagingPredicate.readData(ObjectDataInput in) |
void |
PartitionPredicate.readData(ObjectDataInput in) |
void |
TruePredicate.readData(ObjectDataInput in) |
void |
PredicateBuilder.readData(ObjectDataInput in) |
void |
SqlPredicate.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MapIndexInfo.readData(ObjectDataInput in) |
void |
IndexImpl.NullObject.readData(ObjectDataInput in) |
void |
FalsePredicate.readData(ObjectDataInput in) |
void |
IndexInfo.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InstanceOfPredicate.readData(ObjectDataInput in) |
void |
AbstractPredicate.readData(ObjectDataInput in) |
void |
BetweenPredicate.readData(ObjectDataInput in) |
void |
EqualPredicate.readData(ObjectDataInput in) |
void |
InPredicate.readData(ObjectDataInput in) |
void |
GreaterLessPredicate.readData(ObjectDataInput in) |
void |
OrPredicate.readData(ObjectDataInput in) |
void |
NotPredicate.readData(ObjectDataInput in) |
void |
AndPredicate.readData(ObjectDataInput in) |
void |
RegexPredicate.readData(ObjectDataInput in) |
void |
LikePredicate.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ClearOperationFactory.readData(ObjectDataInput in) |
void |
PutAllOperationFactory.readData(ObjectDataInput in) |
void |
VersionResponsePair.readData(ObjectDataInput in) |
protected void |
ReplicateUpdateOperation.readInternal(ObjectDataInput in) |
protected void |
ValuesOperation.readInternal(ObjectDataInput in) |
protected void |
ReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
RequestMapDataOperation.readInternal(ObjectDataInput in) |
protected void |
SyncReplicatedMapDataOperation.readInternal(ObjectDataInput in) |
protected void |
GetOperation.readInternal(ObjectDataInput in) |
protected void |
KeySetOperation.readInternal(ObjectDataInput in) |
protected void |
CheckReplicaVersionOperation.readInternal(ObjectDataInput in) |
protected void |
SizeOperation.readInternal(ObjectDataInput in) |
protected void |
ReplicateUpdateToCallerOperation.readInternal(ObjectDataInput in) |
protected void |
RemoveOperation.readInternal(ObjectDataInput in) |
protected void |
ContainsValueOperation.readInternal(ObjectDataInput in) |
protected void |
MergeOperation.readInternal(ObjectDataInput in) |
protected void |
ClearOperation.readInternal(ObjectDataInput in) |
protected void |
IsEmptyOperation.readInternal(ObjectDataInput in) |
protected void |
PutAllOperation.readInternal(ObjectDataInput in) |
protected void |
ContainsKeyOperation.readInternal(ObjectDataInput in) |
protected void |
PutOperation.readInternal(ObjectDataInput in) |
protected void |
EntrySetOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RecordMigrationInfo.readData(ObjectDataInput in) |
void |
ReplicatedMapEntryView.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PassThroughMergePolicy.readData(ObjectDataInput in) |
void |
PutIfAbsentMapMergePolicy.readData(ObjectDataInput in) |
void |
HigherHitsMapMergePolicy.readData(ObjectDataInput in) |
void |
LatestUpdateMapMergePolicy.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ReadResultSetImpl.readData(ObjectDataInput in) |
void |
RingbufferContainer.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
AddOperation.readInternal(ObjectDataInput in) |
protected void |
GenericOperation.readInternal(ObjectDataInput in) |
protected void |
ReadOneOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractRingBufferOperation.readInternal(ObjectDataInput in) |
protected void |
AddAllOperation.readInternal(ObjectDataInput in) |
protected void |
ReadManyOperation.readInternal(ObjectDataInput in) |
protected void |
AddBackupOperation.readInternal(ObjectDataInput in) |
protected void |
AddAllBackupOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ScheduledTaskStatisticsImpl.readData(ObjectDataInput in) |
void |
ScheduledTaskHandlerImpl.readData(ObjectDataInput in) |
void |
TaskDefinition.readData(ObjectDataInput in) |
void |
ScheduledTaskDescriptor.readData(ObjectDataInput in) |
void |
ScheduledRunnableAdapter.readData(ObjectDataInput in) |
void |
ScheduledTaskResult.readData(ObjectDataInput in) |
void |
NamedTaskDecorator.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetAllScheduledOnPartitionOperationFactory.readData(ObjectDataInput in) |
protected void |
CancelTaskBackupOperation.readInternal(ObjectDataInput in) |
protected void |
ReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
IsDoneOperation.readInternal(ObjectDataInput in) |
protected void |
CancelTaskOperation.readInternal(ObjectDataInput in) |
protected void |
IsCanceledOperation.readInternal(ObjectDataInput in) |
protected void |
GetResultOperation.readInternal(ObjectDataInput in) |
protected void |
GetDelayOperation.readInternal(ObjectDataInput in) |
protected void |
ResultReadyNotifyOperation.readInternal(ObjectDataInput in) |
protected void |
ScheduleTaskBackupOperation.readInternal(ObjectDataInput in) |
protected void |
GetStatisticsOperation.readInternal(ObjectDataInput in) |
protected void |
AbstractSchedulerOperation.readInternal(ObjectDataInput in) |
protected void |
ScheduleTaskOperation.readInternal(ObjectDataInput in) |
protected void |
DisposeBackupTaskOperation.readInternal(ObjectDataInput in) |
protected void |
SyncStateOperation.readInternal(ObjectDataInput in) |
protected void |
DisposeTaskOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultObjectNamespace.readData(ObjectDataInput in)
Deprecated.
|
void |
OperationControl.readData(ObjectDataInput in) |
void |
DistributedObjectNamespace.readData(ObjectDataInput in) |
void |
Operation.readData(ObjectDataInput in) |
protected void |
AbstractLocalOperation.readInternal(ObjectDataInput in) |
protected void |
Operation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
UnmodifiableLazyList.readData(ObjectDataInput in) |
void |
BinaryOperationFactory.readData(ObjectDataInput in) |
void |
SerializableList.readData(ObjectDataInput in) |
protected void |
AbstractNamedOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
EventEnvelope.readData(ObjectDataInput in) |
void |
TrueEventFilter.readData(ObjectDataInput in) |
void |
Registration.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
SendEventOperation.readInternal(ObjectDataInput in) |
protected void |
OnJoinRegistrationOperation.readInternal(ObjectDataInput in) |
protected void |
RegistrationOperation.readInternalImpl(ObjectDataInput in) |
protected void |
DeregistrationOperation.readInternalImpl(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionIteratingOperation.PartitionResponse.readData(ObjectDataInput in) |
protected void |
Backup.readInternal(ObjectDataInput in) |
protected void |
PartitionIteratingOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
Response.readData(ObjectDataInput in) |
void |
NormalResponse.readData(ObjectDataInput in) |
void |
ErrorResponse.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DistributedObjectEventPacket.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
DistributedObjectDestroyOperation.readInternal(ObjectDataInput in) |
protected void |
InitializeDistributedObjectOperation.readInternal(ObjectDataInput in) |
protected void |
PostJoinProxyOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IPartitionLostEvent.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TopicEvent.readData(ObjectDataInput in) |
protected void |
PublishOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ReliableTopicMessage.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionOptions.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
CreateTxBackupLogOperation.readInternal(ObjectDataInput in) |
protected void |
BroadcastTxRollbackOperation.readInternal(ObjectDataInput in) |
protected void |
ReplicateTxBackupLogOperation.readInternal(ObjectDataInput in) |
protected void |
RollbackTxBackupLogOperation.readInternal(ObjectDataInput in) |
protected void |
PurgeTxBackupLogOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SerializableXID.readData(ObjectDataInput in) |
void |
XATransactionDTO.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
FinalizeRemoteTransactionOperation.readInternal(ObjectDataInput in) |
protected void |
FinalizeRemoteTransactionBackupOperation.readInternal(ObjectDataInput in) |
protected void |
ClearRemoteTransactionBackupOperation.readInternal(ObjectDataInput in) |
protected void |
PutRemoteTransactionBackupOperation.readInternal(ObjectDataInput in) |
protected void |
ClearRemoteTransactionOperation.readInternal(ObjectDataInput in) |
protected void |
XaReplicationOperation.readInternal(ObjectDataInput in) |
protected void |
PutRemoteTransactionOperation.readInternal(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
Version.readData(ObjectDataInput in) |
void |
MemberVersion.readData(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
WanReplicationEvent.readData(ObjectDataInput in) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.