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

Class RemoteSparkJobRef

java.lang.Object

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

All Implemented Interfaces:

SparkJobRef

public class RemoteSparkJobRef
extends Object
implements SparkJobRef

Constructor Summary

Constructors

Constructor and Description
RemoteSparkJobRef(HiveConf hiveConf, JobHandle<Serializable> jobHandler, RemoteSparkJobStatus sparkJobStatus)

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

RemoteSparkJobRef

public RemoteSparkJobRef(HiveConf hiveConf,
                 JobHandle<Serializable> jobHandler,
                 RemoteSparkJobStatus sparkJobStatus)

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