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

Search: nuke compiler warnings in NotebookRestApi

Browse source
This commit is contained in:
Alexander Bezzubov 2015-12-11 15:12:29 +09:00
parent aa5ddb3f8f
commit 6ccd6f11d4
1 changed files with 19 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
zeppelin-server/src/main/java/org/apache/zeppelin/rest/NotebookRestApi.java
View file

@ -210,11 +210,11 @@ public class NotebookRestApi {
LOG.info("run notebook jobs {} ", notebookId);
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
note.runAll();
return new JsonResponse(Status.OK).build();
return new JsonResponse<>(Status.OK).build();
}
/**
@ -230,7 +230,7 @@ public class NotebookRestApi {
LOG.info("stop notebook jobs {} ", notebookId);
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
for (Paragraph p : note.getParagraphs()) {
@ -238,7 +238,7 @@ public class NotebookRestApi {
p.abort();
}
}
return new JsonResponse(Status.OK).build();
return new JsonResponse<>(Status.OK).build();
}
/**
@ -254,10 +254,10 @@ public class NotebookRestApi {
LOG.info("get notebook job status.");
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
return new JsonResponse(Status.OK, null, note.generateParagraphsInfo()).build();
return new JsonResponse<>(Status.OK, null, note.generateParagraphsInfo()).build();
}
/**
@ -274,15 +274,15 @@ public class NotebookRestApi {
LOG.info("run paragraph job {} {} ", notebookId, paragraphId);
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
if (note.getParagraph(paragraphId) == null) {
return new JsonResponse(Status.NOT_FOUND, "paragraph not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "paragraph not found.").build();
}
note.run(paragraphId);
return new JsonResponse(Status.OK).build();
return new JsonResponse<>(Status.OK).build();
}
/**
@ -299,15 +299,15 @@ public class NotebookRestApi {
LOG.info("stop paragraph job {} ", notebookId);
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
Paragraph p = note.getParagraph(paragraphId);
if (p == null) {
return new JsonResponse(Status.NOT_FOUND, "paragraph not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "paragraph not found.").build();
}
p.abort();
return new JsonResponse(Status.OK).build();
return new JsonResponse<>(Status.OK).build();
}
/**
@ -327,11 +327,11 @@ public class NotebookRestApi {
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
if (!CronExpression.isValidExpression(request.getCronString())) {
return new JsonResponse(Status.BAD_REQUEST, "wrong cron expressions.").build();
return new JsonResponse<>(Status.BAD_REQUEST, "wrong cron expressions.").build();
}
Map<String, Object> config = note.getConfig();
@ -339,7 +339,7 @@ public class NotebookRestApi {
note.setConfig(config);
notebook.refreshCron(note.id());
return new JsonResponse(Status.OK).build();
return new JsonResponse<>(Status.OK).build();
}
/**
@ -356,7 +356,7 @@ public class NotebookRestApi {
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
Map<String, Object> config = note.getConfig();
@ -364,7 +364,7 @@ public class NotebookRestApi {
note.setConfig(config);
notebook.refreshCron(note.id());
return new JsonResponse(Status.OK).build();
return new JsonResponse<>(Status.OK).build();
}
/**
@ -381,10 +381,10 @@ public class NotebookRestApi {
Note note = notebook.getNote(notebookId);
if (note == null) {
return new JsonResponse(Status.NOT_FOUND, "note not found.").build();
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
return new JsonResponse(Status.OK, note.getConfig().get("cron")).build();
return new JsonResponse<>(Status.OK, note.getConfig().get("cron")).build();
}
/**