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

Review comments

Browse source
This commit is contained in:
Rajat Venkatesh 2015-09-07 13:07:36 -07:00
parent 255d0d904e
commit ca649310c0
1 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
hbase/src/main/java/org/apache/zeppelin/hbase/HbaseInterpreter.java
View file

@ -14,10 +14,7 @@
package org.apache.zeppelin.hbase;
import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterPropertyBuilder;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.*;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;
import org.jruby.embed.LocalContextScope;
@ -26,6 +23,7 @@ import org.slf4j.LoggerFactory;
import org.jruby.embed.ScriptingContainer;
import java.io.File;
import java.io.InputStream;
import java.io.IOException;
import java.io.StringWriter;
@ -63,7 +61,8 @@ public class HbaseInterpreter extends Interpreter {
.add("hbase.home", "/usr/lib/hbase/", "Installation dir. of Hbase")
.add("hbase.ruby.sources", "lib/ruby",
"Path to Ruby scripts relative to 'hbase.home'")
.add("hbase.irb.load", "true", "Load hirb. Optional for testing only")
.add("hbase.irb.load", "true", "Load hirb. hirb loads hbase shell. " +
"For unit tests it has to be turned off.")
.build());
}
@ -77,6 +76,11 @@ public class HbaseInterpreter extends Interpreter {
String ruby_src = getProperty("hbase.ruby.sources");
String abs_ruby_src = hbase_home + ruby_src;
File f = new File(abs_ruby_src);
if (!f.exists() || !f.isDirectory()) {
throw new InterpreterException("hbase ruby sources is not correctly defined.");
}
logger.info("Home:" + hbase_home);
logger.info("Ruby Src:" + ruby_src);