Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec.spark.status.impl | |
org.apache.hive.spark.client |
Constructor and Description |
---|
RemoteSparkJobRef(HiveConf hiveConf,
JobHandle<Serializable> jobHandler,
RemoteSparkJobStatus sparkJobStatus) |
RemoteSparkJobStatus(SparkClient sparkClient,
JobHandle<Serializable> jobHandle,
long timeoutInSeconds) |
Modifier and Type | Method and Description |
---|---|
<T extends Serializable> |
SparkClient.submit(Job<T> job)
Submits a job for asynchronous execution.
|
Modifier and Type | Method and Description |
---|---|
void |
JobHandle.Listener.onJobCancelled(JobHandle<T> job) |
void |
JobHandle.Listener.onJobFailed(JobHandle<T> job,
Throwable cause) |
void |
JobHandle.Listener.onJobQueued(JobHandle<T> job) |
void |
JobHandle.Listener.onJobStarted(JobHandle<T> job) |
void |
JobHandle.Listener.onJobSucceeded(JobHandle<T> job,
T result) |
void |
JobHandle.Listener.onSparkJobStarted(JobHandle<T> job,
int sparkJobId)
Called when a monitored Spark job is started on the remote context.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.