org.apache.tephra.persist

Class CommitMarkerCodec

java.lang.Object

org.apache.tephra.persist.CommitMarkerCodec

All Implemented Interfaces:

Closeable, AutoCloseable

public class CommitMarkerCodec
extends Object
implements Closeable

Class to read and write commit markers used in HDFSTransactionLogReaderV2 and above.

Constructor Summary

Constructors

Constructor and Description
CommitMarkerCodec()

Method Summary

Modifier and Type	Method and Description
void	close()
int	readMarker(org.apache.hadoop.io.SequenceFile.Reader reader)
static void	writeMarker(org.apache.hadoop.io.SequenceFile.Writer writer, int count)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommitMarkerCodec

public CommitMarkerCodec()

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

readMarker

public int readMarker(org.apache.hadoop.io.SequenceFile.Reader reader)
               throws IOException

Throws:

IOException

writeMarker

public static void writeMarker(org.apache.hadoop.io.SequenceFile.Writer writer,
                               int count)
                        throws IOException

Throws:

IOException