org.apache.giraph.io.hcatalog

Class HCatalogEdgeInputFormat.SingleRowHCatalogEdgeReader<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>

org.apache.giraph.io.hcatalog.HCatalogEdgeInputFormat.SingleRowHCatalogEdgeReader<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

Enclosing class:

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

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

HCatalogEdgeInputFormat.HCatalogEdgeReader for tables holding a complete edge in each row.

Constructor Summary

Constructors

Constructor and Description
SingleRowHCatalogEdgeReader(GiraphHCatInputFormat hCatInputFormat) Constructor

Method Summary

Modifier and Type	Method and Description
Edge<I,E>	getCurrentEdge() Get the current edge.
I	getCurrentSourceId() Get the current edge source id.
protected abstract E	getEdgeValue(org.apache.hcatalog.data.HCatRecord record) Get edge value from a record.
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

SingleRowHCatalogEdgeReader

public SingleRowHCatalogEdgeReader(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

getEdgeValue

protected abstract E getEdgeValue(org.apache.hcatalog.data.HCatRecord record)

Get edge value from a record.

Parameters:

record - Input record

Returns:

E Edge value

getCurrentSourceId

public I getCurrentSourceId()
                     throws IOException,
                            InterruptedException

Description copied from class: EdgeReader

Get the current edge source id.

Specified by:

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

Returns:

Current edge source id which has been read. nextEdge() should be called first.

Throws:

IOException

InterruptedException

getCurrentEdge

public Edge<I,E> getCurrentEdge()
                         throws IOException,
                                InterruptedException

Description copied from class: EdgeReader

Get the current edge.

Specified by:

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

Returns:

the current edge which has been read. nextEdge() should be called first.

Throws:

IOException

InterruptedException