@Test public void testNextlineInvoke() { InterpreterResult result = flink.interpret("\"123\"\n .toInt", context); assertEquals("res0: Int = 123\n", result.message()); }
@Override public InterpreterResult interpret(String line, InterpreterContext context) { if (line == null || line.trim().length() == 0) { return new InterpreterResult(Code.SUCCESS); } InterpreterResult result = interpret(line.split("\n"), context); return result; }
FlinkInterpreter extends Interpreter { @Override public InterpreterResult interpret(String line, InterpreterContext context) { if (line == null || line.trim().length() == 0) { return new InterpreterResult(Code.SUCCESS); } InterpreterResult result = interpret(line.split("\n"), context); return result; } }
FlinkInterpreter extends Interpreter { @Override public InterpreterResult interpret(String line, InterpreterContext context) { if (line == null || line.trim().length() == 0) { return new InterpreterResult(Code.SUCCESS); } InterpreterResult result = interpret(line.split("\n"), context); return result; } FlinkInterpreter(Properties property); }
FlinkInterpreter extends Interpreter { @Override public InterpreterResult interpret(String line, InterpreterContext context) { if (line == null || line.trim().length() == 0) { return new InterpreterResult(Code.SUCCESS); } InterpreterResult result = interpret(line.split("\n"), context); return result; } FlinkInterpreter(Properties property); @Override void open(); Object getValue(String name); @Override void close(); @Override InterpreterResult interpret(String line, InterpreterContext context); InterpreterResult interpret(String[] lines, InterpreterContext context); @Override void cancel(InterpreterContext context); @Override FormType getFormType(); @Override int getProgress(InterpreterContext context); @Override List<String> completion(String buf, int cursor); }
FlinkInterpreter extends Interpreter { @Override public InterpreterResult interpret(String line, InterpreterContext context) { if (line == null || line.trim().length() == 0) { return new InterpreterResult(Code.SUCCESS); } InterpreterResult result = interpret(line.split("\n"), context); return result; } FlinkInterpreter(Properties property); @Override void open(); Object getValue(String name); @Override void close(); @Override InterpreterResult interpret(String line, InterpreterContext context); InterpreterResult interpret(String[] lines, InterpreterContext context); @Override void cancel(InterpreterContext context); @Override FormType getFormType(); @Override int getProgress(InterpreterContext context); @Override List<String> completion(String buf, int cursor);  }