public final class SparkExecutor extends Object
Modifier and Type | Method and Description |
---|---|
static <K,V,OK,OV> |
executeCombine(<any> mapRDD,
Configuration apacheConfiguration) |
static <K,V> <any> |
executeMap(<any> graphRDD,
MapReduce<K,V,?,?,?> mapReduce,
Configuration apacheConfiguration) |
static <K,V,OK,OV> |
executeReduce(<any> mapOrCombineRDD,
MapReduce<K,V,OK,OV,?> mapReduce,
Configuration apacheConfiguration) |
static <M> <any> |
executeVertexProgramIteration(<any> graphRDD,
<any> viewIncomingRDD,
SparkMemory memory,
Configuration apacheConfiguration) |
static <M> <any> |
prepareFinalGraphRDD(<any> graphRDD,
<any> viewIncomingRDD,
String[] elementComputeKeys) |
public static <M> <any> executeVertexProgramIteration(<any> graphRDD, <any> viewIncomingRDD, SparkMemory memory, Configuration apacheConfiguration)
public static <M> <any> prepareFinalGraphRDD(<any> graphRDD, <any> viewIncomingRDD, String[] elementComputeKeys)
public static <K,V> <any> executeMap(<any> graphRDD, MapReduce<K,V,?,?,?> mapReduce, Configuration apacheConfiguration)
public static <K,V,OK,OV> <any> executeCombine(<any> mapRDD, Configuration apacheConfiguration)
public static <K,V,OK,OV> <any> executeReduce(<any> mapOrCombineRDD, MapReduce<K,V,OK,OV,?> mapReduce, Configuration apacheConfiguration)
Copyright © 2013–2016 Apache Software Foundation. All rights reserved.