org.apache.tinkerpop.gremlin.spark.structure.io

Class OutputFormatRDD

java.lang.Object

org.apache.tinkerpop.gremlin.spark.structure.io.OutputFormatRDD

All Implemented Interfaces:

OutputRDD

public final class OutputFormatRDD
extends Object
implements OutputRDD

Author:

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

Constructor Summary

Constructors

Constructor and Description
OutputFormatRDD()

Method Summary

Modifier and Type	Method and Description
void	writeGraphRDD(Configuration configuration, <any> graphRDD) Write the graphRDD to an output location.
<K,V> Iterator<KeyValue<K,V>>	writeMemoryRDD(Configuration configuration, String memoryKey, <any> memoryRDD) Write the sideEffect memoryRDD to an output location.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputFormatRDD

public OutputFormatRDD()

Method Detail

writeGraphRDD

public void writeGraphRDD(Configuration configuration,
                          <any> graphRDD)

Description copied from interface: OutputRDD

Write the graphRDD to an output location. The Configuration maintains the specified location via Constants.GREMLIN_HADOOP_OUTPUT_LOCATION.

Specified by:

writeGraphRDD in interface OutputRDD

Parameters:

configuration - the configuration of the Spark job

graphRDD - the graphRDD to output

writeMemoryRDD

public <K,V> Iterator<KeyValue<K,V>> writeMemoryRDD(Configuration configuration,
                                                    String memoryKey,
                                                    <any> memoryRDD)

Description copied from interface: OutputRDD

Write the sideEffect memoryRDD to an output location. The Configuration maintains the specified location via Constants.GREMLIN_HADOOP_OUTPUT_LOCATION. The default implementation returns an empty iterator.

Specified by:

writeMemoryRDD in interface OutputRDD

Type Parameters:

K - the key class of the RDD

V - the value class of the RDD

Parameters:

configuration - the configuration of the Spark job

memoryKey - the memory key of the memoryRDD

memoryRDD - the memoryRDD

Returns:

the KeyValue iterator to store in the final resultant Memory.