public static class StoreFile.Writer extends java.lang.Object implements Compactor.CellSink
Modifier and Type | Field and Description |
---|---|
protected int |
bytesPerChecksum
Bytes per Checksum
|
protected HFile.Writer |
writer |
Modifier and Type | Method and Description |
---|---|
void |
append(Cell cell) |
void |
appendFileInfo(byte[] key,
byte[] value) |
void |
appendMetadata(long maxSequenceId,
boolean majorCompaction)
Writes meta data.
|
void |
appendMetadata(long maxSequenceId,
boolean majorCompaction,
long mobCellsCount)
Writes meta data.
|
void |
appendTrackedTimestampsToMetadata()
Add TimestampRange and earliest put timestamp to Metadata
|
void |
close() |
Path |
getPath() |
boolean |
hasGeneralBloom() |
void |
setTimeRangeTracker(TimeRangeTracker trt)
Set TimeRangeTracker
|
void |
trackTimestamps(Cell cell)
Record the earlest Put timestamp.
|
protected int bytesPerChecksum
protected HFile.Writer writer
public void appendMetadata(long maxSequenceId, boolean majorCompaction) throws java.io.IOException
close()
since its written as meta data to this file.maxSequenceId
- Maximum sequence id.majorCompaction
- True if this file is product of a major compactionjava.io.IOException
- problem writing to FSpublic void appendMetadata(long maxSequenceId, boolean majorCompaction, long mobCellsCount) throws java.io.IOException
close()
since its written as meta data to this file.maxSequenceId
- Maximum sequence id.majorCompaction
- True if this file is product of a major compactionmobCellsCount
- The number of mob cells.java.io.IOException
- problem writing to FSpublic void appendTrackedTimestampsToMetadata() throws java.io.IOException
java.io.IOException
public void setTimeRangeTracker(TimeRangeTracker trt)
trt
- public void trackTimestamps(Cell cell)
cell
- public void append(Cell cell) throws java.io.IOException
append
in interface Compactor.CellSink
java.io.IOException
public Path getPath()
public boolean hasGeneralBloom()
public void close() throws java.io.IOException
java.io.IOException
public void appendFileInfo(byte[] key, byte[] value) throws java.io.IOException
java.io.IOException