ScatterGatherPartitionInfo |
ScatterGatherOperationFutureListener.addPartition(int partitionId,
ScatterGatherRemoteOperationRequest<T> request) |
<T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T> |
CoordinatorFactory.createAsyncScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request,
AsyncFutureListener<Object> listener,
PartitionedClusterRemoteOperationRouter router) |
protected <T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T> |
CoordinatorFactory.createScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request,
AsyncFutureListener<Object> listener,
PartitionedClusterRemoteOperationRouter router,
boolean getResultOnCompletion) |
<T extends RemoteOperationResult> ScatterGatherOperationFutureListener<T> |
CoordinatorFactory.createSyncScatterGatherListener(ScatterGatherRemoteOperationRequest<T> request,
PartitionedClusterRemoteOperationRouter router) |
ScatterGatherRemoteOperationRequest<T> |
ScatterGatherOperationFutureListener.getPartitionRequest(int partitionId,
ScatterGatherRemoteOperationRequest<T> mainRequest) |
void |
ScatterGatherRemoteOperationRequest.loadPartitionData(ScatterGatherRemoteOperationRequest<TResult> mainRequest) |
void |
ScatterGatherOperationFutureListener.mapIndexToPartition(int index,
int partitionId,
ScatterGatherRemoteOperationRequest<T> request) |
void |
ScatterGatherOperationFutureListener.mapValuesByHashCode(Object[] array,
ScatterGatherRemoteOperationRequest<T> request) |
boolean |
ScatterGatherRemoteOperationRequest.processPartitionResult(ScatterGatherRemoteOperationRequest<TResult> partitionRequest,
List<ScatterGatherRemoteOperationRequest<TResult>> previousRequests) |