Interface RemoteOperationRequest<TResult extends RemoteOperationResult>

All Superinterfaces:
Externalizable, LRMIMethodTrackingIdProvider, Serializable, SmartExternalizable
All Known Subinterfaces:
ScatterGatherRemoteOperationRequest<TResult>
All Known Implementing Classes:
AbortPreparedTransactionSpaceOperationRequest, AddEntryTypeIndexesSpaceOperationRequest, AggregateEntriesSpaceOperationRequest, ChangeEntriesSpaceOperationRequest, CommitPreparedTransactionSpaceOperationRequest, CountClearEntriesSpaceOperationRequest, ExecuteDurableTaskSpaceOperationRequest, ExecuteTaskSpaceOperationRequest, GetEntryTypeDescriptorSpaceOperationRequest, ListDurableTaskSpaceOperationRequest, PrepareAndCommitTransactionSpaceOperationRequest, ReadTakeEntriesByIdsSpaceOperationRequest, ReadTakeEntriesSpaceOperationRequest, ReadTakeEntriesUidsSpaceOperationRequest, ReadTakeEntrySpaceOperationRequest, RegisterDurableTaskSpaceOperationRequest, RegisterEntriesListenerSpaceOperationRequest, RegisterEntryTypeDescriptorSpaceOperationRequest, RegisterLocalViewSpaceOperationRequest, SpaceOperationRequest, SpaceScatterGatherOperationRequest, UnregisterDurableTaskSpaceOperationRequest, UnregisterLocalViewSpaceOperationRequest, UpdateLeaseSpaceOperationRequest, UpdateLeasesSpaceOperationRequest, WriteEntriesSpaceOperationRequest, WriteEntrySpaceOperationRequest

public interface RemoteOperationRequest<TResult extends RemoteOperationResult> extends LRMIMethodTrackingIdProvider, SmartExternalizable
Since:
9.0.0
Author:
Niv Ingberg
  • Method Details

    • getOperationCode

      int getOperationCode()
    • createRemoteOperationResult

      TResult createRemoteOperationResult()
    • getRemoteOperationResult

      TResult getRemoteOperationResult()
    • setRemoteOperationResult

      void setRemoteOperationResult(TResult remoteOperationResult)
    • setRemoteOperationExecutionError

      void setRemoteOperationExecutionError(Exception error)
    • getAsyncFinalResult

      Object getAsyncFinalResult() throws Exception
      Throws:
      Exception
    • isBlockingOperation

      boolean isBlockingOperation()
    • processUnknownTypeException

      boolean processUnknownTypeException(List<Integer> positions)
    • getPartitionedClusterExecutionType

      PartitionedClusterExecutionType getPartitionedClusterExecutionType()
    • getPartitionedClusterRoutingValue

      Object getPartitionedClusterRoutingValue(PartitionedClusterRemoteOperationRouter router)
    • requiresPartitionedPreciseDistribution

      boolean requiresPartitionedPreciseDistribution()
    • getPreciseDistributionGroupingCode

      int getPreciseDistributionGroupingCode()
    • getSpaceContext

      SpaceContext getSpaceContext()
    • createCopy

      RemoteOperationRequest<TResult> createCopy(int targetPartitionId)
    • processPartitionResult

      boolean processPartitionResult(TResult remoteOperationResult, List<TResult> previousResults, int numOfPartitions)
    • isDedicatedPoolRequired

      boolean isDedicatedPoolRequired()
    • isDirectExecutionEnabled

      boolean isDirectExecutionEnabled()