org.apache.giraph.io.hcatalog

Class HCatalogVertexOutputFormat.SingleRowHCatalogVertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

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

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

org.apache.giraph.io.hcatalog.HCatalogVertexOutputFormat.HCatalogVertexWriter<I,V,E>

org.apache.giraph.io.hcatalog.HCatalogVertexOutputFormat.SingleRowHCatalogVertexWriter<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Implemented Interfaces:

GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, SimpleVertexWriter<I,V,E>

Enclosing class:

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

protected abstract static class HCatalogVertexOutputFormat.SingleRowHCatalogVertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends HCatalogVertexOutputFormat.HCatalogVertexWriter<I,V,E>

HCatalogVertexWriter to write each vertex in each row.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SingleRowHCatalogVertexWriter()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hcatalog.data.HCatRecord	createRecord(Vertex<I,V,E> vertex) create record
protected abstract void	fillRecord(org.apache.hcatalog.data.HCatRecord record, Vertex<I,V,E> vertex) fill record
protected abstract int	getNumColumns() get num columns
void	writeVertex(Vertex<I,V,E> vertex) Writes the next vertex and associated data

Methods inherited from class org.apache.giraph.io.hcatalog.HCatalogVertexOutputFormat.HCatalogVertexWriter

close, getContext, getRecordWriter, initialize, initialize

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

SingleRowHCatalogVertexWriter

protected SingleRowHCatalogVertexWriter()

Method Detail

getNumColumns

protected abstract int getNumColumns()

get num columns

Returns:

intcolumns

fillRecord

protected abstract void fillRecord(org.apache.hcatalog.data.HCatRecord record,
                                   Vertex<I,V,E> vertex)

fill record

Parameters:

record - to fill

vertex - to populate record

createRecord

protected org.apache.hcatalog.data.HCatRecord createRecord(Vertex<I,V,E> vertex)

create record

Parameters:

vertex - to populate record

Returns:

HCatRecord newly created

writeVertex

public final void writeVertex(Vertex<I,V,E> vertex)
                       throws IOException,
                              InterruptedException

Description copied from interface: SimpleVertexWriter

Writes the next vertex and associated data

Parameters:

vertex - set the properties of this vertex

Throws:

IOException

InterruptedException