update to latest Spring Hadoop changes

spring-attic · Oct 1, 2012 · 850c942 · 850c942
1 parent 8fe98e8
commit 850c942
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/plugin-hive/src/main/java/org/springframework/data/hadoop/impala/hive/HiveCommands.java b/plugin-hive/src/main/java/org/springframework/data/hadoop/impala/hive/HiveCommands.java
@@ -126,7 +126,7 @@ public String script(@CliOption(key = { "", "location" }, mandatory = true, help
 		StringBuilder sb = new StringBuilder();
 
 		try {
-			sb.append(StringUtils.collectionToDelimitedString(hiveTemplate.execute(resource),
+			sb.append(StringUtils.collectionToDelimitedString(hiveTemplate.executeScript(resource),
 					StringUtils.LINE_SEPARATOR));
 		} catch (Exception ex) {
 			return "Script [" + uri + "] failed - " + ex;

diff --git a/plugin-pig/src/main/java/org/springframework/data/hadoop/impala/pig/PigCommands.java b/plugin-pig/src/main/java/org/springframework/data/hadoop/impala/pig/PigCommands.java
@@ -189,7 +189,7 @@ public String script(@CliOption(key = { "", "location" }, mandatory = true, help
 				init();
 			}
 
-			List<ExecJob> results = pigTemplate.execute(resource);
+			List<ExecJob> results = pigTemplate.executeScript(resource);
 			ExecJob result = results.get(0);
 			Exception exception = result.getException();
 			StringBuilder sb = new StringBuilder(result.getStatus().name());