org.apache.giraph.io.hcatalog

Class HCatalogVertexOutputFormat.MultiRowHCatalogVertexWriter<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.MultiRowHCatalogVertexWriter<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>

public abstract static class HCatalogVertexOutputFormat.MultiRowHCatalogVertexWriter<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 multiple rows.

Constructor Summary

Constructors

Constructor and Description
MultiRowHCatalogVertexWriter()

Method Summary

Modifier and Type	Method and Description
protected abstract Iterable<org.apache.hcatalog.data.HCatRecord>	createRecords(Vertex<I,V,E> vertex) create records
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

MultiRowHCatalogVertexWriter

public MultiRowHCatalogVertexWriter()

Method Detail

createRecords

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

create records

Parameters:

vertex - to populate records

Returns:

Iterable of records

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