org.apache.giraph.io.hcatalog

Class HCatalogEdgeInputFormat.SingleRowHCatalogEdgeNoValueReader<I extends org.apache.hadoop.io.WritableComparable>

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,org.apache.hadoop.io.NullWritable>

org.apache.giraph.io.hcatalog.HCatalogEdgeInputFormat.SingleRowHCatalogEdgeNoValueReader<I>

All Implemented Interfaces:

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

Enclosing class:

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

protected abstract static class HCatalogEdgeInputFormat.SingleRowHCatalogEdgeNoValueReader<I extends org.apache.hadoop.io.WritableComparable>
extends HCatalogEdgeInputFormat.HCatalogEdgeReader<I,org.apache.hadoop.io.NullWritable>

HCatalogEdgeInputFormat.HCatalogEdgeReader for tables holding a complete edge in each row where the edges contain no data other than IDs they point to.

Constructor Summary

Constructors

Constructor and Description
SingleRowHCatalogEdgeNoValueReader(GiraphHCatInputFormat hCatInputFormat) Constructor

Method Summary

Modifier and Type	Method and Description
Edge<I,org.apache.hadoop.io.NullWritable>	getCurrentEdge()
I	getCurrentSourceId()
protected abstract I	getSourceVertexId(org.apache.hcatalog.data.HCatRecord record) Get source vertex id from a record.
protected abstract I	getTargetVertexId(org.apache.hcatalog.data.HCatRecord record) Get target vertex id from a record.

Methods inherited from class org.apache.giraph.io.hcatalog.HCatalogEdgeInputFormat.HCatalogEdgeReader

close, getContext, getProgress, getRecordReader, initialize, nextEdge

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

SingleRowHCatalogEdgeNoValueReader

public SingleRowHCatalogEdgeNoValueReader(GiraphHCatInputFormat hCatInputFormat)

Constructor

Parameters:

hCatInputFormat - giraph input format to use

Method Detail

getSourceVertexId

protected abstract I getSourceVertexId(org.apache.hcatalog.data.HCatRecord record)

Get source vertex id from a record.

Parameters:

record - Input record

Returns:

I Source vertex id

getTargetVertexId

protected abstract I getTargetVertexId(org.apache.hcatalog.data.HCatRecord record)

Get target vertex id from a record.

Parameters:

record - Input record

Returns:

I Target vertex id

getCurrentSourceId

public I getCurrentSourceId()
                     throws IOException,
                            InterruptedException

Specified by:

getCurrentSourceId in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException

getCurrentEdge

public Edge<I,org.apache.hadoop.io.NullWritable> getCurrentEdge()
                                                         throws IOException,
                                                                InterruptedException

Specified by:

getCurrentEdge in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException