org.apache.beam.runners.flink

Class FlinkJobServerDriver

java.lang.Object

org.apache.beam.runners.fnexecution.jobsubmission.JobServerDriver

org.apache.beam.runners.flink.FlinkJobServerDriver

All Implemented Interfaces:

java.lang.Runnable

public class FlinkJobServerDriver
extends JobServerDriver

Driver program that starts a job server for the Flink runner.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkJobServerDriver.FlinkServerConfiguration Flink runner-specific Configuration for the jobServer.

Nested classes/interfaces inherited from class org.apache.beam.runners.fnexecution.jobsubmission.JobServerDriver

JobServerDriver.ServerConfiguration

Field Summary

Fields inherited from class org.apache.beam.runners.fnexecution.jobsubmission.JobServerDriver

configuration

Method Summary

Modifier and Type	Method and Description
static FlinkJobServerDriver	create(FlinkJobServerDriver.FlinkServerConfiguration configuration, ServerFactory jobServerFactory, ServerFactory artifactServerFactory)
protected JobInvoker	createJobInvoker()
static FlinkJobServerDriver	fromConfig(FlinkJobServerDriver.FlinkServerConfiguration configuration)
static FlinkJobServerDriver	fromParams(java.lang.String[] args)
static void	main(java.lang.String[] args)

Methods inherited from class org.apache.beam.runners.fnexecution.jobsubmission.JobServerDriver

createArtifactServerFactory, createJobServerFactory, createJobService, createSessionToken, run, start, stop

Methods inherited from class java.lang.Object

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

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

fromParams

public static FlinkJobServerDriver fromParams(java.lang.String[] args)

fromConfig

public static FlinkJobServerDriver fromConfig(FlinkJobServerDriver.FlinkServerConfiguration configuration)

create

public static FlinkJobServerDriver create(FlinkJobServerDriver.FlinkServerConfiguration configuration,
                                          ServerFactory jobServerFactory,
                                          ServerFactory artifactServerFactory)

createJobInvoker

protected JobInvoker createJobInvoker()

Specified by:

createJobInvoker in class JobServerDriver