Package org.apache.beam.runners.jobsubmission

Class JobServerDriver

java.lang.Object

org.apache.beam.runners.jobsubmission.JobServerDriver

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

FlinkJobServerDriver, SparkJobServerDriver

public abstract class JobServerDriver
extends Object
implements Runnable

Shared code for starting and serving an InMemoryJobService.

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
JobServerDriver.ServerConfiguration	configuration

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected static ServerFactory	createArtifactServerFactory(JobServerDriver.ServerConfiguration configuration)
protected static ServerFactory	createJobServerFactory(JobServerDriver.ServerConfiguration configuration)
protected InMemoryJobService	createJobService()
protected String	createSessionToken(String session)
String	getJobServerUrl()
void	run()
String	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

configuration

public JobServerDriver.ServerConfiguration configuration

Constructor Details

JobServerDriver

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

Method Details

createJobService

protected InMemoryJobService createJobService()
                                       throws IOException

Throws:

IOException

createJobServerFactory

protected static ServerFactory createJobServerFactory(JobServerDriver.ServerConfiguration configuration)

createArtifactServerFactory

protected static ServerFactory createArtifactServerFactory(JobServerDriver.ServerConfiguration configuration)

getJobServerUrl

public String getJobServerUrl()

start

public String start()
             throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()

createSessionToken

protected String createSessionToken(String session)