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

Interface TransformTranslator<TransformT extends PTransform>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

ImpulseTranslatorBatch

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, AbstractTranslationContext context) Base class for translators of PTransform.

Method Detail

translateTransform

void translateTransform(TransformT transform,
                        AbstractTranslationContext context)

Base class for translators of PTransform.