Add jars in WindowingClient;

set SUMBITCHILDJVM to true
set windowingOutput to true

Author: hbutani

windowing/src/main/java/com/sap/hadoop/windowing/Constants.java

@@ -22,7 +22,7 @@ public class Constants
 	public static final String WINDOW_PARTITION_MEM_SIZE = "com.sap.hadoop.windowing.partition.memory.size";
 
 	public static final String WINDOW_PARTITION_CLASS = "com.sap.hadoop.windowing.partition.class";
-	public static final String DEFAULT_WINDOW_PARTITION_CLASS = "com.sap.hadoop.ds.list.ByteBasedList";
+	public static final String DEFAULT_WINDOW_PARTITION_CLASS = "com.sap.hadoop.ds.list.PartitionedByteBasedList";
 
 	/*
 	 * the difference between script & expression is that script is only parsed during translation,

windowing/src/main/java/com/sap/hadoop/windowing/cli2/WindowingClient.java

@@ -1,6 +1,10 @@
 package com.sap.hadoop.windowing.cli2;
 
+import org.apache.hadoop.hive.conf.HiveConf;
+import org.apache.hadoop.hive.conf.HiveConf.ConfVars;
+import org.apache.hadoop.hive.ql.session.SessionState;
 import org.apache.hadoop.hive.ql.session.SessionState.LogHelper;
+import org.apache.hadoop.hive.ql.session.SessionState.ResourceType;
 
 import com.sap.hadoop.windowing.Constants;
 import com.sap.hadoop.windowing.WindowingException;
@@ -22,6 +26,7 @@ class WindowingClient implements HiveQueryExecutor
 	WindowingClient(WindowingHiveCliDriver hiveDriver) throws WindowingException
 	{
 		this.hiveDriver = hiveDriver;
+		setupConf(hiveDriver.getCfg());
 		wshell = new WindowingShell( hiveDriver.getCfg(), new Translator(), new MRExecutor());
 		wshell.setHiveQryExec(this);
 		qryOutPrntr = new QueryOutputPrinter(hiveDriver.getHiveConsole());
@@ -79,4 +84,45 @@ private boolean outputQueryResult()
 	{
 		return wshell.getCfg().getBoolean(Constants.WINDOWING_OUTPUT_QUERY_RESULT, false);
 	}
+	
+	private static final String[] addedJars = new String[] {
+		"lib/com.sap.hadoop.windowing-0.0.2-SNAPSHOT.jar",
+		"lib/antlr-runtime-3.0.1.jar",
+		"lib/groovy-all-1.8.0.jar",
+		"lib/hive-metastore-0.10.0-SNAPSHOT.jar"
+	};
+	
+	private void setupConf(HiveConf cfg) throws WindowingException
+	{
+		String hiveHome = System.getenv("HIVE_HOME");
+		// for testing purposes
+		hiveHome = hiveHome == null ? cfg.get("HIVE_HOME") : hiveHome;
+		
+		if ( hiveHome == null)
+		{
+			throw new WindowingException("Environment variable HIVE_HOME must be set.");
+		}
+		
+		if ( !hiveHome.endsWith("/"))
+		{
+			hiveHome += "/";
+		}
+		
+		/*
+		 * add jars to SessionState
+		 */
+		SessionState ss = SessionState.get();
+		for(String j : addedJars)
+		{
+			ss.add_resource(ResourceType.JAR, hiveHome + j);
+		}
+		
+		/*
+		 * set run in childJvm to true
+		 * why? because w/o this CLI tries to print status based on QueryPlan, which is null for us.
+		 */
+		cfg.setBoolean(ConfVars.SUBMITVIACHILD.toString(), true);
+		
+		cfg.setBoolean(Constants.WINDOWING_OUTPUT_QUERY_RESULT, true);
+	}
 }