ORemoteTask (OrientDB 3.1.2-SNAPSHOT API)

All Known Implementing Classes:

NodeOperationTask, OAbstractCommandTask, OAbstractRemoteTask, OAbstractReplicatedTask, OAbstractSyncDatabaseTask, OCloseQueryTask, OCopyDatabaseChunkTask, ODropDatabaseTask, OEnterpriseStatsTask, OFetchQueryPageTask, OGossipTask, ONewSQLCommandTask, ORequestDatabaseConfigurationTask, ORestartServerTask, ORunQueryExecutionPlanTask, OScriptTask, OSQLCommandTask, OStopServerTask, OSyncClusterTask, OSyncDatabaseNewDeltaTask, OSyncDatabaseTask, OSynchronizedTaskWrapper, OTransactionPhase1Task, OTransactionPhase2Task, OUnreachableServerLocalTask, OUpdateDatabaseConfigurationTask, OUpdateDatabaseSequenceStatusTask, OUpdateDatabaseStatusTask, OWaitPartitionsReadyTask
```
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()`
`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()
```

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