org.apache.beam.runners.spark

Class SparkJobServerDriver

java.lang.Object

org.apache.beam.runners.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.jobsubmission.JobServerDriver

JobServerDriver.JobInvokerFactory, JobServerDriver.ServerConfiguration

Field Summary

Fields inherited from class org.apache.beam.runners.jobsubmission.JobServerDriver

configuration

Method Summary

Modifier and Type	Method and Description
static SparkJobServerDriver	fromConfig(SparkJobServerDriver.SparkServerConfiguration configuration)
static SparkJobServerDriver	fromParams(java.lang.String[] args)
static void	main(java.lang.String[] args)

Methods inherited from class org.apache.beam.runners.jobsubmission.JobServerDriver

createArtifactServerFactory, createJobServerFactory, createJobService, createSessionToken, getJobServerUrl, run, start, 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)

fromParams

public static SparkJobServerDriver fromParams(java.lang.String[] args)

fromConfig

public static SparkJobServerDriver fromConfig(SparkJobServerDriver.SparkServerConfiguration configuration)