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

Class ImpulseTranslatorBatch

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.TransformTranslator<PBegin,PCollection<byte[]>,Impulse>

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

public class ImpulseTranslatorBatch
extends TransformTranslator<PBegin,PCollection<byte[]>,Impulse>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.runners.spark.structuredstreaming.translation.TransformTranslator

TransformTranslator.Context

Constructor Summary

Constructors

Constructor and Description
ImpulseTranslatorBatch()

Method Summary

Modifier and Type	Method and Description
void	translate(Impulse transform, TransformTranslator.Context cxt)

Methods inherited from class org.apache.beam.runners.spark.structuredstreaming.translation.TransformTranslator

translate, windowCoder

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

translate

public void translate(Impulse transform,
                      TransformTranslator.Context cxt)

Specified by:

translate in class TransformTranslator<PBegin,PCollection<byte[]>,Impulse>