org.apache.beam.runners.flink

Class FlinkRunnerRegistrar.Runner

java.lang.Object

org.apache.beam.runners.flink.FlinkRunnerRegistrar.Runner

All Implemented Interfaces:

org.apache.beam.sdk.runners.PipelineRunnerRegistrar

Enclosing class:

FlinkRunnerRegistrar

@AutoService(value=org.apache.beam.sdk.runners.PipelineRunnerRegistrar.class)
public static class FlinkRunnerRegistrar.Runner
extends java.lang.Object
implements org.apache.beam.sdk.runners.PipelineRunnerRegistrar

Pipeline runner registrar.

Constructor Summary

Constructors

Constructor and Description
Runner()

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<java.lang.Class<? extends PipelineRunner<?>>>	getPipelineRunners() Get the set of PipelineRunners to register.

Methods inherited from class java.lang.Object

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

Constructor Detail

Runner

public Runner()

Method Detail

getPipelineRunners

public java.lang.Iterable<java.lang.Class<? extends PipelineRunner<?>>> getPipelineRunners()

Description copied from interface: org.apache.beam.sdk.runners.PipelineRunnerRegistrar

Get the set of PipelineRunners to register.

Specified by:

getPipelineRunners in interface org.apache.beam.sdk.runners.PipelineRunnerRegistrar