org.apache.beam.runners.spark.structuredstreaming.translation

Interface TransformTranslator<TransformT extends PTransform>

All Superinterfaces:

java.io.Serializable

public interface TransformTranslator<TransformT extends PTransform>
extends java.io.Serializable

Supports translation between a Beam transform, and Spark's operations on Datasets.

Method Summary

Modifier and Type	Method and Description
void	translateTransform(TransformT transform, TranslationContext context) Base class for translators of PTransform.

Method Detail

translateTransform

void translateTransform(TransformT transform,
                        TranslationContext context)

Base class for translators of PTransform.