add option for hyracks driver to have text output
diff --git a/genomix/genomix-data/src/main/java/edu/uci/ics/genomix/config/GenomixJobConf.java b/genomix/genomix-data/src/main/java/edu/uci/ics/genomix/config/GenomixJobConf.java
index 63758f2..40c343f 100644
--- a/genomix/genomix-data/src/main/java/edu/uci/ics/genomix/config/GenomixJobConf.java
+++ b/genomix/genomix-data/src/main/java/edu/uci/ics/genomix/config/GenomixJobConf.java
@@ -123,6 +123,9 @@
@Option(name = "-runLocal", usage = "Run a local instance using the Hadoop MiniCluster. NOTE: overrides settings for -ip and -port and those in conf/*.properties", required=false)
private boolean runLocal = false;
+ @Option(name = "-hyracksBuildOutputText", usage = "text output for hyracks build (debug option)", required=false)
+ private boolean hyracksBuildOutputText = false;
+
@Argument
private ArrayList<String> arguments = new ArrayList<String>();
}
@@ -212,6 +215,7 @@
public static final String HDFS_WORK_PATH = "genomix.hdfs.work.path";
public static final String HYRACKS_IO_DIRS = "genomix.hyracks.IO_DIRS";
public static final String HYRACKS_SLAVES = "genomix.hyracks.slaves.list";
+ public static final String HYRACKS_BUILD_OUTPUT_TEXT = "genomix.hyracks.build.outout.text";
private static final Patterns[] DEFAULT_PIPELINE_ORDER = {
Patterns.BUILD, Patterns.MERGE,
@@ -384,6 +388,7 @@
setBoolean(DRAW_STATISTICS, opts.drawStatistics);
setBoolean(RUN_LOCAL, opts.runLocal);
+ setBoolean(HYRACKS_BUILD_OUTPUT_TEXT, opts.hyracksBuildOutputText);
// Hyracks/Pregelix Setup
if (opts.ipAddress != null)
diff --git a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/graph/driver/Driver.java b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/graph/driver/Driver.java
index b3da280..ecf2a33 100644
--- a/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/graph/driver/Driver.java
+++ b/genomix/genomix-hyracks/src/main/java/edu/uci/ics/genomix/hyracks/graph/driver/Driver.java
@@ -170,7 +170,10 @@
String IODirs = jobConf.get(GenomixJobConf.HYRACKS_IO_DIRS, null);
int numOfDuplicate = IODirs != null ? IODirs.split(",").length : 4;
boolean bProfiling = jobConf.getBoolean(GenomixJobConf.PROFILE, true);
- jobConf.set(GenomixJobConf.OUTPUT_FORMAT, GenomixJobConf.OUTPUT_FORMAT_BINARY);
+ if (Boolean.getBoolean(jobConf.get(GenomixJobConf.HYRACKS_BUILD_OUTPUT_TEXT)))
+ jobConf.set(GenomixJobConf.OUTPUT_FORMAT, GenomixJobConf.OUTPUT_FORMAT_TEXT);
+ else
+ jobConf.set(GenomixJobConf.OUTPUT_FORMAT, GenomixJobConf.OUTPUT_FORMAT_BINARY);
jobConf.set(GenomixJobConf.GROUPBY_TYPE, GenomixJobConf.GROUPBY_TYPE_PRECLUSTER);
System.out.println(GenomixJobConf.INITIAL_INPUT_DIR);