org.apache.reef.io.storage

Class FramingOutputStream

java.lang.Object

java.io.OutputStream

org.apache.reef.io.storage.FramingOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, Accumulable<byte[]>

public class FramingOutputStream
extends OutputStream
implements Accumulable<byte[]>

Constructor Summary

Constructors

Constructor and Description
FramingOutputStream(OutputStream o)

Method Summary

Methods

Modifier and Type	Method and Description
Accumulator<byte[]>	accumulator() Returns a new Accumulator.
void	close()
void	flush()
long	getCurrentOffset()
void	nextFrame()
void	write(byte[] b)
void	write(byte[] b, int offset, int length)
void	write(int b)

Methods inherited from class java.lang.Object

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

Constructor Detail

FramingOutputStream

public FramingOutputStream(OutputStream o)

Method Detail

nextFrame

public void nextFrame()
               throws StorageException

Throws:

StorageException

getCurrentOffset

public long getCurrentOffset()

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b,
         int offset,
         int length)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

flush

public void flush()

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class OutputStream

Throws:

IOException

accumulator

public Accumulator<byte[]> accumulator()
                                throws StorageException

Description copied from interface: Accumulable

Returns a new Accumulator.

Specified by:

accumulator in interface Accumulable<byte[]>

Returns:

the new Accumulator

Throws:

StorageException