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) 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.
int[]	getPartitions() This method will be called on operation runner node.

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)

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

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

getPartitions

public int[] getPartitions()

This method will be called on operation runner node.

Created operations by this factory will be run on the partitions returned by this method. Returning null means operations will be run provided partitions by default.

Returns:

null to preserve default behaviour or return relevant partition IDs for the operations of this factory

createOperation

public Operation createOperation()

Description copied from interface: OperationFactory

Creates the operation.

Specified by:

createOperation in interface OperationFactory

Returns:

the created operation.