Package org.aksw.iguana.commons.io

Class BigByteArrayOutputStream

java.lang.Object

java.io.OutputStream

org.aksw.iguana.commons.io.ReversibleOutputStream

org.aksw.iguana.commons.io.BigByteArrayOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class BigByteArrayOutputStream
extends ReversibleOutputStream

This class represents a ByteArrayOutputStream that can hold a large amount of byte data. It is designed to overcome the limitations of the standard ByteArrayOutputStream, which has a fixed internal byte array and can run into out of memory errors when trying to write a large amount of data.

The BigByteArrayOutputStream works by using an ArrayList of ByteArrayOutputStreams to store the byte data. When the current ByteArrayOutputStream fills up, a new one is created with the maximum array size (Integer.MAX_VALUE - 8) as its initial capacity and added to the list. Writing data to the stream involves writing to the current active ByteArrayOutputStream. When the stream is cleared, all the internal ByteArrayOutputStreams are cleared and a new one is added to the list.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ARRAY_SIZE_LIMIT	The maximum size limit for an array.

Constructor Summary

Constructors

Constructor	Description
BigByteArrayOutputStream()	Initializes a new instance of the BigByteArrayOutputStream class with default buffer size.
BigByteArrayOutputStream(int bufferSize)	Initializes a new instance of the BigByteArrayOutputStream class with buffer size.
BigByteArrayOutputStream(long bufferSize)	Initializes a new instance of the BigByteArrayOutputStream class with buffer size.

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears the state of the object by removing all ByteArrayOutputStreams from the baosList except for the first one.
void	close()
List<org.apache.hadoop.hbase.io.ByteArrayOutputStream>	getBaos()
void	reset()	Resets the state of the object by setting the baosListIndex to zero and assigning the first ByteArrayOutputStream in the baosList to the currentBaos variable.
long	size()
byte[][]	toByteArray()
InputStream	toInputStream()
void	write(byte b)
void	write(byte[][] byteArray)
void	write(byte[] b, int off, int len)
void	write(int i)
void	write(BigByteArrayOutputStream bbaos)

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

ARRAY_SIZE_LIMIT

public static final int ARRAY_SIZE_LIMIT

The maximum size limit for an array. This is no limit to the amount of bytes BigByteArrayOutputStream can consume.

See Also:

• Constant Field Values

Constructor Details

BigByteArrayOutputStream

public BigByteArrayOutputStream()

Initializes a new instance of the BigByteArrayOutputStream class with default buffer size.

BigByteArrayOutputStream

public BigByteArrayOutputStream(int bufferSize)

Initializes a new instance of the BigByteArrayOutputStream class with buffer size.

Parameters:

bufferSize - initial guaranteed buffer size

BigByteArrayOutputStream

public BigByteArrayOutputStream(long bufferSize)

Initializes a new instance of the BigByteArrayOutputStream class with buffer size.

Parameters:

bufferSize - initial guaranteed buffer size

Method Details

getBaos

public List<org.apache.hadoop.hbase.io.ByteArrayOutputStream> getBaos()

write

public void write(BigByteArrayOutputStream bbaos)
           throws IOException

Throws:

IOException

size

public long size()

Specified by:

size in class ReversibleOutputStream

toByteArray

public byte[][] toByteArray()

write

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

Overrides:

write in class OutputStream

Throws:

IOException

write

public void write(byte[][] byteArray)
           throws IOException

Throws:

IOException

write

public void write(byte b)
           throws IOException

Throws:

IOException

write

public void write(int i)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

reset

public void reset()
           throws IOException

Resets the state of the object by setting the baosListIndex to zero and assigning the first ByteArrayOutputStream in the baosList to the currentBaos variable. No ByteArrayOutputStreams are actually removed.

Throws:

IOException

clear

public void clear()
           throws IOException

Clears the state of the object by removing all ByteArrayOutputStreams from the baosList except for the first one. The baosListIndex is set to 1 and the currentBaos variable is reassigned to the first ByteArrayOutputStream in the baosList.

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

toInputStream

public InputStream toInputStream()

Specified by:

toInputStream in class ReversibleOutputStream