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

Use Paths and Path instead of Strings to manipulate file system paths

Browse source
This commit is contained in:
Rajat Venkatesh 2016-01-11 08:40:11 +05:30
parent e21539b20b
commit be1bde75ad
1 changed files with 20 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -27,6 +27,8 @@ import java.io.File;
import java.io.InputStream;
import java.io.IOException;
import java.io.StringWriter;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
@ -71,27 +73,28 @@ public class HbaseInterpreter extends Interpreter {
@Override
public void open() {
String hbase_home = getProperty("hbase.home");
String ruby_src = getProperty("hbase.ruby.sources");
String abs_ruby_src = hbase_home + ruby_src;
File f = new File(abs_ruby_src);
if (!Boolean.parseBoolean(getProperty("hbase.test.mode")) &&
(!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);
Properties props = System.getProperties();
props.setProperty("hbase.ruby.sources", abs_ruby_src);
this.scriptingContainer = new ScriptingContainer(LocalContextScope.SINGLETON);
List<String> paths = new ArrayList<>(Arrays.asList(abs_ruby_src));
this.writer = new StringWriter();
scriptingContainer.setOutput(this.writer);
this.scriptingContainer.setLoadPaths(paths);
scriptingContainer.setCompatVersion(org.jruby.CompatVersion.RUBY1_9);
if (!Boolean.parseBoolean(getProperty("hbase.test.mode"))) {
String hbase_home = getProperty("hbase.home");
String ruby_src = getProperty("hbase.ruby.sources");
Path abs_ruby_src = Paths.get(hbase_home, ruby_src).toAbsolutePath();
logger.info("Home:" + hbase_home);
logger.info("Ruby Src:" + ruby_src);
File f = abs_ruby_src.toFile();
if (!f.exists() || !f.isDirectory()) {
throw new InterpreterException("hbase ruby sources is not available at '" + abs_ruby_src
+ "'");
}
List<String> paths = new ArrayList<>(Arrays.asList(abs_ruby_src.toAbsolutePath().toString()));
this.scriptingContainer.setLoadPaths(paths);
}
}
@Override