org.apache.solr.update

Class CdcrTransactionLog

java.lang.Object

org.apache.solr.update.TransactionLog

org.apache.solr.update.CdcrTransactionLog

All Implemented Interfaces:

Closeable, AutoCloseable

public class CdcrTransactionLog
extends TransactionLog

Extends TransactionLog to:

• reopen automatically the output stream if its reference count reached 0. This is achieved by extending methods incref(), close() and reopenOutputStream().
• encode the number of records in the tlog file in the last commit record. The number of records will be decoded and reuse if the tlog file is reopened. This is achieved by extending the constructor, and the methods writeCommit(CommitUpdateCommand, int) and getReader(long).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CdcrTransactionLog.CdcrLogReader

Nested classes/interfaces inherited from class org.apache.solr.update.TransactionLog

TransactionLog.FSReverseReader, TransactionLog.LogCodec, TransactionLog.LogReader, TransactionLog.ReverseReader, TransactionLog.SortedLogReader

Field Summary

Fields inherited from class org.apache.solr.update.TransactionLog

deleteOnClose, END_MESSAGE

Method Summary

Modifier and Type	Method and Description
void	close()
TransactionLog.LogReader	getReader(long startingPos) Returns a reader that can be used while a log is still in use.
void	incref()
int	numRecords() Returns the number of records in the log (currently includes the header and an optional commit).
boolean	try_incref() Modified to act like incref() in order to be compatible with UpdateLog.recoverFromLog().
long	write(AddUpdateCommand cmd, long prevPointer, int flags) Writes an add update command to the transaction log.
long	writeCommit(CommitUpdateCommand cmd, int flags)
long	writeDelete(DeleteUpdateCommand cmd, int flags)
long	writeDeleteByQuery(DeleteUpdateCommand cmd, int flags)

Methods inherited from class org.apache.solr.update.TransactionLog

addGlobalStrings, checkWriteHeader, closeOutput, decref, endRecord, endsWithCommit, finish, forceClose, getLogSize, getReverseReader, getSortedReader, lookup, position, rollback, snapshot, toString, write, writeData, writeLogHeader

Methods inherited from class java.lang.Object

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

Method Detail

numRecords

public int numRecords()

Returns the number of records in the log (currently includes the header and an optional commit).

Overrides:

numRecords in class TransactionLog

write

public long write(AddUpdateCommand cmd,
                  long prevPointer,
                  int flags)

Description copied from class: TransactionLog

Writes an add update command to the transaction log. This should be called only for writing in-place updates, or else pass -1 as the prevPointer.

Overrides:

write in class TransactionLog

Parameters:

cmd - The add update command to be written

prevPointer - The pointer in the transaction log which this update depends on (applicable for in-place updates)

flags - Options for writing the command to the transaction log

Returns:

Returns the position pointer of the written update command

writeDelete

public long writeDelete(DeleteUpdateCommand cmd,
                        int flags)

Overrides:

writeDelete in class TransactionLog

writeDeleteByQuery

public long writeDeleteByQuery(DeleteUpdateCommand cmd,
                               int flags)

Overrides:

writeDeleteByQuery in class TransactionLog

writeCommit

public long writeCommit(CommitUpdateCommand cmd,
                        int flags)

Overrides:

writeCommit in class TransactionLog

getReader

public TransactionLog.LogReader getReader(long startingPos)

Returns a reader that can be used while a log is still in use. Currently only *one* LogReader may be outstanding, and that log may only be used from a single thread.

Overrides:

getReader in class TransactionLog

incref

public void incref()

Overrides:

incref in class TransactionLog

try_incref

public boolean try_incref()

Modified to act like incref() in order to be compatible with UpdateLog.recoverFromLog(). Otherwise, we would have to duplicate the method UpdateLog.recoverFromLog() in CdcrUpdateLog and change the call if (!ll.try_incref()) continue; to incref(); .

Overrides:

try_incref in class TransactionLog

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class TransactionLog