public class SnappyDataZeppelinInterpreter
extends org.apache.zeppelin.interpreter.Interpreter
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
FS_S3A_ACCESS_KEY |
static java.lang.String |
FS_S3A_IMPL |
static java.lang.String |
FS_S3A_SECRET_KEY |
static org.slf4j.Logger |
logger |
| Constructor and Description |
|---|
SnappyDataZeppelinInterpreter(java.util.Properties property) |
SnappyDataZeppelinInterpreter(java.util.Properties property,
org.apache.spark.SparkContext sc) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancel(org.apache.zeppelin.interpreter.InterpreterContext context) |
static void |
cancelAllJobsAndPause() |
void |
close() |
java.util.List<org.apache.zeppelin.interpreter.thrift.InterpreterCompletion> |
completion(java.lang.String buf,
int cursor) |
org.apache.spark.SparkContext |
createSparkContext() |
org.apache.spark.sql.SparkSession |
createSparkSession()
Spark 2.x
Create SparkSession
|
org.apache.zeppelin.spark.dep.SparkDependencyResolver |
getDependencyResolver() |
org.apache.zeppelin.interpreter.Interpreter.FormType |
getFormType() |
org.apache.spark.ui.jobs.JobProgressListener |
getJobProgressListener() |
java.lang.Object |
getLastObject() |
int |
getProgress(org.apache.zeppelin.interpreter.InterpreterContext context) |
org.apache.zeppelin.scheduler.Scheduler |
getScheduler() |
org.apache.spark.sql.SnappyContext |
getSnappyContext() |
org.apache.spark.SparkContext |
getSparkContext() |
org.apache.spark.sql.SparkSession |
getSparkSession() |
org.apache.zeppelin.spark.ZeppelinContext |
getZeppelinContext() |
org.apache.zeppelin.interpreter.InterpreterResult |
interpret(java.lang.String[] lines,
org.apache.zeppelin.interpreter.InterpreterContext context) |
org.apache.zeppelin.interpreter.InterpreterResult |
interpret(java.lang.String line,
org.apache.zeppelin.interpreter.InterpreterContext context)
Interpret a single line.
|
org.apache.zeppelin.interpreter.InterpreterResult |
interpretInput(java.lang.String[] lines,
org.apache.zeppelin.interpreter.InterpreterContext context) |
boolean |
isSparkContextInitialized() |
void |
open() |
destroy, findRegisteredInterpreterByClassName, getClassloaderUrls, getClassName, getInterpreterGroup, getInterpreterInTheSameSessionByClassName, getProperty, getProperty, register, register, register, register, setClassloaderUrls, setInterpreterGroup, setPropertypublic static final java.lang.String FS_S3A_IMPL
public static org.slf4j.Logger logger
public static final java.lang.String FS_S3A_ACCESS_KEY
public static final java.lang.String FS_S3A_SECRET_KEY
public SnappyDataZeppelinInterpreter(java.util.Properties property)
public SnappyDataZeppelinInterpreter(java.util.Properties property,
org.apache.spark.SparkContext sc)
public org.apache.spark.SparkContext getSparkContext()
public boolean isSparkContextInitialized()
public org.apache.spark.sql.SparkSession getSparkSession()
public org.apache.spark.sql.SnappyContext getSnappyContext()
public org.apache.zeppelin.spark.dep.SparkDependencyResolver getDependencyResolver()
public org.apache.spark.sql.SparkSession createSparkSession()
public org.apache.spark.SparkContext createSparkContext()
public void open()
open in class org.apache.zeppelin.interpreter.Interpreterpublic java.util.List<org.apache.zeppelin.interpreter.thrift.InterpreterCompletion> completion(java.lang.String buf,
int cursor)
completion in class org.apache.zeppelin.interpreter.Interpreterpublic java.lang.Object getLastObject()
public org.apache.zeppelin.interpreter.InterpreterResult interpret(java.lang.String line,
org.apache.zeppelin.interpreter.InterpreterContext context)
interpret in class org.apache.zeppelin.interpreter.Interpreterpublic org.apache.zeppelin.interpreter.InterpreterResult interpret(java.lang.String[] lines,
org.apache.zeppelin.interpreter.InterpreterContext context)
public org.apache.zeppelin.interpreter.InterpreterResult interpretInput(java.lang.String[] lines,
org.apache.zeppelin.interpreter.InterpreterContext context)
public void cancel(org.apache.zeppelin.interpreter.InterpreterContext context)
cancel in class org.apache.zeppelin.interpreter.Interpreterpublic int getProgress(org.apache.zeppelin.interpreter.InterpreterContext context)
getProgress in class org.apache.zeppelin.interpreter.Interpreterpublic void close()
close in class org.apache.zeppelin.interpreter.Interpreterpublic org.apache.zeppelin.interpreter.Interpreter.FormType getFormType()
getFormType in class org.apache.zeppelin.interpreter.Interpreterpublic org.apache.spark.ui.jobs.JobProgressListener getJobProgressListener()
public org.apache.zeppelin.scheduler.Scheduler getScheduler()
getScheduler in class org.apache.zeppelin.interpreter.Interpreterpublic org.apache.zeppelin.spark.ZeppelinContext getZeppelinContext()
public static void cancelAllJobsAndPause()