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

Class ImpulseTranslatorBatch

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, TransformTranslator<PTransform<PBegin,PCollection<byte[]>>>

public class ImpulseTranslatorBatch
extends java.lang.Object
implements TransformTranslator<PTransform<PBegin,PCollection<byte[]>>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ImpulseTranslatorBatch()

Method Summary

Modifier and Type	Method and Description
void	translateTransform(PTransform<PBegin,PCollection<byte[]>> transform, AbstractTranslationContext context) Base class for translators of PTransform.

Methods inherited from class java.lang.Object

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

Constructor Detail

ImpulseTranslatorBatch

public ImpulseTranslatorBatch()

Method Detail

translateTransform

public void translateTransform(PTransform<PBegin,PCollection<byte[]>> transform,
                               AbstractTranslationContext context)

Description copied from interface: TransformTranslator

Base class for translators of PTransform.

Specified by:

translateTransform in interface TransformTranslator<PTransform<PBegin,PCollection<byte[]>>>