org.apache.beam.runners.flink

Class FlinkRunnerRegistrar

java.lang.Object

org.apache.beam.runners.flink.FlinkRunnerRegistrar

public class FlinkRunnerRegistrar
extends java.lang.Object

AutoService registrar - will register FlinkRunner and FlinkOptions as possible pipeline runner services.

It ends up in META-INF/services and gets picked up by Beam.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkRunnerRegistrar.Options Pipeline options registrar.
static class	FlinkRunnerRegistrar.Runner Pipeline runner registrar.

Method Summary

Methods inherited from class java.lang.Object

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