org.apache.giraph.io.iterables

Interface GiraphReader<T>

Type Parameters:

T - Type of data which we are reading (can be vertex, edges, etc)

All Superinterfaces:

Iterator<T>

public interface GiraphReader<T>
extends Iterator<T>

Reader for some kind of data.

Method Summary

Modifier and Type	Method and Description
void	close() Close this GiraphReader to future operations.
float	getProgress() How much of the input has the GiraphReader consumed i.e.
void	initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) Use the input split and context to setup reading.

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Method Detail

initialize

void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                org.apache.hadoop.mapreduce.TaskAttemptContext context)
         throws IOException,
                InterruptedException

Use the input split and context to setup reading. Guaranteed to be called prior to any other function.

Parameters:

inputSplit - Input split to be used for reading.

context - Context from the task.

Throws:

IOException

InterruptedException

close

void close()
    throws IOException

Close this GiraphReader to future operations.

Throws:

IOException

getProgress

float getProgress()
           throws IOException,
                  InterruptedException

How much of the input has the GiraphReader consumed i.e. has been processed by?

Returns:

Progress from 0.0 to 1.0.

Throws:

IOException

InterruptedException