Package org.apache.beam.runners.spark.translation

Interface TransformEvaluator<TransformT extends org.apache.beam.sdk.transforms.PTransform<?,?>>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

StatefulStreamingParDoEvaluator

public interface TransformEvaluator<TransformT extends org.apache.beam.sdk.transforms.PTransform<?,?>>
extends java.io.Serializable

Describe a PTransform evaluator.

Method Summary

Modifier and Type	Method	Description
void	evaluate(TransformT transform, EvaluationContext context)
java.lang.String	toNativeString()

Method Detail

evaluate

void evaluate(TransformT transform,
              EvaluationContext context)

toNativeString

java.lang.String toNativeString()