Package org.apache.beam.runners.flink
Class FlinkRunnerRegistrar
java.lang.Object
org.apache.beam.runners.flink.FlinkRunnerRegistrar
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 ClassesModifier and TypeClassDescriptionstatic class
Pipeline options registrar.static class
Pipeline runner registrar. -
Method Summary