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/03/23 17:27:48 UTC
[17/50] [abbrv] bigtop git commit: Added key value assignments to
arguments. (cherry picked from commit
9cd5f71997eae0263b5a405d13dd6daff88b46eb)
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 <rd...@us.ibm.com>
Authored: Thu Jan 19 15:08:45 2017 -0800
Committer: Roman Shaposhnik <rv...@apache.org>
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);