test_class.declarator: LOG = LoggerFactory.getLogger(ZeppelinClientTest.class)
test_class.modifier: private
test_class.original_string: private Logger LOG = LoggerFactory.getLogger(ZeppelinClientTest.class);
test_class.type: Logger
test_class.var_name: LOG
test_class.declarator: zeppelinPort = 8090
test_class.modifier: private final
test_class.original_string: private final int zeppelinPort = 8090;
test_class.type: int
test_class.var_name: zeppelinPort
test_class.declarator: validWebsocketUrl = "ws://localhost:" + zeppelinPort + "/ws"
test_class.modifier: private final
test_class.original_string: private final String validWebsocketUrl = "ws://localhost:" + zeppelinPort + "/ws";
test_class.type: String
test_class.var_name: validWebsocketUrl
test_class.declarator: executor
test_class.modifier: private
test_class.original_string: private ExecutorService executor;
test_class.type: ExecutorService
test_class.var_name: executor
test_class.declarator: echoServer
test_class.modifier: private
test_class.original_string: private MockEchoWebsocketServer echoServer;
test_class.type: MockEchoWebsocketServer
test_class.var_name: echoServer
test_class.declarator: runNotebookMsg =
        "{\"op\":\"RUN_NOTEBOOK\"," +
        "\"data\":[{\"id\":\"20150112-172845_1301897143\",\"title\":null,\"config\":{},\"params\":{},\"data\":null}," +
        "{\"id\":\"20150112-172845_1301897143\",\"title\":null,\"config\":{},\"params\":{},\"data\":null}]," +
        "\"meta\":{\"owner\":\"author\",\"instance\":\"my-zepp\",\"noteId\":\"2AB7SY361\"}}"
test_class.modifier: private final
test_class.original_string: private final String runNotebookMsg =
        "{\"op\":\"RUN_NOTEBOOK\"," +
        "\"data\":[{\"id\":\"20150112-172845_1301897143\",\"title\":null,\"config\":{},\"params\":{},\"data\":null}," +
        "{\"id\":\"20150112-172845_1301897143\",\"title\":null,\"config\":{},\"params\":{},\"data\":null}]," +
        "\"meta\":{\"owner\":\"author\",\"instance\":\"my-zepp\",\"noteId\":\"2AB7SY361\"}}";
test_class.type: String
test_class.var_name: runNotebookMsg
test_class.declarator: invalidRunNotebookMsg = "some random string"
test_class.modifier: private final
test_class.original_string: private final String invalidRunNotebookMsg = "some random string";
test_class.type: String
test_class.var_name: invalidRunNotebookMsg
test_class.file: smart-zeppelin/zeppelin-zengine/src/test/java/org/apache/zeppelin/notebook/repo/zeppelinhub/websocket/ZeppelinhubClientTest.java
test_class.identifier: ZeppelinhubClientTest
test_case.body: @Test
    public void runAllParagraphTest() throws Exception {
      Client.initialize(validWebsocketUrl, validWebsocketUrl, "TOKEN", null);
      Client.getInstance().start();
      ZeppelinhubClient zeppelinhubClient = ZeppelinhubClient.getInstance();
      boolean runStatus = zeppelinhubClient.runAllParagraph("2AB7SY361", runNotebookMsg);
      assertTrue(runStatus);
      runStatus = zeppelinhubClient.runAllParagraph("2AB7SY361", invalidRunNotebookMsg);
      assertFalse(runStatus);
      Client.getInstance().stop();
    }
test_case.class_method_signature: ZeppelinhubClientTest.runAllParagraphTest()
test_case.full_signature: @Test public void runAllParagraphTest()
test_case.identifier: runAllParagraphTest
test_case.invocations: initialize start getInstance getInstance runAllParagraph assertTrue runAllParagraph assertFalse stop getInstance
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void runAllParagraphTest()
focal_class.declarator: LOG = LoggerFactory.getLogger(ZeppelinhubClient.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(ZeppelinhubClient.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: client
focal_class.modifier: private final
focal_class.original_string: private final WebSocketClient client;
focal_class.type: WebSocketClient
focal_class.var_name: client
focal_class.declarator: zeppelinhubWebsocketUrl
focal_class.modifier: private final
focal_class.original_string: private final URI zeppelinhubWebsocketUrl;
focal_class.type: URI
focal_class.var_name: zeppelinhubWebsocketUrl
focal_class.declarator: zeppelinhubToken
focal_class.modifier: private final
focal_class.original_string: private final String zeppelinhubToken;
focal_class.type: String
focal_class.var_name: zeppelinhubToken
focal_class.declarator: CONNECTION_IDLE_TIME = TimeUnit.SECONDS.toMillis(30)
focal_class.modifier: private static final
focal_class.original_string: private static final long CONNECTION_IDLE_TIME = TimeUnit.SECONDS.toMillis(30);
focal_class.type: long
focal_class.var_name: CONNECTION_IDLE_TIME
focal_class.declarator: instance = null
focal_class.modifier: private static
focal_class.original_string: private static ZeppelinhubClient instance = null;
focal_class.type: ZeppelinhubClient
focal_class.var_name: instance
focal_class.declarator: gson
focal_class.modifier: private static
focal_class.original_string: private static Gson gson;
focal_class.type: Gson
focal_class.var_name: gson
focal_class.declarator: schedulerService
focal_class.modifier: private
focal_class.original_string: private SchedulerService schedulerService;
focal_class.type: SchedulerService
focal_class.var_name: schedulerService
focal_class.declarator: sessionMap = 
        new ConcurrentHashMap<String, ZeppelinhubSession>()
focal_class.modifier: private
focal_class.original_string: private Map<String, ZeppelinhubSession> sessionMap = 
        new ConcurrentHashMap<String, ZeppelinhubSession>();
focal_class.type: Map<String, ZeppelinhubSession>
focal_class.var_name: sessionMap
focal_class.file: smart-zeppelin/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/repo/zeppelinhub/websocket/ZeppelinhubClient.java
focal_class.identifier: ZeppelinhubClient
focal_class.class_method_signature: ZeppelinhubClient.initialize(String zeppelinhubUrl, String token)
focal_class.full_signature: public static ZeppelinhubClient initialize(String zeppelinhubUrl, String token)
focal_class.identifier: initialize
focal_class.modifiers: public static
focal_class.parameters: (String zeppelinhubUrl, String token)
focal_class.return: ZeppelinhubClient
focal_class.signature: ZeppelinhubClient initialize(String zeppelinhubUrl, String token)
focal_class.class_method_signature: ZeppelinhubClient.getInstance()
focal_class.full_signature: public static ZeppelinhubClient getInstance()
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: ZeppelinhubClient
focal_class.signature: ZeppelinhubClient getInstance()
focal_class.class_method_signature: ZeppelinhubClient.ZeppelinhubClient(String url, String token)
focal_class.full_signature: private  ZeppelinhubClient(String url, String token)
focal_class.identifier: ZeppelinhubClient
focal_class.modifiers: private
focal_class.parameters: (String url, String token)
focal_class.signature:  ZeppelinhubClient(String url, String token)
focal_class.class_method_signature: ZeppelinhubClient.start()
focal_class.full_signature: public void start()
focal_class.identifier: start
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void start()
focal_class.class_method_signature: ZeppelinhubClient.initUser(String token)
focal_class.full_signature: public void initUser(String token)
focal_class.identifier: initUser
focal_class.modifiers: public
focal_class.parameters: (String token)
focal_class.return: void
focal_class.signature: void initUser(String token)
focal_class.class_method_signature: ZeppelinhubClient.stop()
focal_class.full_signature: public void stop()
focal_class.identifier: stop
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stop()
focal_class.class_method_signature: ZeppelinhubClient.stopUser(String token)
focal_class.full_signature: public void stopUser(String token)
focal_class.identifier: stopUser
focal_class.modifiers: public
focal_class.parameters: (String token)
focal_class.return: void
focal_class.signature: void stopUser(String token)
focal_class.class_method_signature: ZeppelinhubClient.getToken()
focal_class.full_signature: public String getToken()
focal_class.identifier: getToken
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getToken()
focal_class.class_method_signature: ZeppelinhubClient.send(String msg, String token)
focal_class.full_signature: public void send(String msg, String token)
focal_class.identifier: send
focal_class.modifiers: public
focal_class.parameters: (String msg, String token)
focal_class.return: void
focal_class.signature: void send(String msg, String token)
focal_class.class_method_signature: ZeppelinhubClient.isConnectedToZeppelinhub(ZeppelinhubSession zeppelinhubSession)
focal_class.full_signature: private boolean isConnectedToZeppelinhub(ZeppelinhubSession zeppelinhubSession)
focal_class.identifier: isConnectedToZeppelinhub
focal_class.modifiers: private
focal_class.parameters: (ZeppelinhubSession zeppelinhubSession)
focal_class.return: boolean
focal_class.signature: boolean isConnectedToZeppelinhub(ZeppelinhubSession zeppelinhubSession)
focal_class.class_method_signature: ZeppelinhubClient.connect(String token)
focal_class.full_signature: private ZeppelinhubSession connect(String token)
focal_class.identifier: connect
focal_class.modifiers: private
focal_class.parameters: (String token)
focal_class.return: ZeppelinhubSession
focal_class.signature: ZeppelinhubSession connect(String token)
focal_class.class_method_signature: ZeppelinhubClient.setSession(String token, ZeppelinhubSession session)
focal_class.full_signature: private void setSession(String token, ZeppelinhubSession session)
focal_class.identifier: setSession
focal_class.modifiers: private
focal_class.parameters: (String token, ZeppelinhubSession session)
focal_class.return: void
focal_class.signature: void setSession(String token, ZeppelinhubSession session)
focal_class.class_method_signature: ZeppelinhubClient.getSession(String token)
focal_class.full_signature: private ZeppelinhubSession getSession(String token)
focal_class.identifier: getSession
focal_class.modifiers: private
focal_class.parameters: (String token)
focal_class.return: ZeppelinhubSession
focal_class.signature: ZeppelinhubSession getSession(String token)
focal_class.class_method_signature: ZeppelinhubClient.removeSession(String token)
focal_class.full_signature: public void removeSession(String token)
focal_class.identifier: removeSession
focal_class.modifiers: public
focal_class.parameters: (String token)
focal_class.return: void
focal_class.signature: void removeSession(String token)
focal_class.class_method_signature: ZeppelinhubClient.getConnectionRequest(String token)
focal_class.full_signature: private ClientUpgradeRequest getConnectionRequest(String token)
focal_class.identifier: getConnectionRequest
focal_class.modifiers: private
focal_class.parameters: (String token)
focal_class.return: ClientUpgradeRequest
focal_class.signature: ClientUpgradeRequest getConnectionRequest(String token)
focal_class.class_method_signature: ZeppelinhubClient.createNewWebsocketClient()
focal_class.full_signature: private WebSocketClient createNewWebsocketClient()
focal_class.identifier: createNewWebsocketClient
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: WebSocketClient
focal_class.signature: WebSocketClient createNewWebsocketClient()
focal_class.class_method_signature: ZeppelinhubClient.addRoutines()
focal_class.full_signature: private void addRoutines()
focal_class.identifier: addRoutines
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void addRoutines()
focal_class.class_method_signature: ZeppelinhubClient.handleMsgFromZeppelinHub(String message)
focal_class.full_signature: public void handleMsgFromZeppelinHub(String message)
focal_class.identifier: handleMsgFromZeppelinHub
focal_class.modifiers: public
focal_class.parameters: (String message)
focal_class.return: void
focal_class.signature: void handleMsgFromZeppelinHub(String message)
focal_class.class_method_signature: ZeppelinhubClient.handleZeppelinHubOpMsg(ZeppelinHubOp op, ZeppelinhubMessage hubMsg, String msg)
focal_class.full_signature: private void handleZeppelinHubOpMsg(ZeppelinHubOp op, ZeppelinhubMessage hubMsg, String msg)
focal_class.identifier: handleZeppelinHubOpMsg
focal_class.modifiers: private
focal_class.parameters: (ZeppelinHubOp op, ZeppelinhubMessage hubMsg, String msg)
focal_class.return: void
focal_class.signature: void handleZeppelinHubOpMsg(ZeppelinHubOp op, ZeppelinhubMessage hubMsg, String msg)
focal_class.class_method_signature: ZeppelinhubClient.forwardToZeppelin(Message.OP op, ZeppelinhubMessage hubMsg)
focal_class.full_signature: @SuppressWarnings("unchecked") private void forwardToZeppelin(Message.OP op, ZeppelinhubMessage hubMsg)
focal_class.identifier: forwardToZeppelin
focal_class.modifiers: @SuppressWarnings("unchecked") private
focal_class.parameters: (Message.OP op, ZeppelinhubMessage hubMsg)
focal_class.return: void
focal_class.signature: void forwardToZeppelin(Message.OP op, ZeppelinhubMessage hubMsg)
focal_class.class_method_signature: ZeppelinhubClient.runAllParagraph(String noteId, String hubMsg)
focal_class.full_signature:  boolean runAllParagraph(String noteId, String hubMsg)
focal_class.identifier: runAllParagraph
focal_class.parameters: (String noteId, String hubMsg)
focal_class.return: boolean
focal_class.signature: boolean runAllParagraph(String noteId, String hubMsg)
focal_method.body: boolean runAllParagraph(String noteId, String hubMsg) {
      return true;
    }
focal_method.class_method_signature: ZeppelinhubClient.runAllParagraph(String noteId, String hubMsg)
focal_method.full_signature:  boolean runAllParagraph(String noteId, String hubMsg)
focal_method.identifier: runAllParagraph
focal_method.parameters: (String noteId, String hubMsg)
focal_method.return: boolean
focal_method.signature: boolean runAllParagraph(String noteId, String hubMsg)