static <M> org.apache.spark.api.java.JavaPairRDD<Object,org.apache.tinkerpop.gremlin.spark.process.computer.payload.ViewIncomingPayload<M>> |
GraknSparkExecutor.executeVertexProgramIteration(org.apache.spark.api.java.JavaPairRDD<Object,org.apache.tinkerpop.gremlin.hadoop.structure.io.VertexWritable> graphRDD,
org.apache.spark.api.java.JavaPairRDD<Object,org.apache.tinkerpop.gremlin.spark.process.computer.payload.ViewIncomingPayload<M>> viewIncomingRDD,
GraknSparkMemory memory,
org.apache.commons.configuration.Configuration apacheConfiguration) |