You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bigtop.apache.org by rv...@apache.org on 2017/02/24 19:52:44 UTC
[41/50] [abbrv] bigtop git commit: Sort of working prototype. Lots of
hard coded pieces at the moment.
Sort of working prototype. Lots of hard coded pieces at the moment.
Project: http://git-wip-us.apache.org/repos/asf/bigtop/repo
Commit: http://git-wip-us.apache.org/repos/asf/bigtop/commit/246939ae
Tree: http://git-wip-us.apache.org/repos/asf/bigtop/tree/246939ae
Diff: http://git-wip-us.apache.org/repos/asf/bigtop/diff/246939ae
Branch: refs/heads/BIGTOP-2666
Commit: 246939aee4796bbc622e6527034ed9751b92f25e
Parents: 27ba88b
Author: Alan Gates <ga...@hortonworks.com>
Authored: Mon Nov 7 15:52:37 2016 -0800
Committer: Roman Shaposhnik <rv...@apache.org>
Committed: Fri Feb 24 11:51:24 2017 -0800
----------------------------------------------------------------------
.../src/main/java/org/odpi/specs/runtime/hive/HCatalogMR.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/bigtop/blob/246939ae/bigtop-tests/spec-tests/runtime/src/main/java/org/odpi/specs/runtime/hive/HCatalogMR.java
----------------------------------------------------------------------
diff --git a/bigtop-tests/spec-tests/runtime/src/main/java/org/odpi/specs/runtime/hive/HCatalogMR.java b/bigtop-tests/spec-tests/runtime/src/main/java/org/odpi/specs/runtime/hive/HCatalogMR.java
index 4a733d6..6fcfe37 100644
--- a/bigtop-tests/spec-tests/runtime/src/main/java/org/odpi/specs/runtime/hive/HCatalogMR.java
+++ b/bigtop-tests/spec-tests/runtime/src/main/java/org/odpi/specs/runtime/hive/HCatalogMR.java
@@ -27,6 +27,7 @@ import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.util.GenericOptionsParser;
import org.apache.hadoop.util.Tool;
+import org.apache.hadoop.util.ToolRunner;
import org.apache.hive.hcatalog.data.DefaultHCatRecord;
import org.apache.hive.hcatalog.data.HCatRecord;
import org.apache.hive.hcatalog.data.schema.HCatSchema;
@@ -74,6 +75,7 @@ public class HCatalogMR extends Configured implements Tool {
job.addCacheArchive(new URI("hdfs:/user/gates/hive-hcatalog-core-1.2.1.jar"));
job.addCacheArchive(new URI("hdfs:/user/gates/hive-metastore-1.2.1.jar"));
job.addCacheArchive(new URI("hdfs:/user/gates/hive-exec-1.2.1.jar"));
+ job.addCacheArchive(new URI("hdfs:/user/gates/libfb303-0.9.2.jar"));
return job.waitForCompletion(true) ? 0 : 1;
@@ -121,4 +123,9 @@ public class HCatalogMR extends Configured implements Tool {
context.write(null, output);
}
}
+
+ public static void main(String[] args) throws Exception {
+ int exitCode = ToolRunner.run(new HCatalogMR(), args);
+ System.exit(exitCode);
+ }
}