A B C G H J L O R S U V

A

addFile(URI) - Method in interface org.apache.livy.LivyClient

Adds a file to the running remote context.

addJar(URI) - Method in interface org.apache.livy.LivyClient

Adds a jar file to the running remote context.

addListener(JobHandle.Listener<T>) - Method in interface org.apache.livy.JobHandle

Add a listener to the job handle.

B

build() - Method in class org.apache.livy.LivyClientBuilder

C

call(JobContext) - Method in interface org.apache.livy.Job

createClient(URI, Properties) - Method in interface org.apache.livy.LivyClientFactory

Instantiates a new client if the given URI is supported by the implementation.

createStreamingContext(long) - Method in interface org.apache.livy.JobContext

Creates the SparkStreaming context.

G

getLocalTmpDir() - Method in interface org.apache.livy.JobContext

getSharedObject(String) - Method in interface org.apache.livy.JobContext

Get shared object

getState() - Method in interface org.apache.livy.JobHandle

Return the current state of the job.

H

hivectx() - Method in interface org.apache.livy.JobContext

J

Job<T> - Interface in org.apache.livy

Interface for a Spark remote job.

JobContext - Interface in org.apache.livy

Holds runtime information about the job execution context.

JobHandle<T> - Interface in org.apache.livy

A handle to a submitted job.

JobHandle.Listener<T> - Interface in org.apache.livy

A listener for monitoring the state of the job in the remote context.

JobHandle.State - Enum in org.apache.livy

The current state of the submitted job.

L

LIVY_URI_KEY - Static variable in class org.apache.livy.LivyClientBuilder

LivyClient - Interface in org.apache.livy

A client for submitting Spark-based jobs to a Livy backend.

LivyClientBuilder - Class in org.apache.livy

A builder for Livy clients.

LivyClientBuilder() - Constructor for class org.apache.livy.LivyClientBuilder

Creates a new builder that will automatically load the default Livy and Spark configuration from the classpath.

LivyClientBuilder(boolean) - Constructor for class org.apache.livy.LivyClientBuilder

Creates a new builder that will optionally load the default Livy and Spark configuration from the classpath.

LivyClientFactory - Interface in org.apache.livy

A factory for Livy clients.

O

onJobCancelled(JobHandle<T>) - Method in interface org.apache.livy.JobHandle.Listener

onJobFailed(JobHandle<T>, Throwable) - Method in interface org.apache.livy.JobHandle.Listener

onJobQueued(JobHandle<T>) - Method in interface org.apache.livy.JobHandle.Listener

Notifies when a job has been queued for execution on the remote context.

onJobStarted(JobHandle<T>) - Method in interface org.apache.livy.JobHandle.Listener

onJobSucceeded(JobHandle<T>, T) - Method in interface org.apache.livy.JobHandle.Listener

org.apache.livy - package org.apache.livy

Livy programmatic Java API

R

removeSharedObject(String) - Method in interface org.apache.livy.JobContext

Remove shared object from cache

run(Job<T>) - Method in interface org.apache.livy.LivyClient

Asks the remote context to run a job immediately.

S

sc() - Method in interface org.apache.livy.JobContext

setAll(Map<String, String>) - Method in class org.apache.livy.LivyClientBuilder

setAll(Properties) - Method in class org.apache.livy.LivyClientBuilder

setConf(String, String) - Method in class org.apache.livy.LivyClientBuilder

setSharedObject(String, E) - Method in interface org.apache.livy.JobContext

Set shared object, it will replace the old one if already existed

setURI(URI) - Method in class org.apache.livy.LivyClientBuilder

sparkSession() - Method in interface org.apache.livy.JobContext

sqlctx() - Method in interface org.apache.livy.JobContext

stop(boolean) - Method in interface org.apache.livy.LivyClient

Stops the remote context.

stopStreamingCtx() - Method in interface org.apache.livy.JobContext

Stops the SparkStreaming context.

streamingctx() - Method in interface org.apache.livy.JobContext

submit(Job<T>) - Method in interface org.apache.livy.LivyClient

Submits a job for asynchronous execution.

U

uploadFile(File) - Method in interface org.apache.livy.LivyClient

Upload a file to be passed to the Spark application

uploadJar(File) - Method in interface org.apache.livy.LivyClient

Upload a jar to be added to the Spark application classpath

V

valueOf(String) - Static method in enum org.apache.livy.JobHandle.State

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.livy.JobHandle.State

Returns an array containing the constants of this enum type, in the order they are declared.

A B C G H J L O R S U V