You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/03/14 01:01:17 UTC
[42/50] [abbrv] incubator-kylin git commit: refactor
refactor
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/73c53b4f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/73c53b4f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/73c53b4f
Branch: refs/heads/streaming-localdict
Commit: 73c53b4f7f1b1a0cf547673b7830a8f53f655e72
Parents: ea0a623
Author: qianhao.zhou <qi...@ebay.com>
Authored: Fri Mar 13 15:59:22 2015 +0800
Committer: qianhao.zhou <qi...@ebay.com>
Committed: Fri Mar 13 15:59:22 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/storage/hbase/HBaseClientKVIterator.java | 2 +-
.../org/apache/kylin/storage/hbase/InvertedIndexHBaseTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/73c53b4f/storage/src/main/java/org/apache/kylin/storage/hbase/HBaseClientKVIterator.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/hbase/HBaseClientKVIterator.java b/storage/src/main/java/org/apache/kylin/storage/hbase/HBaseClientKVIterator.java
index 6c1085e..3702609 100644
--- a/storage/src/main/java/org/apache/kylin/storage/hbase/HBaseClientKVIterator.java
+++ b/storage/src/main/java/org/apache/kylin/storage/hbase/HBaseClientKVIterator.java
@@ -44,7 +44,7 @@ public class HBaseClientKVIterator implements Iterable<IIRow>, Closeable {
ResultScanner scanner;
Iterator<Result> iterator;
- public HBaseClientKVIterator(HConnection hconn, String tableName, byte[] family, byte[] qualifier) throws IOException {
+ public HBaseClientKVIterator(HConnection hconn, String tableName, byte[] family) throws IOException {
this.family = family;
this.table = hconn.getTable(tableName);
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/73c53b4f/storage/src/test/java/org/apache/kylin/storage/hbase/InvertedIndexHBaseTest.java
----------------------------------------------------------------------
diff --git a/storage/src/test/java/org/apache/kylin/storage/hbase/InvertedIndexHBaseTest.java b/storage/src/test/java/org/apache/kylin/storage/hbase/InvertedIndexHBaseTest.java
index 548224c..9e37447 100644
--- a/storage/src/test/java/org/apache/kylin/storage/hbase/InvertedIndexHBaseTest.java
+++ b/storage/src/test/java/org/apache/kylin/storage/hbase/InvertedIndexHBaseTest.java
@@ -84,7 +84,7 @@ public class InvertedIndexHBaseTest extends HBaseMetadataTestCase {
IIKeyValueCodec codec = new IIKeyValueCodec(info.getDigest());
List<Slice> slices = Lists.newArrayList();
- HBaseClientKVIterator kvIterator = new HBaseClientKVIterator(hconn, tableName, IIDesc.HBASE_FAMILY_BYTES, IIDesc.HBASE_QUALIFIER_BYTES);
+ HBaseClientKVIterator kvIterator = new HBaseClientKVIterator(hconn, tableName, IIDesc.HBASE_FAMILY_BYTES);
try {
for (Slice slice : codec.decodeKeyValue(kvIterator)) {
slices.add(slice);