Package org.apache.hadoop.hbase.io.encoding

Class RowIndexEncoderV1

java.lang.Object

org.apache.hadoop.hbase.io.encoding.RowIndexEncoderV1

@Private
public class RowIndexEncoderV1
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final HFileBlockEncodingContext	context
private NoneEncoder	encoder
private ExtendedCell	lastCell	The Cell previously appended.
private static final org.slf4j.Logger	LOG
private DataOutputStream	out
private ByteArrayOutputStream	rowsOffsetBAOS
private int	startOffset

Constructor Summary

Constructors

Constructor	Description
RowIndexEncoderV1(DataOutputStream out, HFileBlockDefaultEncodingContext encodingCtx)

Method Summary

Modifier and Type	Method	Description
(package private) void	beforeShipped()
protected boolean	checkRow(ExtendedCell cell)
void	flush()
void	write(ExtendedCell cell)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

lastCell

private ExtendedCell lastCell

The Cell previously appended.

out

private DataOutputStream out

encoder

private NoneEncoder encoder

startOffset

private int startOffset

rowsOffsetBAOS

private ByteArrayOutputStream rowsOffsetBAOS

context

private final HFileBlockEncodingContext context

Constructor Details

RowIndexEncoderV1

public RowIndexEncoderV1(DataOutputStream out,
 HFileBlockDefaultEncodingContext encodingCtx)

Method Details

write

public void write(ExtendedCell cell)
           throws IOException

Throws:

IOException

checkRow

protected boolean checkRow(ExtendedCell cell)
                    throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

beforeShipped

void beforeShipped()