Class OSyncDatabaseNewDeltaTask
java.lang.Object
com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
com.orientechnologies.orient.server.distributed.impl.task.OSyncDatabaseNewDeltaTask
- All Implemented Interfaces:
ORemoteTask
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask
ORemoteTask.RESULT_STRATEGY -
Field Summary
FieldsFields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
nodeSource -
Constructor Summary
ConstructorsConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionexecute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) voidfromStream(DataInput in, ORemoteTaskFactory factory) longintgetName()voidtoStream(DataOutput out) Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
getNodeSource, getResultStrategy, getSynchronousTimeout, getTotalTimeout, hasResponse, isIdempotent, isNodeOnlineRequired, isUsingDatabase, setNodeSource, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask
finished, received
-
Field Details
-
CHUNK_MAX_SIZE
public static final int CHUNK_MAX_SIZE- See Also:
-
FACTORYID
public static final int FACTORYID- See Also:
-
-
Constructor Details
-
OSyncDatabaseNewDeltaTask
-
OSyncDatabaseNewDeltaTask
public OSyncDatabaseNewDeltaTask()
-
-
Method Details
-
getName
-
getQuorumType
-
execute
public Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) throws Exception - Throws:
Exception
-
toStream
- Specified by:
toStreamin interfaceORemoteTask- Overrides:
toStreamin classOAbstractRemoteTask- Throws:
IOException
-
fromStream
- Specified by:
fromStreamin interfaceORemoteTask- Overrides:
fromStreamin classOAbstractRemoteTask- Throws:
IOException
-
getLastState
-
getFactoryId
public int getFactoryId() -
getDistributedTimeout
public long getDistributedTimeout()- Specified by:
getDistributedTimeoutin interfaceORemoteTask- Overrides:
getDistributedTimeoutin classOAbstractRemoteTask
-