com.orientechnologies.orient.server.distributed.impl.task
Class OSyncDatabaseDeltaTask
public class OSyncDatabaseDeltaTask extends OAbstractReplicatedTask
ORemoteTask.RESULT_STRATEGY| Modifier and Type | Field and Description |
|---|---|
static int |
CHUNK_MAX_SIZE |
static String |
DEPLOYDB |
protected Set<String> |
excludedClusterNames |
static int |
FACTORYID |
protected long |
random |
protected OLogSequenceNumber |
startLSN |
nodeSource| Constructor and Description |
|---|
OSyncDatabaseDeltaTask() |
OSyncDatabaseDeltaTask(OLogSequenceNumber iFirstLSN) |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
deltaBackup(ODistributedRequestId requestId,
ODistributedServerManager iManager,
ODatabaseDocumentTx database,
String databaseName) |
void |
excludeClusterName(String name) |
Object |
execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
long |
getDistributedTimeout() |
int |
getFactoryId() |
String |
getName() |
String |
getPayload() |
OCommandDistributedReplicateRequest.QUORUM_TYPE |
getQuorumType() |
ORemoteTask.RESULT_STRATEGY |
getResultStrategy() |
boolean |
isNodeOnlineRequired() |
void |
readExternal(ObjectInput in) |
void |
writeExternal(ObjectOutput out) |
getFixTask, getUndoTaskgetNodeSource, getPartitionKey, getSynchronousTimeout, getTotalTimeout, isIdempotent, setNodeSource, toStringpublic static final int CHUNK_MAX_SIZE
public static final String DEPLOYDB
public static final int FACTORYID
protected OLogSequenceNumber startLSN
protected long random
public OSyncDatabaseDeltaTask()
public OSyncDatabaseDeltaTask(OLogSequenceNumber iFirstLSN)
public Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentTx database) throws Exception
execute in interface ORemoteTaskexecute in class OAbstractRemoteTaskExceptionpublic void excludeClusterName(String name)
protected Object deltaBackup(ODistributedRequestId requestId, ODistributedServerManager iManager, ODatabaseDocumentTx database, String databaseName) throws IOException, InterruptedException
IOExceptionInterruptedExceptionpublic ORemoteTask.RESULT_STRATEGY getResultStrategy()
getResultStrategy in interface ORemoteTaskgetResultStrategy in class OAbstractRemoteTaskpublic OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
getQuorumType in interface ORemoteTaskgetQuorumType in class OAbstractRemoteTaskpublic long getDistributedTimeout()
getDistributedTimeout in interface ORemoteTaskgetDistributedTimeout in class OAbstractRemoteTaskpublic String getPayload()
getPayload in class OAbstractReplicatedTaskpublic String getName()
getName in interface ORemoteTaskgetName in class OAbstractRemoteTaskpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic boolean isNodeOnlineRequired()
isNodeOnlineRequired in interface ORemoteTaskisNodeOnlineRequired in class OAbstractRemoteTaskpublic int getFactoryId()
Copyright © 2009–2016 Orient Technologies. All rights reserved.