@InterfaceAudience.Private public class ProcedureWALFile extends Object implements Comparable<ProcedureWALFile>
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.fs.FileSystem |
fs |
private org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader |
header |
private static org.slf4j.Logger |
LOG |
private org.apache.hadoop.fs.Path |
logFile |
private long |
logSize |
private long |
maxProcId |
private long |
minProcId |
private long |
startPos |
private org.apache.hadoop.fs.FSDataInputStream |
stream |
private long |
timestamp |
private ProcedureStoreTracker |
tracker |
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,
org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader header,
long startPos,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
addToSize(long size)
Used to update in-progress log sizes.
|
void |
close() |
int |
compareTo(ProcedureWALFile other) |
boolean |
equals(Object o) |
org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader |
getHeader() |
long |
getLogId() |
long |
getMaxProcId() |
long |
getMinProcId() |
long |
getSize() |
org.apache.hadoop.fs.FSDataInputStream |
getStream() |
long |
getTimestamp() |
ProcedureStoreTracker |
getTracker() |
int |
hashCode() |
boolean |
isCompacted() |
void |
open() |
void |
readTracker() |
org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALTrailer |
readTrailer() |
void |
removeFile(org.apache.hadoop.fs.Path walArchiveDir) |
void |
setProcIds(long minId,
long maxId) |
String |
toString() |
void |
updateLocalTracker(ProcedureStoreTracker tracker) |
private static final org.slf4j.Logger LOG
private org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader header
private org.apache.hadoop.fs.FSDataInputStream stream
private org.apache.hadoop.fs.FileSystem fs
private org.apache.hadoop.fs.Path logFile
private long startPos
private long minProcId
private long maxProcId
private long logSize
private long timestamp
private final ProcedureStoreTracker tracker
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, org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader header, long startPos, long timestamp)
public ProcedureStoreTracker getTracker()
public void open() throws IOException
IOException
public org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALTrailer readTrailer() throws IOException
IOException
public void readTracker() throws IOException
IOException
public void updateLocalTracker(ProcedureStoreTracker tracker)
public void close()
public org.apache.hadoop.fs.FSDataInputStream getStream()
public org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader getHeader()
public long getTimestamp()
public boolean isCompacted()
public long getLogId()
public long getSize()
void addToSize(long size)
public void removeFile(org.apache.hadoop.fs.Path walArchiveDir) 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–2020 The Apache Software Foundation. All rights reserved.