Sort of working prototype. Lots of hard coded pieces at the moment. (cherry picked from commit 83cfc6ab0891e2c7b73b8c72ea4ea20d98b774bf)
Project: http://git-wip-us.apache.org/repos/asf/bigtop/repo Commit: http://git-wip-us.apache.org/repos/asf/bigtop/commit/f9c6c65c Tree: http://git-wip-us.apache.org/repos/asf/bigtop/tree/f9c6c65c Diff: http://git-wip-us.apache.org/repos/asf/bigtop/diff/f9c6c65c Branch: refs/heads/master Commit: f9c6c65c35838af182af35dce462419f19417927 Parents: c313795 Author: Alan Gates <[email protected]> Authored: Mon Nov 7 15:52:37 2016 -0800 Committer: Roman Shaposhnik <[email protected]> Committed: Thu Mar 23 10:27:12 2017 -0700 ---------------------------------------------------------------------- .../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/f9c6c65c/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); + } }
