You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by jy...@apache.org on 2016/02/13 01:14:51 UTC
phoenix git commit: PHOENIX-2674 PhoenixMapReduceUtil#setInput
doesn't honor condition clause (addendum)
Repository: phoenix
Updated Branches:
refs/heads/4.x-HBase-0.98 35b893d21 -> 470477e50
PHOENIX-2674 PhoenixMapReduceUtil#setInput doesn't honor condition clause (addendum)
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/470477e5
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/470477e5
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/470477e5
Branch: refs/heads/4.x-HBase-0.98
Commit: 470477e5053075e5ebf128bc3ae532e908a25067
Parents: 35b893d
Author: Jesse Yates <jy...@apache.org>
Authored: Fri Feb 12 15:46:11 2016 -0800
Committer: Jesse Yates <jy...@apache.org>
Committed: Fri Feb 12 16:14:41 2016 -0800
----------------------------------------------------------------------
.../org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtil.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/470477e5/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtil.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtil.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtil.java
index 125c6a8..98f0364 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtil.java
@@ -58,8 +58,9 @@ public final class PhoenixMapReduceUtil {
* @param inputQuery Select query.
*/
public static void setInput(final Job job, final Class<? extends DBWritable> inputClass, final String tableName, final String inputQuery) {
- final Configuration configuration = setInput(job, inputClass, tableName);
- PhoenixConfigurationUtil.setSchemaType(configuration, SchemaType.QUERY);
+ final Configuration configuration = setInput(job, inputClass, tableName);
+ PhoenixConfigurationUtil.setInputQuery(configuration, inputQuery);
+ PhoenixConfigurationUtil.setSchemaType(configuration, SchemaType.QUERY);
}
private static Configuration setInput(final Job job, final Class<? extends DBWritable> inputClass, final String tableName){