org.apache.giraph.io.hcatalog

Class HCatalogVertexInputFormat.SingleRowHCatalogVertexReader

java.lang.Object

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

org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E>

org.apache.giraph.io.VertexReader<I,V,E>

org.apache.giraph.io.hcatalog.HCatalogVertexInputFormat.HCatalogVertexReader

org.apache.giraph.io.hcatalog.HCatalogVertexInputFormat.SingleRowHCatalogVertexReader

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

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

protected abstract class HCatalogVertexInputFormat.SingleRowHCatalogVertexReader
extends HCatalogVertexInputFormat.HCatalogVertexReader

HCatalogVertexReader for tables holding complete vertex info within each row.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SingleRowHCatalogVertexReader()

Method Summary

Modifier and Type	Method and Description
Vertex<I,V,E>	getCurrentVertex() Get the current vertex.
protected abstract Iterable<Edge<I,E>>	getEdges(org.apache.hcatalog.data.HCatRecord record) get edges.
protected abstract I	getVertexId(org.apache.hcatalog.data.HCatRecord record) get vertex id.
protected abstract V	getVertexValue(org.apache.hcatalog.data.HCatRecord record) get vertex value.

Methods inherited from class org.apache.giraph.io.hcatalog.HCatalogVertexInputFormat.HCatalogVertexReader

close, getContext, getProgress, getRecordReader, initialize, nextVertex

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

SingleRowHCatalogVertexReader

protected SingleRowHCatalogVertexReader()

Method Detail

getVertexId

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

get vertex id.

Parameters:

record - hcat record

Returns:

I id

getVertexValue

protected abstract V getVertexValue(org.apache.hcatalog.data.HCatRecord record)

get vertex value.

Parameters:

record - hcat record

Returns:

V value

getEdges

protected abstract Iterable<Edge<I,E>> getEdges(org.apache.hcatalog.data.HCatRecord record)

get edges.

Parameters:

record - hcat record

Returns:

Edges

getCurrentVertex

public final Vertex<I,V,E> getCurrentVertex()
                                     throws IOException,
                                            InterruptedException

Description copied from class: VertexReader

Get the current vertex.

Specified by:

getCurrentVertex in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Returns:

the current vertex which has been read. nextVertex() should be called first.

Throws:

IOException

InterruptedException