com.hazelcast.map.impl.operation

Class PartitionWideEntryWithPredicateOperationFactory

java.lang.Object

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

com.hazelcast.map.impl.operation.PartitionWideEntryWithPredicateOperationFactory

All Implemented Interfaces:

DataSerializable, OperationFactory

public class PartitionWideEntryWithPredicateOperationFactory
extends PartitionAwareOperationFactory

Field Summary

Fields inherited from class com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

partitions

Constructor Summary

Constructors

Constructor and Description
PartitionWideEntryWithPredicateOperationFactory()
PartitionWideEntryWithPredicateOperationFactory(String name, EntryProcessor entryProcessor, Predicate predicate)
PartitionWideEntryWithPredicateOperationFactory(String name, EntryProcessor entryProcessor, Predicate predicate, Map<Integer,List<Data>> partitionIdToKeysMap)

Method Summary

Methods

Modifier and Type	Method and Description
PartitionAwareOperationFactory	createFactoryOnRunner(NodeEngine nodeEngine) This method will be called on operation runner node.
Operation	createPartitionOperation(int partition) This method can be called both caller and runner nodes.
void	readData(ObjectDataInput in) Reads fields from the input stream
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

createOperation, getPartitions

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionWideEntryWithPredicateOperationFactory

public PartitionWideEntryWithPredicateOperationFactory()

PartitionWideEntryWithPredicateOperationFactory

public PartitionWideEntryWithPredicateOperationFactory(String name,
                                               EntryProcessor entryProcessor,
                                               Predicate predicate,
                                               Map<Integer,List<Data>> partitionIdToKeysMap)

PartitionWideEntryWithPredicateOperationFactory

public PartitionWideEntryWithPredicateOperationFactory(String name,
                                               EntryProcessor entryProcessor,
                                               Predicate predicate)

Method Detail

createFactoryOnRunner

public PartitionAwareOperationFactory createFactoryOnRunner(NodeEngine nodeEngine)

Description copied from class: PartitionAwareOperationFactory

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.

Overrides:

createFactoryOnRunner in class PartitionAwareOperationFactory

Parameters:

nodeEngine - nodeEngine

createPartitionOperation

public Operation createPartitionOperation(int partition)

Description copied from class: PartitionAwareOperationFactory

This method can be called both caller and runner nodes. Creates a partition-operation for supplied partition-id

Specified by:

createPartitionOperation in class PartitionAwareOperationFactory

Parameters:

partition - id of partition

Returns:

created partition-operation

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Parameters:

out - output

Throws:

IOException

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Parameters:

in - input

Throws:

IOException