com.orientechnologies.orient.server.distributed.impl

Class OIncrementalServerSync

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.OIncrementalServerSync

public class OIncrementalServerSync
extends Object

Synchronizes a database from the wire.

Author:

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

Constructor Summary

Constructors

Constructor and Description
OIncrementalServerSync()

Method Summary

Modifier and Type	Method and Description
void	importDelta(OServer serverInstance, ODatabaseDocumentInternal db, FileInputStream in, String iNode) Deleted records are written in output stream first, then created/updated records.

Methods inherited from class java.lang.Object

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

Constructor Detail

OIncrementalServerSync

public OIncrementalServerSync()

Method Detail

importDelta

public void importDelta(OServer serverInstance,
                        ODatabaseDocumentInternal db,
                        FileInputStream in,
                        String iNode)
                 throws IOException

Deleted records are written in output stream first, then created/updated records. All records are sorted by record id.

Each record in output stream is written using following format:

1. Record's cluster id - 4 bytes
2. Record's cluster position - 8 bytes
3. Delete flag, 1 if record is deleted - 1 byte
4. Record version , only if record is not deleted - 4 bytes
5. Record type, only if record is not deleted - 1 byte
6. Length of binary presentation of record, only if record is not deleted - 4 bytes
7. Binary presentation of the record, only if record is not deleted - length of content is provided in above entity

Throws:

IOException