public class PartitionWideEntryWithPredicateOperationFactory extends PartitionAwareOperationFactory
partitions
Constructor and Description |
---|
PartitionWideEntryWithPredicateOperationFactory() |
PartitionWideEntryWithPredicateOperationFactory(String name,
EntryProcessor entryProcessor,
Predicate predicate) |
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.
|
Operation |
createPartitionOperation(int partition)
This method can be called both caller and runner nodes.
|
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
public PartitionWideEntryWithPredicateOperationFactory()
public PartitionWideEntryWithPredicateOperationFactory(String name, EntryProcessor entryProcessor, Predicate predicate)
public PartitionAwareOperationFactory createFactoryOnRunner(NodeEngine nodeEngine, int[] partitions)
PartitionAwareOperationFactory
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.
createFactoryOnRunner
in class PartitionAwareOperationFactory
nodeEngine
- nodeEnginepartitions
- 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.public Operation createPartitionOperation(int partition)
PartitionAwareOperationFactory
Creates a partition-operation for supplied partition ID.
createPartitionOperation
in class PartitionAwareOperationFactory
partition
- ID of partitionpublic void writeData(ObjectDataOutput out) throws IOException
DataSerializable
out
- outputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
output stream has been closed.public void readData(ObjectDataInput in) throws IOException
DataSerializable
in
- inputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
input stream has been closed.public Operation createOperation()
OperationFactory
createOperation
in interface OperationFactory
createOperation
in class PartitionAwareOperationFactory
public int getFactoryId()
IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.