Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

null check

Browse source
This commit is contained in:
Lee moon soo 2016-04-14 06:03:35 +01:00
parent 03be3a1205
commit c30f53c7bb
1 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Note.java
View file

@ -537,7 +537,9 @@ public class Note implements Serializable, ParagraphJobListener {
public void beforeStatusChange(Job job, Status before, Status after) {
if (jobListenerFactory != null) {
ParagraphJobListener listener = jobListenerFactory.getParagraphJobListener(this);
listener.beforeStatusChange(job, before, after);
if (listener != null) {
listener.beforeStatusChange(job, before, after);
}
}
}
@ -545,7 +547,9 @@ public class Note implements Serializable, ParagraphJobListener {
public void afterStatusChange(Job job, Status before, Status after) {
if (jobListenerFactory != null) {
ParagraphJobListener listener = jobListenerFactory.getParagraphJobListener(this);
listener.afterStatusChange(job, before, after);
if (listener != null) {
listener.afterStatusChange(job, before, after);
}
}
if (noteEventListener != null) {
@ -557,7 +561,9 @@ public class Note implements Serializable, ParagraphJobListener {
public void onProgressUpdate(Job job, int progress) {
if (jobListenerFactory != null) {
ParagraphJobListener listener = jobListenerFactory.getParagraphJobListener(this);
listener.onProgressUpdate(job, progress);
if (listener != null) {
listener.onProgressUpdate(job, progress);
}
}
}
@ -566,7 +572,9 @@ public class Note implements Serializable, ParagraphJobListener {
public void onOutputAppend(Paragraph paragraph, InterpreterOutput out, String output) {
if (jobListenerFactory != null) {
ParagraphJobListener listener = jobListenerFactory.getParagraphJobListener(this);
listener.onOutputAppend(paragraph, out, output);
if (listener != null) {
listener.onOutputAppend(paragraph, out, output);
}
}
}
@ -574,7 +582,9 @@ public class Note implements Serializable, ParagraphJobListener {
public void onOutputUpdate(Paragraph paragraph, InterpreterOutput out, String output) {
if (jobListenerFactory != null) {
ParagraphJobListener listener = jobListenerFactory.getParagraphJobListener(this);
listener.onOutputUpdate(paragraph, out, output);
if (listener != null) {
listener.onOutputUpdate(paragraph, out, output);
}
}
}