org.apache.giraph.utils

Class ExtendedByteArrayOutputBuffer

java.lang.Object

org.apache.giraph.utils.ExtendedByteArrayOutputBuffer

public class ExtendedByteArrayOutputBuffer
extends Object

Wraps a list of byte array outputs and provides convenient utilities on top of it

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExtendedByteArrayOutputBuffer.IndexAndDataOut Holder for index & DataOutput objects

Field Summary

Fields

Modifier and Type	Field and Description
static IntConfOption	CAPACITY_OF_DATAOUT_IN_BUFFER This option sets the capacity of an ExtendedDataOutput instance created in ExtendedByteArrayOutputBuffer
static FloatConfOption	FILLING_THRESHOLD_OF_DATAOUT_IN_BUFFER This option sets the maximum fraction of a ExtendedDataOutput instance (stored in ExtendedByteArrayOutputBuffer) that can be filled

Constructor Summary

Constructors

Constructor and Description
ExtendedByteArrayOutputBuffer(ImmutableClassesGiraphConfiguration<?,?,?> config) Constructor

Method Summary

Modifier and Type	Method and Description
ExtendedDataOutput	getDataOutput(int index) Get dataoutput from bytearrayOutputs
ExtendedByteArrayOutputBuffer.IndexAndDataOut	getIndexAndDataOut() Return threadLocal indexAndDataOutput instance

Methods inherited from class java.lang.Object

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

Field Detail

CAPACITY_OF_DATAOUT_IN_BUFFER

public static final IntConfOption CAPACITY_OF_DATAOUT_IN_BUFFER

This option sets the capacity of an ExtendedDataOutput instance created in ExtendedByteArrayOutputBuffer

FILLING_THRESHOLD_OF_DATAOUT_IN_BUFFER

public static final FloatConfOption FILLING_THRESHOLD_OF_DATAOUT_IN_BUFFER

This option sets the maximum fraction of a ExtendedDataOutput instance (stored in ExtendedByteArrayOutputBuffer) that can be filled

Constructor Detail

ExtendedByteArrayOutputBuffer

public ExtendedByteArrayOutputBuffer(ImmutableClassesGiraphConfiguration<?,?,?> config)

Constructor

Parameters:

config - configuration

Method Detail

getIndexAndDataOut

public ExtendedByteArrayOutputBuffer.IndexAndDataOut getIndexAndDataOut()

Return threadLocal indexAndDataOutput instance

Returns:

threadLocal indexAndDataOutput instance

getDataOutput

public ExtendedDataOutput getDataOutput(int index)

Get dataoutput from bytearrayOutputs

Parameters:

index - index in bytearrayOutputs

Returns:

extendeddataoutput at given index