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

Class PipelineTranslatorFactory

java.lang.Object

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

@Internal
public final class PipelineTranslatorFactory
extends Object

Factory to create the PipelineTranslator matching the execution mode of the pipeline.

This shared base version only supports batch mode. The Spark 4 module shadows this file to additionally dispatch to a streaming translator.

Method Summary

Modifier and Type	Method	Description
static PipelineTranslator	create(boolean streaming)	Creates a PipelineTranslator for the given execution mode.

Methods inherited from class java.lang.Object

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

Method Details

create

public static PipelineTranslator create(boolean streaming)

Creates a PipelineTranslator for the given execution mode.