org.apache.spark.util.io

Class ByteArrayChunkOutputStream

Object

java.io.OutputStream

org.apache.spark.util.io.ByteArrayChunkOutputStream

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, AutoCloseable

public class ByteArrayChunkOutputStream
extends java.io.OutputStream

An OutputStream that writes to fixed-size chunks of byte arrays.

Constructor Summary

Constructors

Constructor and Description
ByteArrayChunkOutputStream(int chunkSize)

Method Summary

Methods

Modifier and Type	Method and Description
byte[][]	toArrays()
void	write(byte[] bytes, int off, int len)
void	write(int b)

Methods inherited from class java.io.OutputStream

close, flush, write

Methods inherited from class Object

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

Constructor Detail

ByteArrayChunkOutputStream

public ByteArrayChunkOutputStream(int chunkSize)

Method Detail

write

public void write(int b)

Specified by:

write in class java.io.OutputStream

write

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

Overrides:

write in class java.io.OutputStream

toArrays

public byte[][] toArrays()