org.apache.giraph.utils.io

Class BigDataInputOutput

java.lang.Object

org.apache.giraph.utils.io.DataInputOutput

org.apache.giraph.utils.io.BigDataInputOutput

All Implemented Interfaces:

Factory<ExtendedDataInput>, org.apache.hadoop.io.Writable

public class BigDataInputOutput
extends DataInputOutput

DataInputOutput which uses BigDataInput and BigDataOutput to support larger than allowed array size streams.

Constructor Summary

Constructors

Constructor and Description
BigDataInputOutput(ImmutableClassesGiraphConfiguration conf) Constructor

Method Summary

Modifier and Type	Method and Description
ExtendedDataInput	createDataInput() Create DataInput which reads data from underlying DataOutput
DataOutput	getDataOutput() Get DataOutput to write to
void	readFields(DataInput in)
void	write(DataOutput out)

Methods inherited from class org.apache.giraph.utils.io.DataInputOutput

create

Methods inherited from class java.lang.Object

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

Constructor Detail

BigDataInputOutput

public BigDataInputOutput(ImmutableClassesGiraphConfiguration conf)

Constructor

Parameters:

conf - Configuration

Method Detail

getDataOutput

public DataOutput getDataOutput()

Description copied from class: DataInputOutput

Get DataOutput to write to

Specified by:

getDataOutput in class DataInputOutput

Returns:

DataOutput which we can write to

createDataInput

public ExtendedDataInput createDataInput()

Description copied from class: DataInputOutput

Create DataInput which reads data from underlying DataOutput

Specified by:

createDataInput in class DataInputOutput

Returns:

DataInput

write

public void write(DataOutput out)
           throws IOException

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Throws:

IOException