@InterfaceAudience.Private public class RowIndexEncoderV1 extends Object
Modifier and Type | Field and Description |
---|---|
private NoneEncoder |
encoder |
private Cell |
lastCell
The Cell previously appended.
|
private static org.slf4j.Logger |
LOG |
private DataOutputStream |
out |
private ByteArrayOutputStream |
rowsOffsetBAOS |
private int |
startOffset |
Constructor and Description |
---|
RowIndexEncoderV1(DataOutputStream out,
HFileBlockDefaultEncodingContext encodingCtx) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
beforeShipped() |
protected boolean |
checkRow(Cell cell) |
void |
flush() |
int |
write(Cell cell) |
private static final org.slf4j.Logger LOG
private DataOutputStream out
private NoneEncoder encoder
private int startOffset
private ByteArrayOutputStream rowsOffsetBAOS
public RowIndexEncoderV1(DataOutputStream out, HFileBlockDefaultEncodingContext encodingCtx)
public int write(Cell cell) throws IOException
IOException
protected boolean checkRow(Cell cell) throws IOException
IOException
public void flush() throws IOException
IOException
void beforeShipped()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.