com.hazelcast.spi.impl.merge

Class AbstractMergeRunnable<Store,MergingItem>

java.lang.Object

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

Type Parameters:

Store - type of the store in a partition

All Implemented Interfaces:

Disposable, Runnable

public abstract class AbstractMergeRunnable<Store,MergingItem>
extends Object
implements Runnable, Disposable

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMergeRunnable(String serviceName, Map<String,Collection<Store>> collectedStores, Map<String,Collection<Store>> collectedStoresWithLegacyPolicies, Collection<Store> backupStores, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
protected abstract void	consumeStore(Store recordStore, BiConsumer<Integer,MergingItem> consumer) Use to merge with policies which are a type of SplitBrainMergePolicy
protected abstract void	consumeStoreLegacy(Store recordStore, BiConsumer<Integer,Operation> consumer) Use to merge with legacy merge policies
protected abstract OperationFactory	createMergeOperationFactory(String dataStructureName, SplitBrainMergePolicy mergePolicy, int[] partitions, List<MergingItem>[] entries) Returned OperationFactory is used for SplitBrainMergePolicy types, legacy ones don't use this method.
protected abstract void	destroyStores(Collection<Store> stores) Destroy a collection of stores
void	dispose() Disposes this object and releases any data and/or resources associated with it.
protected abstract int	getBatchSize(String dataStructureName) This batch size can only be used when merge policy is a type of SplitBrainMergePolicy, legacy merge policies don't support batch data sending.
protected abstract InMemoryFormat	getInMemoryFormat(String dataStructureName)
protected abstract Object	getMergePolicy(String dataStructureName)
protected InternalSerializationService	getSerializationService()
void	run()
protected Data	toData(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,
                                Map<String,Collection<Store>> collectedStores,
                                Map<String,Collection<Store>> collectedStoresWithLegacyPolicies,
                                Collection<Store> backupStores,
                                NodeEngine nodeEngine)

Method Detail

run

public final void run()

Specified by:

run in interface Runnable

dispose

public final void dispose()

Description copied from interface: Disposable

Disposes this object and releases any data and/or resources associated with it. If this object is already disposed then invoking this method has no effect.

Specified by:

dispose in interface Disposable

getSerializationService

protected InternalSerializationService getSerializationService()

toData

protected Data toData(Object object)

destroyStores

protected abstract void destroyStores(Collection<Store> stores)

Destroy a collection of stores

consumeStore

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

Use to merge with policies which are a type of SplitBrainMergePolicy

consumeStoreLegacy

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

Use to merge with legacy merge policies

getBatchSize

protected abstract int getBatchSize(String dataStructureName)

This batch size can only be used when merge policy is a type of 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

getInMemoryFormat

protected abstract InMemoryFormat getInMemoryFormat(String dataStructureName)

Returns:

in memory format of data structure

createMergeOperationFactory

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

Returned OperationFactory is used for SplitBrainMergePolicy types, legacy ones don't use this method.

Returns:

a new operation factory