org.apache.beam.runners.fnexecution.jobsubmission

Class JobServerDriver

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

FlinkJobServerDriver, SparkJobServerDriver

public abstract class JobServerDriver
extends java.lang.Object
implements java.lang.Runnable

Shared code for starting and serving an InMemoryJobService.

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
JobServerDriver.ServerConfiguration	configuration

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobServerDriver(JobServerDriver.ServerConfiguration configuration, ServerFactory jobServerFactory, ServerFactory artifactServerFactory)

Method Summary

Modifier and Type	Method and Description
protected static ServerFactory	createArtifactServerFactory(JobServerDriver.ServerConfiguration configuration)
protected abstract JobInvoker	createJobInvoker()
protected static ServerFactory	createJobServerFactory(JobServerDriver.ServerConfiguration configuration)
protected InMemoryJobService	createJobService()
protected java.lang.String	createSessionToken(java.lang.String session)
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

Field Detail

configuration

public JobServerDriver.ServerConfiguration configuration

Constructor Detail

JobServerDriver

protected JobServerDriver(JobServerDriver.ServerConfiguration configuration,
                          ServerFactory jobServerFactory,
                          ServerFactory artifactServerFactory)

Method Detail

createJobInvoker

protected abstract JobInvoker createJobInvoker()

createJobService

protected InMemoryJobService createJobService()
                                       throws java.io.IOException

Throws:

java.io.IOException

createJobServerFactory

protected static ServerFactory createJobServerFactory(JobServerDriver.ServerConfiguration configuration)

createArtifactServerFactory

protected static ServerFactory createArtifactServerFactory(JobServerDriver.ServerConfiguration configuration)

start

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

Throws:

java.io.IOException

run

public void run()

Specified by:

run in interface java.lang.Runnable

stop

public void stop()

createSessionToken

protected java.lang.String createSessionToken(java.lang.String session)