@InterfaceAudience.Private class StoreFileListFile extends Object
Modifier and Type | Field and Description |
---|---|
private StoreContext |
ctx |
private static org.slf4j.Logger |
LOG |
private static int |
MAX_FILE_SIZE |
private int |
nextTrackFile |
private long |
prevTimestamp |
(package private) static String |
TRACK_FILE_DIR |
(package private) static Pattern |
TRACK_FILE_PATTERN |
private static String |
TRACK_FILE_PREFIX |
private static String |
TRACK_FILE_ROTATE_PREFIX |
private static char |
TRACK_FILE_SEPARATOR |
private org.apache.hadoop.fs.Path |
trackFileDir |
private org.apache.hadoop.fs.Path[] |
trackFiles |
Constructor and Description |
---|
StoreFileListFile(StoreContext ctx) |
Modifier and Type | Method and Description |
---|---|
private void |
cleanUpTrackFiles(long loadedSeqId,
NavigableMap<Long,List<org.apache.hadoop.fs.Path>> seqId2TrackFiles) |
private void |
initializeTrackFiles(long seqId) |
private NavigableMap<Long,List<org.apache.hadoop.fs.Path>> |
listFiles() |
(package private) org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList |
load(boolean readOnly) |
(package private) static org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList |
load(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
(package private) org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList |
load(org.apache.hadoop.fs.Path path) |
private int |
select(org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList[] lists) |
(package private) void |
update(org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList.Builder builder)
We will set the timestamp in this method so just pass the builder in
|
private static final org.slf4j.Logger LOG
static final String TRACK_FILE_DIR
private static final String TRACK_FILE_PREFIX
private static final String TRACK_FILE_ROTATE_PREFIX
private static final char TRACK_FILE_SEPARATOR
static final Pattern TRACK_FILE_PATTERN
private static final int MAX_FILE_SIZE
private final StoreContext ctx
private final org.apache.hadoop.fs.Path trackFileDir
private final org.apache.hadoop.fs.Path[] trackFiles
private long prevTimestamp
private int nextTrackFile
StoreFileListFile(StoreContext ctx)
static org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList load(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
IOException
org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList load(org.apache.hadoop.fs.Path path) throws IOException
IOException
private int select(org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList[] lists)
private NavigableMap<Long,List<org.apache.hadoop.fs.Path>> listFiles() throws IOException
IOException
private void initializeTrackFiles(long seqId)
private void cleanUpTrackFiles(long loadedSeqId, NavigableMap<Long,List<org.apache.hadoop.fs.Path>> seqId2TrackFiles)
org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList load(boolean readOnly) throws IOException
IOException
void update(org.apache.hadoop.hbase.shaded.protobuf.generated.StoreFileTrackerProtos.StoreFileList.Builder builder) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.