org.apache.giraph.comm.aggregators

Class CountingOutputStream

java.lang.Object

org.apache.giraph.comm.aggregators.CountingOutputStream

Direct Known Subclasses:

GlobalCommValueOutputStream

public abstract class CountingOutputStream
extends Object

Wrapper for output stream which keeps the place in the beginning for the count of objects which were written to it

Field Summary

Fields

Modifier and Type	Field and Description
protected ExtendedDataOutput	dataOutput DataOutput to which subclasses will be writing data

Constructor Summary

Constructors

Constructor and Description
CountingOutputStream() Default constructor

Method Summary

Modifier and Type	Method and Description
byte[]	flush() Returns all the data from the stream and clears it.
protected int	getSize() Get the number of bytes in the stream
protected void	incrementCounter() Subclasses should call this method when an object is written

Methods inherited from class java.lang.Object

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

Field Detail

dataOutput

protected ExtendedDataOutput dataOutput

DataOutput to which subclasses will be writing data

Constructor Detail

CountingOutputStream

public CountingOutputStream()

Default constructor

Method Detail

incrementCounter

protected void incrementCounter()

Subclasses should call this method when an object is written

getSize

protected int getSize()

Get the number of bytes in the stream

Returns:

Number of bytes

flush

public byte[] flush()

Returns all the data from the stream and clears it.

Returns:

Number of objects followed by the data written to the stream