public class ScatterGatherOperationFutureListener<T extends RemoteOperationResult> extends RemoteOperationFutureListener<T>
_logger
Constructor and Description |
---|
ScatterGatherOperationFutureListener(ScatterGatherRemoteOperationRequest<T> mainRequest,
AsyncFutureListener<Object> listener,
PartitionedClusterRemoteOperationRouter router,
boolean getResultOnCompletion) |
Modifier and Type | Method and Description |
---|---|
ScatterGatherPartitionInfo |
addPartition(int partitionId,
ScatterGatherRemoteOperationRequest<T> request) |
int |
getNextDistributionPartitionId() |
int |
getNumOfPartitions() |
int |
getPartitionIdByHashcode(Object value) |
int[] |
getPartitionIds() |
ScatterGatherRemoteOperationRequest<T> |
getPartitionRequest(int partitionId,
ScatterGatherRemoteOperationRequest<T> mainRequest) |
protected Object |
getResult(RemoteOperationRequest<T> request) |
void |
mapIndexToPartition(int index,
int partitionId,
ScatterGatherRemoteOperationRequest<T> request) |
void |
mapValuesByHashCode(Object[] array,
ScatterGatherRemoteOperationRequest<T> request) |
protected boolean |
onOperationResultArrival(RemoteOperationRequest<T> request) |
cancel, get, get, isCancelled, isDone, onOperationCompletion, setListener, waitForCompletion, waitForCompletion
public ScatterGatherOperationFutureListener(ScatterGatherRemoteOperationRequest<T> mainRequest, AsyncFutureListener<Object> listener, PartitionedClusterRemoteOperationRouter router, boolean getResultOnCompletion)
public void mapValuesByHashCode(Object[] array, ScatterGatherRemoteOperationRequest<T> request)
public int getPartitionIdByHashcode(Object value)
public int getNextDistributionPartitionId()
public void mapIndexToPartition(int index, int partitionId, ScatterGatherRemoteOperationRequest<T> request)
public ScatterGatherPartitionInfo addPartition(int partitionId, ScatterGatherRemoteOperationRequest<T> request)
public int[] getPartitionIds()
public int getNumOfPartitions()
public ScatterGatherRemoteOperationRequest<T> getPartitionRequest(int partitionId, ScatterGatherRemoteOperationRequest<T> mainRequest)
protected boolean onOperationResultArrival(RemoteOperationRequest<T> request)
onOperationResultArrival
in class RemoteOperationFutureListener<T extends RemoteOperationResult>
protected Object getResult(RemoteOperationRequest<T> request) throws Exception
getResult
in class RemoteOperationFutureListener<T extends RemoteOperationResult>
Exception
Copyright © GigaSpaces.