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

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

All Superinterfaces:

Serializable

All Known Implementing Classes:

StatefulStreamingParDoEvaluator

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

Describe a PTransform evaluator.

Method Summary

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

Method Details

evaluate

void evaluate(TransformT transform,
 EvaluationContext context)

toNativeString

String toNativeString()