Added key value assignments to arguments. (cherry picked from commit 9cd5f71997eae0263b5a405d13dd6daff88b46eb)
Project: http://git-wip-us.apache.org/repos/asf/bigtop/repo Commit: http://git-wip-us.apache.org/repos/asf/bigtop/commit/dcd9cb20 Tree: http://git-wip-us.apache.org/repos/asf/bigtop/tree/dcd9cb20 Diff: http://git-wip-us.apache.org/repos/asf/bigtop/diff/dcd9cb20 Branch: refs/heads/master Commit: dcd9cb20ae680df0bd9a1ce62391fefb6b1c35fb Parents: 47c31dc Author: Raj Desai <[email protected]> Authored: Thu Jan 19 15:08:45 2017 -0800 Committer: Roman Shaposhnik <[email protected]> Committed: Thu Mar 23 10:27:13 2017 -0700 ---------------------------------------------------------------------- .../org/odpi/specs/runtime/hive/HCatalogMR.java | 21 +++++++++++++++----- 1 file changed, 16 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bigtop/blob/dcd9cb20/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 7cb9bbe..4110d5d 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 @@ -46,14 +46,25 @@ public class HCatalogMR extends Configured implements Tool { @Override public int run(String[] args) throws Exception { + String inputTable = null; + String outputTable = null; + String inputSchemaStr = null; + String outputSchemaStr = null; + for(int i = 0; i < args.length; i++){ + if(args[i].equalsIgnoreCase("-it")){ + inputTable = args[i+1]; + }else if(args[i].equalsIgnoreCase("-ot")){ + outputTable = args[i+1]; + }else if(args[i].equalsIgnoreCase("-is")){ + inputSchemaStr = args[i+1]; + }else if(args[i].equalsIgnoreCase("-os")){ + outputSchemaStr = args[i+1]; + } + } + Configuration conf = getConf(); args = new GenericOptionsParser(conf, args).getRemainingArgs(); - String inputTable = args[0]; - String outputTable = args[1]; - String inputSchemaStr = args[2]; - String outputSchemaStr = args[3]; - conf.set(INPUT_SCHEMA, inputSchemaStr); conf.set(OUTPUT_SCHEMA, outputSchemaStr);
