org.apache.hadoop.hive.ql.exec.spark.status.impl

Class LocalSparkJobRef

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.status.impl.LocalSparkJobRef

All Implemented Interfaces:

SparkJobRef

public class LocalSparkJobRef
extends Object
implements SparkJobRef

Constructor Summary

Constructors

Constructor and Description
LocalSparkJobRef(String jobId, HiveConf hiveConf, LocalSparkJobStatus sparkJobStatus, org.apache.spark.api.java.JavaSparkContext javaSparkContext)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancelJob()
String	getJobId()
SparkJobStatus	getSparkJobStatus()
int	monitorJob()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalSparkJobRef

public LocalSparkJobRef(String jobId,
                HiveConf hiveConf,
                LocalSparkJobStatus sparkJobStatus,
                org.apache.spark.api.java.JavaSparkContext javaSparkContext)

Method Detail

getJobId

public String getJobId()

Specified by:

getJobId in interface SparkJobRef

getSparkJobStatus

public SparkJobStatus getSparkJobStatus()

Specified by:

getSparkJobStatus in interface SparkJobRef

cancelJob

public boolean cancelJob()

Specified by:

cancelJob in interface SparkJobRef

monitorJob

public int monitorJob()

Specified by:

monitorJob in interface SparkJobRef