org.apache.beam.runners.spark

Class SparkJobServerDriver

java.lang.Object

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

org.apache.beam.runners.spark.SparkJobServerDriver

All Implemented Interfaces:

java.lang.Runnable

public class SparkJobServerDriver
extends JobServerDriver

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkJobServerDriver.SparkServerConfiguration Spark 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
protected JobInvoker	createJobInvoker()
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

createJobInvoker

protected JobInvoker createJobInvoker()

Specified by:

createJobInvoker in class JobServerDriver

main

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