Package com.linkedin.venice.spark.engine

Class SparkEngineTaskConfigProvider

java.lang.Object

com.linkedin.venice.spark.engine.SparkEngineTaskConfigProvider

All Implemented Interfaces:

EngineTaskConfigProvider

public class SparkEngineTaskConfigProvider
extends Object
implements EngineTaskConfigProvider

Constructor Summary

Constructors

Constructor	Description
SparkEngineTaskConfigProvider(Properties jobProps)

Method Summary

Modifier and Type	Method	Description
String	getJobName()
Properties	getJobProps()
int	getTaskId()

Methods inherited from class java.lang.Object

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

Constructor Details

SparkEngineTaskConfigProvider

public SparkEngineTaskConfigProvider(Properties jobProps)

Method Details

getJobName

public String getJobName()

Specified by:

getJobName in interface EngineTaskConfigProvider

Returns:

The name of the compute job. This must be the same for all tasks of the same job.

getTaskId

public int getTaskId()

Specified by:

getTaskId in interface EngineTaskConfigProvider

Returns:

The ID of the current task. This ID number is 0-based.

getJobProps

public Properties getJobProps()

Specified by:

getJobProps in interface EngineTaskConfigProvider

Returns:

The properties of the compute job.