com.orientechnologies.orient.server.distributed.task

Class OAbstractRecordReplicatedTask

java.lang.Object

com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask

com.orientechnologies.orient.server.distributed.task.OAbstractRecordReplicatedTask

All Implemented Interfaces:

ORemoteTask, Externalizable, Serializable

public abstract class OAbstractRecordReplicatedTask
extends OAbstractReplicatedTask

Distributed create record task used for synchronization.

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
protected com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber	lastLSN
protected boolean	lockRecords
protected int	partitionKey
protected com.orientechnologies.orient.core.record.ORecord	previousRecord
protected com.orientechnologies.orient.core.id.ORecordId	rid
protected int	version

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

nodeSource

Constructor Summary

Constructors

Modifier	Constructor and Description
	OAbstractRecordReplicatedTask()
protected	OAbstractRecordReplicatedTask(com.orientechnologies.orient.core.record.ORecord record)
protected	OAbstractRecordReplicatedTask(com.orientechnologies.orient.core.id.ORecordId iRid, int iVersion)

Method Summary

Modifier and Type	Method and Description
boolean	checkForClusterAvailability(String localNode, ODistributedConfiguration cfg)
void	checkRecordExists()
Object	execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database)
abstract Object	executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database)
com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber	getLastLSN()
int	getPartitionKey()
String	getPayload()
abstract com.orientechnologies.orient.core.record.ORecord	getRecord()
com.orientechnologies.orient.core.id.ORecordId	getRid()
int	getVersion()
com.orientechnologies.orient.core.record.ORecord	prepareUndoOperation()
void	readExternal(ObjectInput in)
void	setLastLSN(com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber lastLSN)
void	setLockRecords(boolean lockRecords)
String	toString()
void	writeExternal(ObjectOutput out)

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

getFixTask, getUndoTask

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

getDistributedTimeout, getName, getNodeSource, getQuorumType, getResultStrategy, getSynchronousTimeout, getTotalTimeout, isIdempotent, isNodeOnlineRequired, setNodeSource

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask

getFactoryId

Field Detail

rid

protected com.orientechnologies.orient.core.id.ORecordId rid

version

protected int version

partitionKey

protected int partitionKey

lockRecords

protected boolean lockRecords

lastLSN

protected com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber lastLSN

previousRecord

protected transient com.orientechnologies.orient.core.record.ORecord previousRecord

Constructor Detail

OAbstractRecordReplicatedTask

public OAbstractRecordReplicatedTask()

OAbstractRecordReplicatedTask

protected OAbstractRecordReplicatedTask(com.orientechnologies.orient.core.record.ORecord record)

OAbstractRecordReplicatedTask

protected OAbstractRecordReplicatedTask(com.orientechnologies.orient.core.id.ORecordId iRid,
                                        int iVersion)

Method Detail

executeRecordTask

public abstract Object executeRecordTask(ODistributedRequestId requestId,
                                         OServer iServer,
                                         ODistributedServerManager iManager,
                                         com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database)
                                  throws Exception

Throws:

Exception

getRecord

public abstract com.orientechnologies.orient.core.record.ORecord getRecord()

execute

public final Object execute(ODistributedRequestId requestId,
                            OServer iServer,
                            ODistributedServerManager iManager,
                            com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database)
                     throws Exception

Specified by:

execute in interface ORemoteTask

Specified by:

execute in class OAbstractRemoteTask

Throws:

Exception

getPartitionKey

public int getPartitionKey()

Specified by:

getPartitionKey in interface ORemoteTask

Overrides:

getPartitionKey in class OAbstractRemoteTask

toString

public String toString()

Overrides:

toString in class OAbstractRemoteTask

getRid

public com.orientechnologies.orient.core.id.ORecordId getRid()

getVersion

public int getVersion()

checkForClusterAvailability

public boolean checkForClusterAvailability(String localNode,
                                           ODistributedConfiguration cfg)

prepareUndoOperation

public com.orientechnologies.orient.core.record.ORecord prepareUndoOperation()

checkRecordExists

public void checkRecordExists()

getLastLSN

public com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber getLastLSN()

setLastLSN

public void setLastLSN(com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber lastLSN)

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

setLockRecords

public void setLockRecords(boolean lockRecords)

getPayload

public String getPayload()

Specified by:

getPayload in class OAbstractReplicatedTask