org.apache.oozie.service

Class SparkConfigurationService

java.lang.Object

org.apache.oozie.service.SparkConfigurationService

All Implemented Interfaces:

Service

public class SparkConfigurationService
extends Object
implements Service

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_PREFIX
static String	SPARK_CONFIGURATIONS
static String	SPARK_CONFIGURATIONS_IGNORE_SPARK_YARN_JAR

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
SparkConfigurationService()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the service.
Class<? extends Service>	getInterface() Return the public interface of the service.
Map<String,String>	getSparkConfig(String resourceManagerHostPort)
void	init(Services services) Initialize the service.

Methods inherited from class java.lang.Object

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

Field Detail

CONF_PREFIX

public static final String CONF_PREFIX

See Also:

Constant Field Values

SPARK_CONFIGURATIONS

public static final String SPARK_CONFIGURATIONS

See Also:

Constant Field Values

SPARK_CONFIGURATIONS_IGNORE_SPARK_YARN_JAR

public static final String SPARK_CONFIGURATIONS_IGNORE_SPARK_YARN_JAR

See Also:

Constant Field Values

Constructor Detail

SparkConfigurationService

public SparkConfigurationService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Description copied from interface: Service

Initialize the service.

Invoked by the Service singleton at start up time.

Specified by:

init in interface Service

Parameters:

services - services singleton initializing the service.

Throws:

ServiceException - thrown if the service could not initialize.

destroy

public void destroy()

Description copied from interface: Service

Destroy the service.

Invoked by the Service singleton at shutdown time.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Description copied from interface: Service

Return the public interface of the service.

Services are retrieved by its public interface. Specializations of services must return the public interface.

Specified by:

getInterface in interface Service

Returns:

the interface of the service.

getSparkConfig

public Map<String,String> getSparkConfig(String resourceManagerHostPort)