@InterfaceAudience.Private @InterfaceStability.Evolving public class ProcedureWALFile extends java.lang.Object implements java.lang.Comparable<ProcedureWALFile>
Constructor and Description |
---|
ProcedureWALFile(FileSystem fs,
FileStatus logStatus) |
ProcedureWALFile(FileSystem fs,
Path logFile,
ProcedureProtos.ProcedureWALHeader header,
long startPos,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
compareTo(ProcedureWALFile other) |
boolean |
equals(java.lang.Object o) |
ProcedureProtos.ProcedureWALHeader |
getHeader() |
long |
getLogId() |
long |
getMaxProcId() |
long |
getMinProcId() |
long |
getSize() |
FSDataInputStream |
getStream() |
long |
getTimestamp() |
int |
hashCode() |
boolean |
isCompacted() |
void |
open() |
void |
readTracker(ProcedureStoreTracker tracker) |
ProcedureProtos.ProcedureWALTrailer |
readTrailer() |
void |
removeFile() |
void |
setProcIds(long minId,
long maxId) |
java.lang.String |
toString() |
public ProcedureWALFile(FileSystem fs, FileStatus logStatus)
public ProcedureWALFile(FileSystem fs, Path logFile, ProcedureProtos.ProcedureWALHeader header, long startPos, long timestamp)
public void open() throws java.io.IOException
java.io.IOException
public ProcedureProtos.ProcedureWALTrailer readTrailer() throws java.io.IOException
java.io.IOException
public void readTracker(ProcedureStoreTracker tracker) throws java.io.IOException
java.io.IOException
public void close()
public FSDataInputStream getStream()
public ProcedureProtos.ProcedureWALHeader getHeader()
public long getTimestamp()
public boolean isCompacted()
public long getLogId()
public long getSize()
public void removeFile() throws java.io.IOException
java.io.IOException
public void setProcIds(long minId, long maxId)
public long getMinProcId()
public long getMaxProcId()
public int compareTo(ProcedureWALFile other)
compareTo
in interface java.lang.Comparable<ProcedureWALFile>
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object