com.hazelcast.spi.impl.merge

Class AbstractMergeRunnable<K,V,Store,MergingItem extends MergingEntry<K,V>>

java.lang.Object

com.hazelcast.spi.impl.merge.AbstractMergeRunnable<K,V,Store,MergingItem>

Type Parameters:

K - type of the store key

V - type of the store value

Store - type of the store in a partition

MergingItem - type of the merging item

All Implemented Interfaces:

Runnable

public abstract class AbstractMergeRunnable<K,V,Store,MergingItem extends MergingEntry<K,V>>
extends Object
implements Runnable

Used by ICache, IMap and ReplicatedMap to provide a merge runnable for SplitBrainHandlerService.prepareMergeRunnable().

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMergeRunnable(String serviceName, Collection<Store> mergingStores, AbstractSplitBrainHandlerService<Store> splitBrainHandlerService, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
protected abstract OperationFactory	createMergeOperationFactory(String dataStructureName, SplitBrainMergePolicy<V,MergingItem> mergePolicy, int[] partitions, List<MergingItem>[] entries) Returns an OperationFactory for SplitBrainMergePolicy, legacy merge policies don't use this method.
protected abstract int	getBatchSize(String dataStructureName) This batch size can only be used with SplitBrainMergePolicy, legacy merge policies don't support batch data sending.
protected abstract String	getDataStructureName(Store store)
protected abstract InMemoryFormat	getInMemoryFormat(String dataStructureName)
protected abstract Object	getMergePolicy(String dataStructureName)
protected abstract int	getPartitionId(Store store)
protected InternalSerializationService	getSerializationService()
protected abstract void	mergeStore(Store recordStore, BiConsumer<Integer,MergingItem> consumer) Used to merge with SplitBrainMergePolicy.
protected abstract void	mergeStoreLegacy(Store recordStore, BiConsumer<Integer,Operation> consumer) Used to merge with legacy merge policies.
protected void	onMerge(String dataStructureName)
void	run()
protected Data	toData(Object object)
protected Data	toHeapData(Object object)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractMergeRunnable

protected AbstractMergeRunnable(String serviceName,
                                Collection<Store> mergingStores,
                                AbstractSplitBrainHandlerService<Store> splitBrainHandlerService,
                                NodeEngine nodeEngine)

Method Detail

run

public final void run()

Specified by:

run in interface Runnable

getSerializationService

protected InternalSerializationService getSerializationService()

toData

protected Data toData(Object object)

toHeapData

protected Data toHeapData(Object object)

onMerge

protected void onMerge(String dataStructureName)

mergeStore

protected abstract void mergeStore(Store recordStore,
                                   BiConsumer<Integer,MergingItem> consumer)

Used to merge with SplitBrainMergePolicy.

mergeStoreLegacy

protected abstract void mergeStoreLegacy(Store recordStore,
                                         BiConsumer<Integer,Operation> consumer)

Used to merge with legacy merge policies.

getBatchSize

protected abstract int getBatchSize(String dataStructureName)

This batch size can only be used with SplitBrainMergePolicy, legacy merge policies don't support batch data sending.

Returns:

batch size from MergePolicyConfig

getMergePolicy

protected abstract Object getMergePolicy(String dataStructureName)

Returns:

a type of SplitBrainMergePolicy or a legacy merge policy

getDataStructureName

protected abstract String getDataStructureName(Store store)

getPartitionId

protected abstract int getPartitionId(Store store)

getInMemoryFormat

protected abstract InMemoryFormat getInMemoryFormat(String dataStructureName)

Returns:

in memory format of data structure

createMergeOperationFactory

protected abstract OperationFactory createMergeOperationFactory(String dataStructureName,
                                                                SplitBrainMergePolicy<V,MergingItem> mergePolicy,
                                                                int[] partitions,
                                                                List<MergingItem>[] entries)

Returns an OperationFactory for SplitBrainMergePolicy, legacy merge policies don't use this method.

Returns:

a new operation factory