@InterfaceAudience.Private @InterfaceStability.Evolving public class ProcedureWALFile extends Object implements Comparable<ProcedureWALFile>
| Constructor and Description |
|---|
ProcedureWALFile(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.FileStatus logStatus) |
ProcedureWALFile(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logFile,
ProcedureProtos.ProcedureWALHeader header,
long startPos) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
int |
compareTo(ProcedureWALFile other) |
boolean |
equals(Object o) |
ProcedureProtos.ProcedureWALHeader |
getHeader() |
long |
getLogId() |
long |
getMaxProcId() |
long |
getMinProcId() |
long |
getSize() |
org.apache.hadoop.fs.FSDataInputStream |
getStream() |
int |
hashCode() |
boolean |
isCompacted() |
void |
open() |
void |
readTracker(ProcedureStoreTracker tracker) |
ProcedureProtos.ProcedureWALTrailer |
readTrailer() |
void |
removeFile() |
void |
setProcIds(long minId,
long maxId) |
String |
toString() |
public ProcedureWALFile(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.FileStatus logStatus)
public ProcedureWALFile(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logFile,
ProcedureProtos.ProcedureWALHeader header,
long startPos)
public void open()
throws IOException
IOExceptionpublic ProcedureProtos.ProcedureWALTrailer readTrailer() throws IOException
IOExceptionpublic void readTracker(ProcedureStoreTracker tracker) throws IOException
IOExceptionpublic void close()
public org.apache.hadoop.fs.FSDataInputStream getStream()
public ProcedureProtos.ProcedureWALHeader getHeader()
public boolean isCompacted()
public long getLogId()
public long getSize()
public void removeFile()
throws IOException
IOExceptionpublic void setProcIds(long minId,
long maxId)
public long getMinProcId()
public long getMaxProcId()
public int compareTo(ProcedureWALFile other)
compareTo in interface Comparable<ProcedureWALFile>Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.