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 <[email protected]> Authored: Mon Nov 7 15:52:37 2016 -0800 Committer: Roman Shaposhnik <[email protected]> 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); + } }
