You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/09/17 08:06:53 UTC
[2/4] incubator-kylin git commit: KYLIN-1027 init credentials
manually for HBASE token
KYLIN-1027 init credentials manually for HBASE token
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/7e3f4ca8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/7e3f4ca8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/7e3f4ca8
Branch: refs/heads/2.x-staging
Commit: 7e3f4ca8eb3022291a97a8682901a184291e8b39
Parents: 3a6ad20
Author: honma <ho...@ebay.com>
Authored: Wed Sep 16 17:37:50 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Thu Sep 17 14:09:09 2015 +0800
----------------------------------------------------------------------
.../org/apache/kylin/storage/hbase/steps/HBaseMROutput2.java | 6 +++---
.../kylin/storage/hbase/steps/HBaseMROutput2Transition.java | 1 +
2 files changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7e3f4ca8/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2.java
index 774fe2a..f99ddb5 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2.java
@@ -129,7 +129,7 @@ public class HBaseMROutput2 implements IMROutput2 {
@SuppressWarnings({ "rawtypes", "unchecked" })
private static class HBaseInputFormat implements IMRStorageInputFormat {
final CubeSegment seg;
-
+
final RowValueDecoder[] rowValueDecoders;
final ByteArrayWritable parsedKey;
final Object[] parsedValue;
@@ -137,7 +137,7 @@ public class HBaseMROutput2 implements IMROutput2 {
public HBaseInputFormat(CubeSegment seg) {
this.seg = seg;
-
+
List<RowValueDecoder> valueDecoderList = Lists.newArrayList();
List<MeasureDesc> measuresDescs = Lists.newArrayList();
for (HBaseColumnFamilyDesc cfDesc : seg.getCubeDesc().getHBaseMapping().getColumnFamily()) {
@@ -170,7 +170,7 @@ public class HBaseMROutput2 implements IMROutput2 {
}
TableMapReduceUtil.initTableMapperJob(scans, (Class<? extends TableMapper>) mapperClz, outputKeyClz, outputValueClz, job);
-TableMapReduceUtil.initCredentials(job);
+ TableMapReduceUtil.initCredentials(job);
}
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7e3f4ca8/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2Transition.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2Transition.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2Transition.java
index 237f0c9..00cecf1 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2Transition.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/HBaseMROutput2Transition.java
@@ -184,6 +184,7 @@ public class HBaseMROutput2Transition implements IMROutput2 {
scans.add(scan);
}
TableMapReduceUtil.initTableMapperJob(scans, (Class<? extends TableMapper>) mapperClz, outputKeyClz, outputValueClz, job);
+ TableMapReduceUtil.initCredentials(job);
}
}