public interface OperationService
runOperation(Operation)
and executeOperation(Operation)
.
Or it can executed remotely using the one of the send methods.
It also is possible to execute multiple operation one multiple partitions using one of the invoke methods.Modifier and Type | Method and Description |
---|---|
InvocationBuilder |
createInvocationBuilder(String serviceName,
Operation op,
com.hazelcast.nio.Address target) |
InvocationBuilder |
createInvocationBuilder(String serviceName,
Operation op,
int partitionId) |
void |
executeOperation(Operation op)
Executes operation in operation executor pool.
|
long |
getExecutedOperationCount() |
int |
getOperationExecutorQueueSize() |
int |
getOperationThreadCount() |
int |
getRemoteOperationsCount() |
int |
getResponseQueueSize() |
int |
getRunningOperationsCount() |
Map<Integer,Object> |
invokeOnAllPartitions(String serviceName,
OperationFactory operationFactory)
Invokes a set of operation on each partition.
|
Map<Integer,Object> |
invokeOnPartitions(String serviceName,
OperationFactory operationFactory,
Collection<Integer> partitions)
Invokes an set of operation on selected set of partitions
|
Map<Integer,Object> |
invokeOnTargetPartitions(String serviceName,
OperationFactory operationFactory,
com.hazelcast.nio.Address target)
Invokes a set of operations on all partitions of a target member.
|
boolean |
isOperationThread() |
void |
runOperation(Operation op)
Runs operation in calling thread.
|
boolean |
send(Operation op,
com.hazelcast.nio.Address target)
Executes an operation remotely.
|
boolean |
send(Operation op,
com.hazelcast.nio.Connection connection)
Executes an operation remotely
|
boolean |
send(Operation op,
int partitionId,
int replicaIndex)
Executes an operation remotely.
|
int getResponseQueueSize()
int getOperationExecutorQueueSize()
int getRunningOperationsCount()
int getRemoteOperationsCount()
int getOperationThreadCount()
long getExecutedOperationCount()
boolean isOperationThread()
void runOperation(Operation op)
op
- the operation to execute.void executeOperation(Operation op)
op
- the operation to execute.InvocationBuilder createInvocationBuilder(String serviceName, Operation op, int partitionId)
InvocationBuilder createInvocationBuilder(String serviceName, Operation op, com.hazelcast.nio.Address target)
Map<Integer,Object> invokeOnAllPartitions(String serviceName, OperationFactory operationFactory) throws Exception
serviceName
- operationFactory
- the factory responsible creating operationsException
Map<Integer,Object> invokeOnPartitions(String serviceName, OperationFactory operationFactory, Collection<Integer> partitions) throws Exception
serviceName
- operationFactory
- the factory responsible creating operationspartitions
- the partitions the operation should be executed on.Exception
Map<Integer,Object> invokeOnTargetPartitions(String serviceName, OperationFactory operationFactory, com.hazelcast.nio.Address target) throws Exception
serviceName
- operationFactory
- the factory responsible creating operationstarget
- the address of the target memberException
boolean send(Operation op, int partitionId, int replicaIndex)
op
- the operation to execute.partitionId
- the id of the partition the operation should be executed onreplicaIndex
- boolean send(Operation op, com.hazelcast.nio.Address target)
op
- the operation to send and execute.target
- the address of that target member.boolean send(Operation op, com.hazelcast.nio.Connection connection)
op
- the operation to send and execute.connection
- the connection to the target machine.Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.