@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
IOException
public ProcedureProtos.ProcedureWALTrailer readTrailer() throws IOException
IOException
public void readTracker(ProcedureStoreTracker tracker) throws IOException
IOException
public 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
IOException
public 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.