org.apache.beam.runners.jobsubmission

Class JobServerDriver

java.lang.Object

org.apache.beam.runners.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 interface	JobServerDriver.JobInvokerFactory
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, JobServerDriver.JobInvokerFactory jobInvokerFactory)

Method Summary

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

Method Detail

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)

getJobServerUrl

public java.lang.String getJobServerUrl()

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)