org.apache.giraph.io.hcatalog

Class HCatalogEdgeInputFormat.HCatalogEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<I,org.apache.hadoop.io.Writable,E>

org.apache.giraph.io.EdgeReader<I,E>

org.apache.giraph.io.hcatalog.HCatalogEdgeInputFormat.HCatalogEdgeReader<I,E>

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<I,org.apache.hadoop.io.Writable,E>, ImmutableClassesGiraphConfigurable<I,org.apache.hadoop.io.Writable,E>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Direct Known Subclasses:

HCatalogEdgeInputFormat.SingleRowHCatalogEdgeNoValueReader, HCatalogEdgeInputFormat.SingleRowHCatalogEdgeReader

Enclosing class:

HCatalogEdgeInputFormat<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

protected abstract static class HCatalogEdgeInputFormat.HCatalogEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
extends EdgeReader<I,E>

EdgeReader for HCatalogEdgeInputFormat.

Constructor Summary

Constructors

Constructor and Description
HCatalogEdgeReader(GiraphHCatInputFormat hCatInputFormat) Constructor taking hcat input format to use.

Method Summary

Modifier and Type	Method and Description
void	close()
protected org.apache.hadoop.mapreduce.TaskAttemptContext	getContext() Get the context.
float	getProgress()
protected org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.WritableComparable,org.apache.hcatalog.data.HCatRecord>	getRecordReader() Get the record reader.
void	initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context)
boolean	nextEdge()

Methods inherited from class org.apache.giraph.io.EdgeReader

getCurrentEdge, getCurrentSourceId

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

HCatalogEdgeReader

public HCatalogEdgeReader(GiraphHCatInputFormat hCatInputFormat)

Constructor taking hcat input format to use.

Parameters:

hCatInputFormat - HCatalog input format

Method Detail

initialize

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

Specified by:

initialize in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Throws:

IOException

InterruptedException

nextEdge

public boolean nextEdge()
                 throws IOException,
                        InterruptedException

Specified by:

nextEdge in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Throws:

IOException

InterruptedException

close

public final void close()
                 throws IOException

Specified by:

close in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Throws:

IOException

getProgress

public final float getProgress()
                        throws IOException,
                               InterruptedException

Specified by:

getProgress in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Throws:

IOException

InterruptedException

getRecordReader

protected final org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.WritableComparable,org.apache.hcatalog.data.HCatRecord> getRecordReader()

Get the record reader.

Returns:

Record reader to be used for reading.

getContext

protected final org.apache.hadoop.mapreduce.TaskAttemptContext getContext()

Get the context.

Returns:

Context passed to initialize.