Package | Description |
---|---|
com.hazelcast.collection.impl.collection | |
com.hazelcast.collection.impl.collection.operations | |
com.hazelcast.collection.impl.queue | |
com.hazelcast.collection.impl.queue.operations |
This package contains the IQueue operations
|
com.hazelcast.concurrent.atomiclong |
This package contains IAtomicLong functionality for Hazelcast.
The IAtomicLong is the distributed version of the AtomicLong . |
com.hazelcast.concurrent.atomicreference |
This package contains IAtomicReferece functionality for Hazelcast.
The IAtomicReference is the distributed version of the AtomicReference . |
com.hazelcast.spi.impl.merge |
This package contains split-brain related classes.
|
com.hazelcast.spi.merge |
This package contains out-of-the-box split-brain merge policies.
|
Modifier and Type | Method and Description |
---|---|
CollectionItem |
CollectionContainer.merge(MergingValue<Data> mergingValue,
SplitBrainMergePolicy mergePolicy)
Merges the given
MergingValue via the given SplitBrainMergePolicy . |
Constructor and Description |
---|
CollectionMergeOperation(String name,
SplitBrainMergePolicy mergePolicy,
List<MergingValue<Data>> mergingValues) |
Modifier and Type | Method and Description |
---|---|
QueueItem |
QueueContainer.merge(MergingValue<Data> mergingValue,
SplitBrainMergePolicy mergePolicy)
Merges the given
MergingValue via the given SplitBrainMergePolicy . |
Constructor and Description |
---|
QueueMergeOperation(String name,
SplitBrainMergePolicy mergePolicy,
List<MergingValue<Data>> mergingValues) |
Modifier and Type | Method and Description |
---|---|
Long |
AtomicLongContainer.merge(MergingValue<Long> mergingValue,
SplitBrainMergePolicy mergePolicy,
boolean isExistingContainer,
SerializationService serializationService)
Merges the given
MergingValue via the given SplitBrainMergePolicy . |
Modifier and Type | Method and Description |
---|---|
Data |
AtomicReferenceContainer.merge(MergingValue<Data> mergingValue,
SplitBrainMergePolicy mergePolicy,
boolean isExistingContainer,
SerializationService serializationService)
Merges the given
MergingValue via the given SplitBrainMergePolicy . |
Modifier and Type | Class and Description |
---|---|
class |
FullMergingEntryImpl<K,V>
Implementation of
MergingEntry and all other merging type interfaces. |
class |
MergingEntryImpl<K,V>
Implementation of
MergingEntry . |
class |
MergingValueImpl<V>
Implementation of
MergingValue . |
Modifier and Type | Method and Description |
---|---|
static MergingValue<Data> |
MergingValueFactory.createMergingValue(SerializationService serializationService,
CollectionItem item) |
static MergingValue<Data> |
MergingValueFactory.createMergingValue(SerializationService serializationService,
QueueItem item) |
static <V> MergingValue<V> |
MergingValueFactory.createMergingValue(SerializationService serializationService,
V value) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSplitBrainMergePolicy.checkInstanceOf(MergingValue mergingValue,
Class<?> clazz) |
<V> V |
AbstractSplitBrainMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
AbstractSplitBrainMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
Modifier and Type | Interface and Description |
---|---|
interface |
MergingEntry<K,V>
Represents a read-only view of a data structure key/value-pair for the merging process after a split-brain.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
DiscardMergePolicy.merge(MergingValue<T> mergingValue,
MergingValue<T> existingValue) |
<T> T |
DiscardMergePolicy.merge(MergingValue<T> mergingValue,
MergingValue<T> existingValue) |
<V> V |
HyperLogLogMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
HyperLogLogMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
PassThroughMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
PassThroughMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
LatestAccessMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
LatestAccessMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
LatestUpdateMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
LatestUpdateMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
SplitBrainMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue)
Selects the value of either the merging or the existing
MergingValue which should be merged. |
<V> V |
SplitBrainMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue)
Selects the value of either the merging or the existing
MergingValue which should be merged. |
<V> V |
HigherHitsMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
HigherHitsMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
PutIfAbsentMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
<V> V |
PutIfAbsentMergePolicy.merge(MergingValue<V> mergingValue,
MergingValue<V> existingValue) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.