org.apache.tinkerpop.gremlin.hadoop.structure.io

Class CommonFileOutputFormat

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<K,V>

org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<org.apache.hadoop.io.NullWritable,VertexWritable>

org.apache.tinkerpop.gremlin.hadoop.structure.io.CommonFileOutputFormat

All Implemented Interfaces:

PersistResultGraphAware

Direct Known Subclasses:

GraphSONOutputFormat, GryoOutputFormat, ScriptOutputFormat

public abstract class CommonFileOutputFormat
extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<org.apache.hadoop.io.NullWritable,VertexWritable>
implements PersistResultGraphAware

Author:

Marko A. Rodriguez (http://markorodriguez.com)

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

org.apache.hadoop.mapreduce.lib.output.FileOutputFormat.Counter

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

BASE_OUTPUT_NAME, PART

Constructor Summary

Constructors

Constructor and Description
CommonFileOutputFormat()

Method Summary

Modifier and Type	Method and Description
protected DataOutputStream	getDataOuputStream(org.apache.hadoop.mapreduce.TaskAttemptContext job)
boolean	supportsResultGraphPersistCombination(GraphComputer.ResultGraph resultGraph, GraphComputer.Persist persist)

Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getRecordWriter, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CommonFileOutputFormat

public CommonFileOutputFormat()

Method Detail

getDataOuputStream

protected DataOutputStream getDataOuputStream(org.apache.hadoop.mapreduce.TaskAttemptContext job)
                                       throws IOException,
                                              InterruptedException

Throws:

IOException

InterruptedException

supportsResultGraphPersistCombination

public boolean supportsResultGraphPersistCombination(GraphComputer.ResultGraph resultGraph,
                                                     GraphComputer.Persist persist)

Specified by:

supportsResultGraphPersistCombination in interface PersistResultGraphAware