Skip navigation links
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 
Skip navigation links

Copyright © 2023 The Apache Software Foundation. All rights reserved.