ORemoteTask (OrientDB 2.2.37 API)

All Known Implementing Classes:

OAbstract2pcTask, OAbstractCommandTask, OAbstractReadRecordTask, OAbstractRecordReplicatedTask, OAbstractRemoteTask, OAbstractReplicatedTask, OAbstractSyncDatabaseTask, OClusterRepairInfoTask, OCompleted2pcTask, OCompleted2pcTaskV1, OCopyDatabaseChunkTask, OCreateRecordTask, ODeleteRecordTask, ODistributedLockTask, ODropDatabaseTask, OEnterpriseStatsTask, OFixCreateRecordTask, OFixUpdateRecordTask, OGossipTask, OReadRecordIfNotLatestTask, OReadRecordTask, ORepairClusterTask, ORepairRecordsTask, ORequestDatabaseConfigurationTask, ORestartServerTask, OResurrectRecordTask, OScriptTask, OSQLCommandTask, OStartReplicationTask, OStopServerTask, OSyncClusterTask, OSyncDatabaseDeltaTask, OSyncDatabaseTask, OSynchronizedTaskWrapper, OTxTask, OUnreachableServerLocalTask, OUpdateDatabaseConfigurationTask, OUpdateDatabaseStatusTask, OUpdateRecordTask, OWaitForTask
```
public interface ORemoteTask
```
Remote Task interface.

Author:

Luca Garulli

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
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)`
`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()`
`void`	`setNodeSource(String nodeSource)`
`void`	`toStream(DataOutput out)`

Method Detail

hasResponse
```
boolean hasResponse()
```

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

Interface ORemoteTask

Nested Class Summary

Method Summary

Method Detail

hasResponse

getName

getQuorumType

execute

getPartitionKey

getDistributedTimeout

getSynchronousTimeout

getTotalTimeout

getResultStrategy

getNodeSource

setNodeSource

isIdempotent

isNodeOnlineRequired

isUsingDatabase

getFactoryId

checkIsValid

toStream

fromStream