ORemoteTask (OrientDB 3.1.19 API)

All Known Implementing Classes:

NodeOperationTask, OAbstractCommandTask, OAbstractRemoteTask, OAbstractReplicatedTask, OAbstractSyncDatabaseTask, OCloseQueryTask, OCopyDatabaseChunkTask, ODropDatabaseTask, OEnterpriseStatsTask, OFetchQueryPageTask, OGossipTask, ONewSQLCommandTask, ORequestDatabaseConfigurationTask, ORestartServerTask, ORunQueryExecutionPlanTask, OScriptTask, OSQLCommandTask, OSQLCommandTaskFirstPhase, OSQLCommandTaskSecondPhase, OStopServerTask, OSyncClusterTask, OSyncDatabaseNewDeltaTask, OSyncDatabaseTask, OSynchronizedTaskWrapper, OTransactionPhase1Task, OTransactionPhase2Task, OUnreachableServerLocalTask, OUpdateDatabaseConfigurationTask, OUpdateDatabaseSequenceStatusTask, OUpdateDatabaseStatusTask
```
public interface ORemoteTask
```
Remote Task interface.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested Classes
Modifier and Type Interface and Description

static class ORemoteTask.RESULT_STRATEGY

Nested Classes
Modifier and Type	Interface and Description
`static class`	`ORemoteTask.RESULT_STRATEGY`

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`void`	`checkIsValid(ODistributedServerManager dManager)` Checks the request is still valid.
`Object`	`execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)`
`default void`	`finished(ODistributedDatabase distributedDatabase)`
`void`	`fromStream(DataInput in, ORemoteTaskFactory factory)`
`long`	`getDistributedTimeout()`
`int`	`getFactoryId()`
`String`	`getName()`
`String`	`getNodeSource()`
`int[]`	`getPartitionKey()`
`OCommandDistributedReplicateRequest.QUORUM_TYPE`	`getQuorumType()`
`ORemoteTask.RESULT_STRATEGY`	`getResultStrategy()`
`long`	`getSynchronousTimeout(int iSynchNodes)`
`long`	`getTotalTimeout(int iTotalNodes)`
`boolean`	`hasResponse()`
`boolean`	`isIdempotent()`
`boolean`	`isNodeOnlineRequired()`
`boolean`	`isUsingDatabase()`
`default void`	`received(ODistributedRequest request, ODistributedDatabase distributedDatabase)`
`void`	`setNodeSource(String nodeSource)`
`void`	`toStream(DataOutput out)`

Method Detail

hasResponse
```
boolean hasResponse()
```

received

default void received(ODistributedRequest request,
                      ODistributedDatabase distributedDatabase)

getName
```
String getName()
```

getQuorumType

OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()

execute

Object execute(ODistributedRequestId requestId,
               OServer iServer,
               ODistributedServerManager iManager,
               ODatabaseDocumentInternal database)
        throws Exception

Throws:: Exception

getPartitionKey
```
int[] getPartitionKey()
```

getDistributedTimeout
```
long getDistributedTimeout()
```

getSynchronousTimeout

long getSynchronousTimeout(int iSynchNodes)

getTotalTimeout
```
long getTotalTimeout(int iTotalNodes)
```

getResultStrategy

ORemoteTask.RESULT_STRATEGY getResultStrategy()

getNodeSource
```
String getNodeSource()
```

setNodeSource
```
void setNodeSource(String nodeSource)
```

isIdempotent
```
boolean isIdempotent()
```

isNodeOnlineRequired
```
boolean isNodeOnlineRequired()
```

isUsingDatabase
```
boolean isUsingDatabase()
```

getFactoryId
```
int getFactoryId()
```

checkIsValid

void checkIsValid(ODistributedServerManager dManager)

Checks the request is still valid.

toStream

void toStream(DataOutput out)
       throws IOException

Throws:: IOException

fromStream

void fromStream(DataInput in,
                ORemoteTaskFactory factory)
         throws IOException

Throws:: IOException

finished

default void finished(ODistributedDatabase distributedDatabase)

Interface ORemoteTask

Nested Class Summary

Method Summary

Method Detail

hasResponse

received

getName

getQuorumType

execute

getPartitionKey

getDistributedTimeout

getSynchronousTimeout

getTotalTimeout

getResultStrategy

getNodeSource

setNodeSource

isIdempotent

isNodeOnlineRequired

isUsingDatabase

getFactoryId

checkIsValid

toStream

fromStream

finished