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 java.lang.Object implements EngineTaskConfigProvider
-
-
Constructor Summary
Constructors Constructor Description SparkEngineTaskConfigProvider(java.util.Properties jobProps)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
getJobName()
java.util.Properties
getJobProps()
int
getTaskId()
-
-
-
Method Detail
-
getJobName
public java.lang.String getJobName()
- Specified by:
getJobName
in interfaceEngineTaskConfigProvider
- 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 interfaceEngineTaskConfigProvider
- Returns:
- The ID of the current task. This ID number is 0-based.
-
getJobProps
public java.util.Properties getJobProps()
- Specified by:
getJobProps
in interfaceEngineTaskConfigProvider
- Returns:
- The properties of the compute job.
-
-