Package org.apache.hadoop.hbase.regionserver.wal

Class AsyncProtobufLogWriter.OutputStreamWrapper

java.lang.Object

java.io.OutputStream

org.apache.hadoop.hbase.regionserver.wal.AsyncProtobufLogWriter.OutputStreamWrapper

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, ByteBufferWriter

Enclosing class:

AsyncProtobufLogWriter

private static final class AsyncProtobufLogWriter.OutputStreamWrapper
extends OutputStream
implements ByteBufferWriter

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	oneByteBuf
private final AsyncFSOutput	out

Constructor Summary

Constructors

Constructor	Description
OutputStreamWrapper(AsyncFSOutput out)

Method Summary

Modifier and Type	Method	Description
void	close()
void	write(byte[] b, int off, int len)
void	write(int b)
void	write(ByteBuffer b, int off, int len)	Writes len bytes from the specified ByteBuffer starting at offset off
void	writeInt(int i)	Writes an int to the underlying output stream as four bytes, high byte first.

Methods inherited from class java.io.OutputStream

flush, nullOutputStream, write

Methods inherited from class java.lang.Object

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

Field Details

out

private final AsyncFSOutput out

oneByteBuf

private final byte[] oneByteBuf

Constructor Details

OutputStreamWrapper

public OutputStreamWrapper(AsyncFSOutput out)

Method Details

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(ByteBuffer b,
 int off,
 int len)
           throws IOException

Description copied from interface: ByteBufferWriter

Writes len bytes from the specified ByteBuffer starting at offset off

Specified by:

write in interface ByteBufferWriter

Parameters:

b - the data.

off - the start offset in the data.

len - the number of bytes to write.

Throws:

IOException - if an I/O error occurs.

writeInt

public void writeInt(int i)
              throws IOException

Description copied from interface: ByteBufferWriter

Writes an int to the underlying output stream as four bytes, high byte first.

Specified by:

writeInt in interface ByteBufferWriter

Parameters:

i - the int to write

Throws:

IOException - if an I/O error occurs.

write

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

Overrides:

write in class OutputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException