Interface ORemoteTask
- All Known Implementing Classes:
NodeOperationTask,OAbstractRemoteTask,OCloseQueryTask,OCopyDatabaseChunkTask,ODropDatabaseTask,OEnterpriseStatsTask,OFetchQueryPageTask,OGossipTask,ORequestDatabaseConfigurationTask,ORestartServerTask,ORunQueryExecutionPlanTask,OSQLCommandTaskFirstPhase,OSQLCommandTaskSecondPhase,OStopServerTask,OSyncClusterTask,OSyncDatabaseNewDeltaTask,OSyncDatabaseTask,OTransactionPhase1Task,OTransactionPhase2Task,OUnreachableServerLocalTask,OUpdateDatabaseConfigurationTask,OUpdateDatabaseSequenceStatusTask
public interface ORemoteTask
Remote Task interface.
- Author:
- Luca Garulli (l.garulli--(at)--orientdb.com)
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionexecute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) default voidfinished(ODistributedDatabase distributedDatabase) voidfromStream(DataInput in, ORemoteTaskFactory factory) longintgetName()longgetSynchronousTimeout(int iSynchNodes) longgetTotalTimeout(int iTotalNodes) booleanbooleanbooleanbooleandefault voidreceived(ODistributedRequest request, ODistributedDatabase distributedDatabase) voidsetNodeSource(String nodeSource) voidtoStream(DataOutput out)
-
Method Details
-
hasResponse
boolean hasResponse() -
received
-
getName
String getName() -
getQuorumType
OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType() -
execute
Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) throws Exception - Throws:
Exception
-
getDistributedTimeout
long getDistributedTimeout() -
getSynchronousTimeout
long getSynchronousTimeout(int iSynchNodes) -
getTotalTimeout
long getTotalTimeout(int iTotalNodes) -
getResultStrategy
ORemoteTask.RESULT_STRATEGY getResultStrategy() -
getNodeSource
String getNodeSource() -
setNodeSource
-
isIdempotent
boolean isIdempotent() -
isNodeOnlineRequired
boolean isNodeOnlineRequired() -
isUsingDatabase
boolean isUsingDatabase() -
getFactoryId
int getFactoryId() -
toStream
- Throws:
IOException
-
fromStream
- Throws:
IOException
-
finished
-