public class LocalSparkJobRef extends Object implements SparkJobRef
Constructor and Description |
---|
LocalSparkJobRef(String jobId,
HiveConf hiveConf,
LocalSparkJobStatus sparkJobStatus,
org.apache.spark.api.java.JavaSparkContext javaSparkContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancelJob() |
String |
getJobId() |
SparkJobStatus |
getSparkJobStatus() |
int |
monitorJob() |
public LocalSparkJobRef(String jobId, HiveConf hiveConf, LocalSparkJobStatus sparkJobStatus, org.apache.spark.api.java.JavaSparkContext javaSparkContext)
public String getJobId()
getJobId
in interface SparkJobRef
public SparkJobStatus getSparkJobStatus()
getSparkJobStatus
in interface SparkJobRef
public boolean cancelJob()
cancelJob
in interface SparkJobRef
public int monitorJob()
monitorJob
in interface SparkJobRef
Copyright © 2016 The Apache Software Foundation. All rights reserved.