OTxTask (OrientDB 2.2.1-SNAPSHOT API)

java.lang.Object
- com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
- - com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask
  - - com.orientechnologies.orient.server.distributed.impl.task.OTxTask

All Implemented Interfaces:

ORemoteTask, Externalizable, Serializable
```
public class OTxTask
extends OAbstractReplicatedTask
```
Distributed transaction task.

Author:

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

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask
  ORemoteTask.RESULT_STRATEGY

Field Summary

Fields
Modifier and Type Field and Description

static int FACTORYID

static String NON_LOCAL_CLUSTER
- Fields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
  nodeSource

Fields
Modifier and Type	Field and Description
`static int`	`FACTORYID`
`static String`	`NON_LOCAL_CLUSTER`

Constructor Summary

Constructors
Constructor and Description

OTxTask()

Constructors
Constructor and Description
`OTxTask()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`add(OAbstractRecordReplicatedTask iTask)`
`Object`	`execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentTx database)`
`long`	`getDistributedTimeout()` Computes the timeout according to the transaction size.
`int`	`getFactoryId()`
`ORemoteTask`	`getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)`
`String`	`getName()`
`String`	`getPayload()`
`OCommandDistributedReplicateRequest.QUORUM_TYPE`	`getQuorumType()`
`List<OAbstractRecordReplicatedTask>`	`getTasks()`
`ORemoteTask`	`getUndoTask(ODistributedRequestId reqId)`
`void`	`readExternal(ObjectInput in)`
`void`	`setLocalUndoTasks(List<OAbstractRemoteTask> undoTasks)`
`void`	`setNodeSource(String nodeSource)`
`void`	`writeExternal(ObjectOutput out)`

Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
getNodeSource, getPartitionKey, getResultStrategy, getSynchronousTimeout, getTotalTimeout, isIdempotent, isNodeOnlineRequired, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail
- FACTORYID
```
public static final int FACTORYID
```
  See Also:
  
  Constant Field Values
- NON_LOCAL_CLUSTER
```
public static final String NON_LOCAL_CLUSTER
```
  See Also:
  
  Constant Field Values

Constructor Detail
- OTxTask
```
public OTxTask()
```

Method Detail

add

public void add(OAbstractRecordReplicatedTask iTask)

execute

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

Specified by:: execute in interface ORemoteTask
Specified by:: execute in class OAbstractRemoteTask
Throws:: Exception

getQuorumType
```
public OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
```
Specified by:

getQuorumType in interface ORemoteTask

Specified by:

getQuorumType in class OAbstractRemoteTask

getFixTask

public ORemoteTask getFixTask(ODistributedRequest iRequest,
                              ORemoteTask iOriginalTask,
                              Object iBadResponse,
                              Object iGoodResponse,
                              String executorNodeName,
                              ODistributedServerManager dManager)

Overrides:: getFixTask in class OAbstractReplicatedTask

getUndoTask

public ORemoteTask getUndoTask(ODistributedRequestId reqId)

Overrides:: getUndoTask in class OAbstractReplicatedTask

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:: IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:: IOException; ClassNotFoundException

getDistributedTimeout
```
public long getDistributedTimeout()
```
Computes the timeout according to the transaction size.

Specified by:

getDistributedTimeout in interface ORemoteTask

Overrides:

getDistributedTimeout in class OAbstractRemoteTask

Returns:

getName
```
public String getName()
```
Specified by:

getName in interface ORemoteTask

Specified by:

getName in class OAbstractRemoteTask

getPayload
```
public String getPayload()
```
Specified by:

getPayload in class OAbstractReplicatedTask

getTasks

public List<OAbstractRecordReplicatedTask> getTasks()

getFactoryId
```
public int getFactoryId()
```

setNodeSource
```
public void setNodeSource(String nodeSource)
```
Specified by:

setNodeSource in interface ORemoteTask

Overrides:

setNodeSource in class OAbstractRemoteTask

setLocalUndoTasks

public void setLocalUndoTasks(List<OAbstractRemoteTask> undoTasks)

Class OTxTask

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask

Field Summary

Fields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

Constructor Summary

Method Summary

Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

Methods inherited from class java.lang.Object

Field Detail

FACTORYID

NON_LOCAL_CLUSTER

Constructor Detail

OTxTask

Method Detail

add

execute

getQuorumType

getFixTask

getUndoTask

writeExternal

readExternal

getDistributedTimeout

getName

getPayload

getTasks

getFactoryId

setNodeSource

setLocalUndoTasks