com.hazelcast.spi.impl.operationservice.impl.operations

Class PartitionAwareOperationFactory

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable, OperationFactory

Direct Known Subclasses:

CacheMergeOperationFactory, MergeOperationFactory, MergeOperationFactory, PartitionWideEntryWithPredicateOperationFactory, PutAllPartitionAwareOperationFactory

public abstract class PartitionAwareOperationFactory
extends Object
implements OperationFactory

Creates partition specific operations.

Intended to be used by PartitionIteratingOperation.

Field Summary

Fields

Modifier and Type	Field and Description
protected int[]	partitions Partition-operations will be created for these partition IDs.

Constructor Summary

Constructors

Constructor and Description
PartitionAwareOperationFactory()

Method Summary

Modifier and Type	Method and Description
PartitionAwareOperationFactory	createFactoryOnRunner(NodeEngine nodeEngine, int[] partitions) This method will be called on operation runner node.
Operation	createOperation() Creates the operation.
abstract Operation	createPartitionOperation(int partition) This method can be called both caller and runner nodes.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getFactoryId, getId

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Field Detail

partitions

protected int[] partitions

Partition-operations will be created for these partition IDs.

Constructor Detail

PartitionAwareOperationFactory

public PartitionAwareOperationFactory()

Method Detail

createFactoryOnRunner

public PartitionAwareOperationFactory createFactoryOnRunner(NodeEngine nodeEngine,
                                                            int[] partitions)

This method will be called on operation runner node.

If PartitionAwareOperationFactory needs to have runner-side state different from caller-side one, this method can be used to create it. Otherwise, stateful factories may cause JMM problems.

Parameters:

nodeEngine - nodeEngine

partitions - the partitions provided to an operation which use this factory. The operation factory may decide to use this externally provided partition set if it doesn't manage one internally on its own.

createPartitionOperation

public abstract Operation createPartitionOperation(int partition)

This method can be called both caller and runner nodes.

Creates a partition-operation for supplied partition ID.

Parameters:

partition - ID of partition

Returns:

created partition-operation

createOperation

public Operation createOperation()

Description copied from interface: OperationFactory

Creates the operation.

Specified by:

createOperation in interface OperationFactory

Returns:

the created operation.