org.apache.tinkerpop.gremlin.spark.process.computer.traversal.strategy.optimization.interceptor

Class SparkStarBarrierInterceptor

java.lang.Object

org.apache.tinkerpop.gremlin.spark.process.computer.traversal.strategy.optimization.interceptor.SparkStarBarrierInterceptor

All Implemented Interfaces:

VertexProgramInterceptor<TraversalVertexProgram,<any>,SparkMemory>, SparkVertexProgramInterceptor<TraversalVertexProgram>

public final class SparkStarBarrierInterceptor
extends Object
implements SparkVertexProgramInterceptor<TraversalVertexProgram>

Author:

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

Constructor Summary

Constructors

Constructor and Description
SparkStarBarrierInterceptor()

Method Summary

Modifier and Type	Method and Description
<any>	apply(TraversalVertexProgram vertexProgram, <any> inputRDD, SparkMemory memory)
static boolean	isLegal(Traversal.Admin<?,?> traversal)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkStarBarrierInterceptor

public SparkStarBarrierInterceptor()

Method Detail

apply

public <any> apply(TraversalVertexProgram vertexProgram,
                   <any> inputRDD,
                   SparkMemory memory)

Specified by:

apply in interface VertexProgramInterceptor<TraversalVertexProgram,<any>,SparkMemory>

isLegal

public static boolean isLegal(Traversal.Admin<?,?> traversal)