org.apache.beam.runners.twister2

Class Twister2BatchPortablePipelineTranslator

java.lang.Object

org.apache.beam.runners.twister2.Twister2BatchPortablePipelineTranslator

All Implemented Interfaces:

Twister2PortablePipelineTranslator

public class Twister2BatchPortablePipelineTranslator
extends java.lang.Object
implements Twister2PortablePipelineTranslator

Twister2BatchPortablePipelineTranslator.

Constructor Summary

Constructors

Constructor and Description
Twister2BatchPortablePipelineTranslator()

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.lang.String>	knownUrns()
void	translate(RunnerApi.Pipeline pipeline)

Methods inherited from class java.lang.Object

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

Constructor Detail

Twister2BatchPortablePipelineTranslator

public Twister2BatchPortablePipelineTranslator()

Method Detail

knownUrns

public java.util.Set<java.lang.String> knownUrns()

Specified by:

knownUrns in interface Twister2PortablePipelineTranslator

translate

public void translate(RunnerApi.Pipeline pipeline)

Specified by:

translate in interface Twister2PortablePipelineTranslator