You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ni...@apache.org on 2019/08/15 03:10:42 UTC
[kylin] branch master updated: KYLIN-4127 Remove never used classes
This is an automated email from the ASF dual-hosted git repository.
nic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/master by this push:
new 57fb3c9 KYLIN-4127 Remove never used classes
57fb3c9 is described below
commit 57fb3c9f97994c5c55c7edfc9555fa0eb0c90b94
Author: weibin0516 <co...@126.com>
AuthorDate: Sat Aug 10 12:52:02 2019 +0800
KYLIN-4127 Remove never used classes
---
.../apache/kylin/stream/coordinator/assign/DefaultAssigner.java | 7 -------
.../org/apache/kylin/stream/core/storage/StreamingCubeSegment.java | 6 ------
2 files changed, 13 deletions(-)
diff --git a/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/DefaultAssigner.java b/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/DefaultAssigner.java
index 6e095ad..02bcc09 100644
--- a/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/DefaultAssigner.java
+++ b/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/DefaultAssigner.java
@@ -200,11 +200,4 @@ public class DefaultAssigner implements Assigner {
}
return result;
}
-
- private static class TaskInfo {
- public String cubeName;
- public List<Partition> partitions;
-
- }
-
}
diff --git a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/StreamingCubeSegment.java b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/StreamingCubeSegment.java
index dbcdf19..b4b4638 100644
--- a/stream-core/src/main/java/org/apache/kylin/stream/core/storage/StreamingCubeSegment.java
+++ b/stream-core/src/main/java/org/apache/kylin/stream/core/storage/StreamingCubeSegment.java
@@ -20,7 +20,6 @@ package org.apache.kylin.stream.core.storage;
import java.io.File;
import java.io.IOException;
-import java.util.Map;
import org.apache.kylin.common.util.Pair;
import org.apache.kylin.cube.CubeInstance;
@@ -179,9 +178,4 @@ public class StreamingCubeSegment implements Comparable<StreamingCubeSegment> {
public enum State {
ACTIVE, IMMUTABLE, REMOTE_PERSISTED
}
-
- public static class SegmentInfo {
- private Map<Integer, Long> sourceStartOffsets;
-
- }
}