org.apache.beam.runners.flink

Class FlinkJobServerDriver

java.lang.Object

org.apache.beam.runners.flink.FlinkJobServerDriver

All Implemented Interfaces:

java.lang.Runnable

public class FlinkJobServerDriver
extends java.lang.Object
implements java.lang.Runnable

Driver program that starts a job server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkJobServerDriver.ServerConfiguration Configuration for the jobServer.

Method Summary

Modifier and Type	Method and Description
static FlinkJobServerDriver	create(FlinkJobServerDriver.ServerConfiguration configuration, ListeningExecutorService executor, ServerFactory jobServerFactory, ServerFactory artifactServerFactory)
static FlinkJobServerDriver	fromConfig(FlinkJobServerDriver.ServerConfiguration configuration)
static FlinkJobServerDriver	fromParams(java.lang.String[] args)
static void	main(java.lang.String[] args)
void	run()
java.lang.String	start()
void	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.ServerConfiguration configuration)

create

public static FlinkJobServerDriver create(FlinkJobServerDriver.ServerConfiguration configuration,
                                          ListeningExecutorService executor,
                                          ServerFactory jobServerFactory,
                                          ServerFactory artifactServerFactory)

run

public void run()

Specified by:

run in interface java.lang.Runnable

start

public java.lang.String start()
                       throws java.io.IOException

Throws:

java.io.IOException

stop

public void stop()