kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From qhz...@apache.org
Subject incubator-kylin git commit: fix compile error
Date Tue, 02 Jun 2015 03:26:15 GMT
Repository: incubator-kylin
Updated Branches:
  refs/heads/0.8.0 15fd9af54 -> 61c7115d4


fix compile error


Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/61c7115d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/61c7115d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/61c7115d

Branch: refs/heads/0.8.0
Commit: 61c7115d4cde933ff4976e3764f452c39b234389
Parents: 15fd9af
Author: qianhao.zhou <qianzhou@ebay.com>
Authored: Tue Jun 2 11:26:35 2015 +0800
Committer: qianhao.zhou <qianzhou@ebay.com>
Committed: Tue Jun 2 11:26:35 2015 +0800

----------------------------------------------------------------------
 .../org/apache/kylin/job/hadoop/invertedindex/IITest.java   | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/61c7115d/job/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
----------------------------------------------------------------------
diff --git a/job/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java b/job/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
index 7a88420..390017f 100644
--- a/job/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
+++ b/job/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
@@ -41,6 +41,7 @@ import org.apache.kylin.storage.hbase.coprocessor.endpoint.ClearTextDictionary;
 import org.apache.kylin.storage.hbase.coprocessor.endpoint.EndpointAggregators;
 import org.apache.kylin.storage.hbase.coprocessor.endpoint.IIEndpoint;
 import org.apache.kylin.storage.hbase.coprocessor.endpoint.generated.IIProtos;
+import org.apache.kylin.streaming.MicroStreamBatch;
 import org.apache.kylin.streaming.StreamMessage;
 import org.apache.kylin.streaming.StringStreamParser;
 import org.apache.kylin.streaming.invertedindex.SliceBuilder;
@@ -75,16 +76,16 @@ public class IITest extends LocalFileMetadataTestCase {
         this.ii = IIManager.getInstance(getTestConfig()).getII(iiName);
         this.iiDesc = ii.getDescriptor();
 
-        List<StreamMessage> streamMessages = Lists.transform(Arrays.asList(inputData),
new Function<String, StreamMessage>() {
+        List<List<String>> streamMessages = Lists.transform(Arrays.asList(inputData),
new Function<String, List<String>>() {
             @Nullable
             @Override
-            public StreamMessage apply(String input) {
-                return new StreamMessage(System.currentTimeMillis(), input.getBytes());
+            public List<String> apply(@Nullable String input) {
+                return StringStreamParser.instance.parse(new StreamMessage(System.currentTimeMillis(),
input.getBytes())).getStreamMessage();
             }
         });
 
         iiRows = Lists.newArrayList();
-        final Slice slice = new SliceBuilder(iiDesc, (short) 0, true).buildSlice(streamMessages,
StringStreamParser.instance);
+        final Slice slice = new SliceBuilder(iiDesc, (short) 0, true).buildSlice(new MicroStreamBatch(streamMessages,
org.apache.kylin.common.util.Pair.newPair(System.currentTimeMillis(), System.currentTimeMillis()),
org.apache.kylin.common.util.Pair.newPair(System.currentTimeMillis(), System.currentTimeMillis())));
         IIKeyValueCodec codec = new IIKeyValueCodec(slice.getInfo());
         for (IIRow iiRow : codec.encodeKeyValue(slice)) {
             iiRows.add(iiRow);


Mime
View raw message