Package org.apache.hadoop.hbase.procedure2.util

Class ByteSlot

java.lang.Object

java.io.OutputStream

org.apache.hadoop.hbase.procedure2.util.ByteSlot

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

@Private
@Evolving
public class ByteSlot
extends OutputStream

Similar to the ByteArrayOutputStream, with the exception that we can prepend an header. e.g. you write some data and you want to prepend an header that contains the data len or cksum. ByteSlot slot = new ByteSlot(); // write data slot.write(...); slot.write(...); // write header with the size of the written data slot.markHead(); slot.write(Bytes.toBytes(slot.size())); // flush to stream as [header, data] slot.writeTo(stream);

Field Summary

Fields

Modifier and Type	Field	Description
private byte[]	buf
private static final int	GROW_ALIGN
private int	head
private static final int	LARGE_GROW_SIZE
private static final int	LARGE_GROW_SIZE_THRESHOLD
private static final int	RESET_THRESHOLD
private int	size

Constructor Summary

Constructors

Constructor	Description
ByteSlot()

Method Summary

Modifier and Type	Method	Description
private void	ensureCapacity(int minCapacity)
byte[]	getBuffer()
int	getHead()
void	markHead()
void	reset()
int	size()
void	write(byte[] b, int off, int len)
void	write(int b)
void	writeAt(int offset, int b)
void	writeTo(OutputStream stream)

Methods inherited from class java.io.OutputStream

close, flush, nullOutputStream, write

Methods inherited from class java.lang.Object

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

Field Details

LARGE_GROW_SIZE_THRESHOLD

private static final int LARGE_GROW_SIZE_THRESHOLD

See Also:

• Constant Field Values

LARGE_GROW_SIZE

private static final int LARGE_GROW_SIZE

See Also:

• Constant Field Values

RESET_THRESHOLD

private static final int RESET_THRESHOLD

See Also:

• Constant Field Values

GROW_ALIGN

private static final int GROW_ALIGN

See Also:

• Constant Field Values

buf

private byte[] buf

head

private int head

size

private int size

Constructor Details

ByteSlot

public ByteSlot()

Method Details

reset

public void reset()

markHead

public void markHead()

getHead

public int getHead()

size

public int size()

getBuffer

public byte[] getBuffer()

writeAt

public void writeAt(int offset,
 int b)

write

public void write(int b)

Specified by:

write in class OutputStream

write

public void write(byte[] b,
 int off,
 int len)

Overrides:

write in class OutputStream

writeTo

public void writeTo(OutputStream stream)
             throws IOException

Throws:

IOException

ensureCapacity

private void ensureCapacity(int minCapacity)