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

@InterfaceAudience.Private
@InterfaceStability.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);

Constructor Summary

Constructors

Constructor and Description
ByteSlot()

Method Summary

Methods

Modifier and Type	Method and Description
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, write

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteSlot

public ByteSlot()

Method Detail

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