Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• header

  private org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALHeader header

• stream

  private org.apache.hadoop.fs.FSDataInputStream stream

• logStatus

  private org.apache.hadoop.fs.FileStatus logStatus

• fs

  private org.apache.hadoop.fs.FileSystem fs

• logFile

  private org.apache.hadoop.fs.Path logFile

• startPos

  private long startPos

• minProcId

  private long minProcId

• maxProcId

  private long maxProcId

Constructor Detail

• ProcedureWALFile

  public ProcedureWALFile(org.apache.hadoop.fs.FileSystem fs,
                  org.apache.hadoop.fs.FileStatus logStatus)

• ProcedureWALFile

  public ProcedureWALFile(org.apache.hadoop.fs.FileSystem fs,
                  org.apache.hadoop.fs.Path logFile,
                  org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALHeader header,
                  long startPos)

Method Detail

• open

  public void open()
            throws IOException

  Throws:

  IOException

• readTrailer

  public org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALTrailer readTrailer()
                                                                                             throws IOException

  Throws:

  IOException

• readTracker

  public void readTracker(ProcedureStoreTracker tracker)
                   throws IOException

  Throws:

  IOException

• close

  public void close()

• getStream

  public org.apache.hadoop.fs.FSDataInputStream getStream()

• getHeader

  public org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALHeader getHeader()

• isCompacted

  public boolean isCompacted()

• getLogId

  public long getLogId()

• getSize

  public long getSize()

• removeFile

  public void removeFile()
                  throws IOException

  Throws:

  IOException

• setProcIds

  public void setProcIds(long minId,
                long maxId)

• getMinProcId

  public long getMinProcId()

• getMaxProcId

  public long getMaxProcId()

• compareTo

  public int compareTo(ProcedureWALFile other)

  Specified by:

  compareTo in interface Comparable<ProcedureWALFile>

• equals

  public boolean equals(Object o)

  Overrides:

  equals in class Object

• hashCode

  public int hashCode()

  Overrides:

  hashCode in class Object

• toString

  public String toString()

  Overrides:

  toString in class Object