ZeppelinHubRepo implements NotebookRepo { @Override public Note get(String noteId, AuthenticationInfo subject) throws IOException { if (StringUtils.isBlank(noteId)) { return EMPTY_NOTE; } String response = restApiClient.asyncGet(noteId); Note note = GSON.fromJson(response, Note.class); if (note == null) { return EMPTY_NOTE; } LOG.info("ZeppelinHub REST API get note {} ", noteId); return note; } ZeppelinHubRepo(ZeppelinConfiguration conf); @Override List<NoteInfo> list(AuthenticationInfo subject); @Override Note get(String noteId, AuthenticationInfo subject); @Override void save(Note note, AuthenticationInfo subject); @Override void remove(String noteId, AuthenticationInfo subject); @Override void close(); @Override Revision checkpoint(String noteId, String checkpointMsg, AuthenticationInfo subject); @Override Note get(String noteId, Revision rev, AuthenticationInfo subject); @Override List<Revision> revisionHistory(String noteId, AuthenticationInfo subject); static final String TOKEN_HEADER; }
@Test public void testGetNote() throws IOException { Note notebook = repo.get("AAAAA", null); assertThat(notebook).isNotNull(); assertThat(notebook.id()).isEqualTo("2A94M5J1Z"); }