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

More code cleanup

Browse source
This commit is contained in:
Sriram Krishnan 2015-12-21 15:22:08 -08:00
parent 368dc042ef
commit 7ec2941380
1 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
scalding/src/main/java/org/apache/zeppelin/scalding/ScaldingInterpreter.java
View file

@ -21,10 +21,11 @@ import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.util.Properties;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.net.URL;
import java.net.URLClassLoader;
@ -54,6 +55,8 @@ import scala.tools.nsc.settings.MutableSettings.PathSetting;
public class ScaldingInterpreter extends Interpreter {
Logger logger = LoggerFactory.getLogger(ScaldingInterpreter.class);
public static final List<String> NO_COMPLETION = new ArrayList<>();
static {
Interpreter.register("scalding", ScaldingInterpreter.class.getName());
}
@ -177,7 +180,7 @@ public class ScaldingInterpreter extends Interpreter {
@Override
public InterpreterResult interpret(String cmd, InterpreterContext contextInterpreter) {
logger.info("Run Scalding command '" + cmd + "'");
logger.info("Running Scalding command '" + cmd + "'");
if (cmd == null || cmd.trim().length() == 0) {
return new InterpreterResult(Code.SUCCESS);
@ -222,7 +225,6 @@ public class ScaldingInterpreter extends Interpreter {
try {
res = interpreter.intp().interpret(incomplete + s);
} catch (Exception e) {
e.printStackTrace();
logger.error("Interpreter exception: ", e);
return new InterpreterResult(Code.ERROR, e.getMessage());
}
@ -264,12 +266,12 @@ public class ScaldingInterpreter extends Interpreter {
@Override
public FormType getFormType() {
return FormType.SIMPLE;
return FormType.NATIVE;
}
@Override
public int getProgress(InterpreterContext context) {
// not implemented - return 0
// fine-grained progress not implemented - return 0
return 0;
}
@ -281,7 +283,6 @@ public class ScaldingInterpreter extends Interpreter {
@Override
public List<String> completion(String buf, int cursor) {
return null;
return NO_COMPLETION;
}
}