Class FileTxnLog.FileTxnIterator
- java.lang.Object
-
- org.apache.zookeeper.server.persistence.FileTxnLog.FileTxnIterator
-
- All Implemented Interfaces:
TxnLog.TxnIterator
- Enclosing class:
- FileTxnLog
public static class FileTxnLog.FileTxnIterator extends java.lang.Object implements TxnLog.TxnIterator
this class implements the txnlog iterator interface which is used for reading the transaction logs
-
-
Constructor Summary
Constructors Constructor Description FileTxnIterator(java.io.File logDir, long zxid)
create an iterator over a transaction database directory
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
close the iterator and release the resources.protected org.apache.jute.InputArchive
createInputArchive(java.io.File logFile)
Invoked to indicate that the input stream has been created.TxnHeader
getHeader()
reutrn the current headerorg.apache.jute.Record
getTxn()
return the current transactionprotected void
inStreamCreated(org.apache.jute.InputArchive ia, java.io.InputStream is)
read the header from the inputarchiveprotected java.util.zip.Checksum
makeChecksumAlgorithm()
create a checksum algorithmboolean
next()
the iterator that moves to the next transaction
-
-
-
Method Detail
-
inStreamCreated
protected void inStreamCreated(org.apache.jute.InputArchive ia, java.io.InputStream is) throws java.io.IOException
read the header from the inputarchive- Parameters:
ia
- the inputarchive to be read fromis
- the inputstream- Throws:
java.io.IOException
-
createInputArchive
protected org.apache.jute.InputArchive createInputArchive(java.io.File logFile) throws java.io.IOException
Invoked to indicate that the input stream has been created.- Parameters:
ia
- input archiveis
- file input stream associated with the input archive.- Throws:
java.io.IOException
-
makeChecksumAlgorithm
protected java.util.zip.Checksum makeChecksumAlgorithm()
create a checksum algorithm- Returns:
- the checksum algorithm
-
next
public boolean next() throws java.io.IOException
the iterator that moves to the next transaction- Specified by:
next
in interfaceTxnLog.TxnIterator
- Returns:
- true if there is more transactions to be read false if not.
- Throws:
java.io.IOException
-
getHeader
public TxnHeader getHeader()
reutrn the current header- Specified by:
getHeader
in interfaceTxnLog.TxnIterator
- Returns:
- the current header that is read
-
getTxn
public org.apache.jute.Record getTxn()
return the current transaction- Specified by:
getTxn
in interfaceTxnLog.TxnIterator
- Returns:
- the current transaction that is read
-
close
public void close() throws java.io.IOException
close the iterator and release the resources.- Specified by:
close
in interfaceTxnLog.TxnIterator
- Throws:
java.io.IOException
-
-