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/06/17 10:00:18 UTC
[1/2] incubator-kylin git commit: KYLIN-836 storage cache simply use
StreamSQLDigest's hashcode
Repository: incubator-kylin
Updated Branches:
refs/heads/0.8 2883acf18 -> 15ef5b8de
KYLIN-836 storage cache simply use StreamSQLDigest's hashcode
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/15ef5b8d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/15ef5b8d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/15ef5b8d
Branch: refs/heads/0.8
Commit: 15ef5b8ded5cb7544888972029abce9af61b4605
Parents: 7ca0aaa
Author: honma <ho...@ebay.com>
Authored: Wed Jun 17 15:59:50 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Wed Jun 17 16:00:04 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/rest/service/CacheService.java | 2 +-
.../AbstractCacheFledgedStorageEngine.java | 1 -
.../cache/CacheFledgedDynamicStorageEngine.java | 33 +++++++++++---------
.../cache/CacheFledgedStaticStorageEngine.java | 4 +--
4 files changed, 22 insertions(+), 18 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/15ef5b8d/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/kylin/rest/service/CacheService.java b/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
index ea6d410..66760a5 100644
--- a/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
+++ b/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
@@ -164,7 +164,7 @@ public class CacheService extends BasicService {
logger.debug("server mode: " + serverMode);
if (Constant.SERVER_MODE_JOB.equals(serverMode.toLowerCase()) || Constant.SERVER_MODE_ALL.equals(serverMode.toLowerCase())) {
logger.debug("This is the job engine node, will check whether auto merge is needed on cube " + cubeName);
- CubeSegment newSeg = null;
+ CubeSegment newSeg;
synchronized (CacheService.class) {
CubeInstance cube = getCubeManager().getCube(cubeName);
try {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/15ef5b8d/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java b/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
index 441d7dc..422e335 100644
--- a/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
+++ b/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
@@ -62,7 +62,6 @@ public abstract class AbstractCacheFledgedStorageEngine implements IStorageEngin
if (CACHE_MANAGER.getCache(storageUUID) == null) {
logger.info("Cache for {} initting...", storageUUID);
- // TODO: L4J [2015-04-20 10:44:03,817][WARN][net.sf.ehcache.pool.sizeof.ObjectGraphWalker] - The configured limit of 1,000 object references was reached while attempting to calculate the size of the object graph. Severe performance degradation could occur if the sizing operation continues. This can be avoided by setting the CacheManger or Cache <sizeOfPolicy> elements maxDepthExceededBehavior to "abort" or adding stop points with @IgnoreSizeOf annotations. If performance degradation is NOT an issue at the configured limit, raise the limit value using the CacheManager or Cache <sizeOfPolicy
//Create a Cache specifying its configuration.
CacheConfiguration templateConf = CACHE_MANAGER.getCache(storageCacheTemplate).getCacheConfiguration();
PersistenceConfiguration pconf = templateConf.getPersistenceConfiguration();
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/15ef5b8d/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
index 734a2dd..0cfa382 100644
--- a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
+++ b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
@@ -40,6 +40,13 @@ public class CacheFledgedDynamicStorageEngine extends AbstractCacheFledgedStorag
@Override
public ITupleIterator search(final StorageContext context, final SQLDigest sqlDigest, final TupleInfo returnTupleInfo) {
+ //check if ts condition in sqlDigest valid
+ ts = TsConditionExtractor.extractTsCondition(partitionColRef, sqlDigest.filter);
+ if (ts == null || ts.isEmpty()) {
+ logger.info("ts range in the query conflicts,return empty directly");
+ return ITupleIterator.EMPTY_TUPLE_ITERATOR;
+ }
+
//enable dynamic cache iff group by columns contains partition col
//because cache extraction requires partition col value as selection key
boolean needUpdateCache = sqlDigest.groupbyColumns.contains(partitionColRef);
@@ -47,18 +54,12 @@ public class CacheFledgedDynamicStorageEngine extends AbstractCacheFledgedStorag
streamSQLDigest = new StreamSQLDigest(sqlDigest, partitionColRef);
StreamSQLResult cachedResult = null;
Cache cache = CACHE_MANAGER.getCache(this.underlyingStorage.getStorageUUID());
- Element element = cache.get(streamSQLDigest);
+ Element element = cache.get(streamSQLDigest.hashCode());
if (element != null) {
this.queryCacheExists = true;
cachedResult = (StreamSQLResult) element.getObjectValue();
}
- ts = TsConditionExtractor.extractTsCondition(partitionColRef, sqlDigest.filter);
- if (ts == null || ts.isEmpty()) {
- logger.info("ts range in the query conflicts,return empty directly");
- return ITupleIterator.EMPTY_TUPLE_ITERATOR;
- }
-
ITupleIterator ret = null;
if (cachedResult != null) {
Range<Long> reusePeriod = cachedResult.getReusableResults(ts);
@@ -75,7 +76,7 @@ public class CacheFledgedDynamicStorageEngine extends AbstractCacheFledgedStorag
List<ITupleIterator> iTupleIteratorList = Lists.newArrayList();
iTupleIteratorList.add(reusedTuples);
- for (Range<Long> remaining : remainings) {
+ for (Range<Long> remaining : remainings) {//actually there will be only one loop
logger.info("Appending ts " + RangeUtil.formatTsRange(remaining) + " as additional filter");
ITupleIterator freshTuples = SQLDigestUtil.appendTsFilterToExecute(sqlDigest, partitionColRef, remaining, new Function<Void, ITupleIterator>() {
@@ -89,10 +90,13 @@ public class CacheFledgedDynamicStorageEngine extends AbstractCacheFledgedStorag
ret = new CompoundTupleIterator(iTupleIteratorList);
} else if (remainings.size() == 0) {
+ logger.info("The ts range in new query was fully cached");
needUpdateCache = false;
ret = new SimpleTupleIterator(cachedResult.reuse(reusePeriod));
} else {
- //if using cache causes two underlyingStorage searches, we'd rather not use the cache
+ //if using cache causes more than one underlyingStorage searches
+ //the incurred overhead might be more expensive than the cache benefit
+ logger.info("Give up using cache to avoid complexity");
}
}
} else {
@@ -100,10 +104,10 @@ public class CacheFledgedDynamicStorageEngine extends AbstractCacheFledgedStorag
}
if (ret == null) {
- logger.info("decision: not using cache");
ret = underlyingStorage.search(context, sqlDigest, returnTupleInfo);
+ logger.info("No Cache being used");
} else {
- logger.info("decision: use cache");
+ logger.info("Cache being used");
}
if (needUpdateCache) {
@@ -117,23 +121,24 @@ public class CacheFledgedDynamicStorageEngine extends AbstractCacheFledgedStorag
}
@Override
- public void notify(List<ITuple> duplicated,long createTime) {
+ public void notify(List<ITuple> duplicated, long createTime) {
Range<Long> cacheExclude = this.underlyingStorage.getVolatilePeriod();
if (cacheExclude != null) {
List<Range<Long>> cachablePeriods = RangeUtil.remove(ts, cacheExclude);
if (cachablePeriods.size() == 1) {
if (!ts.equals(cachablePeriods.get(0))) {
- logger.info("With respect to each shard's build status, the cacheable tsRange shrinks from " + RangeUtil.formatTsRange(ts) + " to " + RangeUtil.formatTsRange(cachablePeriods.get(0)));
+ logger.info("With respect to growing storage, the cacheable tsRange shrinks from " + RangeUtil.formatTsRange(ts) + " to " + RangeUtil.formatTsRange(cachablePeriods.get(0)));
}
ts = cachablePeriods.get(0);
} else {
//give up updating the cache, in avoid to make cache complicated
+ logger.info("Skip updating cache to avoid complexity");
}
}
StreamSQLResult newCacheEntry = new StreamSQLResult(duplicated, ts, partitionColRef);
- CACHE_MANAGER.getCache(this.underlyingStorage.getStorageUUID()).put(new Element(streamSQLDigest, newCacheEntry));
+ CACHE_MANAGER.getCache(this.underlyingStorage.getStorageUUID()).put(new Element(streamSQLDigest.hashCode(), newCacheEntry));
logger.info("cache after the query: " + newCacheEntry);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/15ef5b8d/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
index 4082c74..60b8a1b 100644
--- a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
+++ b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
@@ -30,7 +30,7 @@ public class CacheFledgedStaticStorageEngine extends AbstractCacheFledgedStorage
streamSQLDigest = new StreamSQLDigest(sqlDigest, null);
StreamSQLResult cachedResult = null;
Cache cache = CACHE_MANAGER.getCache(this.underlyingStorage.getStorageUUID());
- Element element = cache.get(streamSQLDigest);
+ Element element = cache.get(streamSQLDigest.hashCode());
if (element != null) {
this.queryCacheExists = true;
cachedResult = (StreamSQLResult) element.getObjectValue();
@@ -79,7 +79,7 @@ public class CacheFledgedStaticStorageEngine extends AbstractCacheFledgedStorage
if (cacheIt) {
StreamSQLResult newCacheEntry = new StreamSQLResult(duplicated, Ranges.<Long> all(), null);
- CACHE_MANAGER.getCache(this.underlyingStorage.getStorageUUID()).put(new Element(streamSQLDigest, newCacheEntry));
+ CACHE_MANAGER.getCache(this.underlyingStorage.getStorageUUID()).put(new Element(streamSQLDigest.hashCode(), newCacheEntry));
logger.info("cache after the query: " + newCacheEntry);
}
}
[2/2] incubator-kylin git commit: remove author signature in source
code
Posted by ma...@apache.org.
remove author signature in source code
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/7ca0aaab
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/7ca0aaab
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/7ca0aaab
Branch: refs/heads/0.8
Commit: 7ca0aaab84ae837addd8d17e578751a6e94d04c4
Parents: 2883acf
Author: honma <ho...@ebay.com>
Authored: Wed Jun 17 13:44:32 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Wed Jun 17 16:00:04 2015 +0800
----------------------------------------------------------------------
.../org/apache/kylin/common/cache/CacheUpdater.java | 1 -
.../apache/kylin/common/cache/LocalCacheUpdater.java | 1 -
.../apache/kylin/common/cache/RemoteCacheUpdater.java | 1 -
.../java/org/apache/kylin/common/lock/JobLock.java | 1 -
.../java/org/apache/kylin/common/lock/MockJobLock.java | 1 -
.../org/apache/kylin/common/lock/ZookeeperJobLock.java | 1 -
.../org/apache/kylin/common/util/IdentityUtils.java | 1 -
.../java/org/apache/kylin/common/util/StringUtil.java | 2 --
.../org/apache/kylin/common/util/IdentityUtilTest.java | 1 -
.../java/org/apache/kylin/cube/model/CubeDesc.java | 2 --
.../org/apache/kylin/cube/model/DimensionDesc.java | 2 --
.../org/apache/kylin/cube/model/HBaseColumnDesc.java | 2 --
.../apache/kylin/cube/model/HBaseColumnFamilyDesc.java | 6 ++----
.../org/apache/kylin/cube/model/HBaseMappingDesc.java | 2 --
.../org/apache/kylin/cube/model/HierarchyDesc.java | 2 --
.../java/org/apache/kylin/cube/model/v1/CubeDesc.java | 2 --
.../org/apache/kylin/cube/model/v1/DimensionDesc.java | 2 --
.../model/validation/SourceTableMetadataValidator.java | 2 --
.../org/apache/kylin/metadata/model/ColumnDesc.java | 2 --
.../org/apache/kylin/metadata/model/FunctionDesc.java | 2 --
.../java/org/apache/kylin/metadata/model/JoinDesc.java | 6 ++----
.../org/apache/kylin/metadata/model/MeasureDesc.java | 2 --
.../org/apache/kylin/metadata/model/ParameterDesc.java | 13 +++++--------
.../org/apache/kylin/metadata/model/TableDesc.java | 9 +++------
.../org/apache/kylin/metadata/model/TblColRef.java | 2 --
.../kylin/metadata/tuple/TeeTupleItrListener.java | 1 -
.../org/apache/kylin/metadata/MetadataManagerTest.java | 9 +++------
.../apache/kylin/rest/controller/BasicController.java | 11 ++++-------
.../apache/kylin/rest/security/AclHBaseStorage.java | 1 -
.../kylin/rest/security/MockAclHBaseStorage.java | 1 -
.../kylin/rest/security/RealAclHBaseStorage.java | 1 -
.../apache/kylin/storage/ICachableStorageEngine.java | 1 -
.../cache/AbstractCacheFledgedStorageEngine.java | 1 -
.../cache/CacheFledgedDynamicStorageEngine.java | 1 -
.../storage/cache/CacheFledgedStaticStorageEngine.java | 3 ---
.../apache/kylin/storage/test/DynamicCacheTest.java | 1 -
.../org/apache/kylin/storage/test/StaticCacheTest.java | 1 -
.../apache/kylin/storage/test/StorageMockUtils.java | 1 -
38 files changed, 19 insertions(+), 82 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/cache/CacheUpdater.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/cache/CacheUpdater.java b/common/src/main/java/org/apache/kylin/common/cache/CacheUpdater.java
index 85fdf8f..186fd42 100644
--- a/common/src/main/java/org/apache/kylin/common/cache/CacheUpdater.java
+++ b/common/src/main/java/org/apache/kylin/common/cache/CacheUpdater.java
@@ -4,7 +4,6 @@ import org.apache.kylin.common.restclient.AbstractRestCache;
import org.apache.kylin.common.restclient.Broadcaster;
/**
- * Created by Hongbin Ma(Binmahone) on 6/1/15.
*/
public interface CacheUpdater {
void updateCache(Object key, Object value, Broadcaster.EVENT syncAction, Broadcaster.TYPE type, AbstractRestCache cache);
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/cache/LocalCacheUpdater.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/cache/LocalCacheUpdater.java b/common/src/main/java/org/apache/kylin/common/cache/LocalCacheUpdater.java
index 647623d..8f629e3 100644
--- a/common/src/main/java/org/apache/kylin/common/cache/LocalCacheUpdater.java
+++ b/common/src/main/java/org/apache/kylin/common/cache/LocalCacheUpdater.java
@@ -4,7 +4,6 @@ import org.apache.kylin.common.restclient.AbstractRestCache;
import org.apache.kylin.common.restclient.Broadcaster;
/**
- * Created by Hongbin Ma(Binmahone) on 6/1/15.
*/
public class LocalCacheUpdater implements CacheUpdater {
@Override
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/cache/RemoteCacheUpdater.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/cache/RemoteCacheUpdater.java b/common/src/main/java/org/apache/kylin/common/cache/RemoteCacheUpdater.java
index 8419f75..2a5e59a 100644
--- a/common/src/main/java/org/apache/kylin/common/cache/RemoteCacheUpdater.java
+++ b/common/src/main/java/org/apache/kylin/common/cache/RemoteCacheUpdater.java
@@ -4,7 +4,6 @@ import org.apache.kylin.common.restclient.AbstractRestCache;
import org.apache.kylin.common.restclient.Broadcaster;
/**
- * Created by Hongbin Ma(Binmahone) on 6/1/15.
*/
public class RemoteCacheUpdater implements CacheUpdater {
@Override
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/lock/JobLock.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/lock/JobLock.java b/common/src/main/java/org/apache/kylin/common/lock/JobLock.java
index 5293385..7fdb64c 100644
--- a/common/src/main/java/org/apache/kylin/common/lock/JobLock.java
+++ b/common/src/main/java/org/apache/kylin/common/lock/JobLock.java
@@ -1,7 +1,6 @@
package org.apache.kylin.common.lock;
/**
- * Created by Hongbin Ma(Binmahone) on 5/26/15.
*/
public interface JobLock {
boolean lock();
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/lock/MockJobLock.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/lock/MockJobLock.java b/common/src/main/java/org/apache/kylin/common/lock/MockJobLock.java
index 9285fd2..230d4d8 100644
--- a/common/src/main/java/org/apache/kylin/common/lock/MockJobLock.java
+++ b/common/src/main/java/org/apache/kylin/common/lock/MockJobLock.java
@@ -1,7 +1,6 @@
package org.apache.kylin.common.lock;
/**
- * Created by Hongbin Ma(Binmahone) on 5/26/15.
*/
public class MockJobLock implements JobLock {
@Override
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/lock/ZookeeperJobLock.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/lock/ZookeeperJobLock.java b/common/src/main/java/org/apache/kylin/common/lock/ZookeeperJobLock.java
index 78da480..603894c 100644
--- a/common/src/main/java/org/apache/kylin/common/lock/ZookeeperJobLock.java
+++ b/common/src/main/java/org/apache/kylin/common/lock/ZookeeperJobLock.java
@@ -17,7 +17,6 @@ import org.slf4j.LoggerFactory;
import java.util.concurrent.TimeUnit;
/**
- * Created by Hongbin Ma(Binmahone) on 5/26/15.
*/
public class ZookeeperJobLock implements JobLock {
private Logger logger = LoggerFactory.getLogger(ZookeeperJobLock.class);
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/util/IdentityUtils.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/util/IdentityUtils.java b/common/src/main/java/org/apache/kylin/common/util/IdentityUtils.java
index d0691da..d873959 100644
--- a/common/src/main/java/org/apache/kylin/common/util/IdentityUtils.java
+++ b/common/src/main/java/org/apache/kylin/common/util/IdentityUtils.java
@@ -4,7 +4,6 @@ import java.util.Collection;
import java.util.IdentityHashMap;
/**
- * Created by Hongbin Ma(Binmahone) on 5/14/15.
*/
public class IdentityUtils {
public static <K> boolean collectionReferenceEquals(Collection<K> collectionA, Collection<K> collectionB) {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/main/java/org/apache/kylin/common/util/StringUtil.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/util/StringUtil.java b/common/src/main/java/org/apache/kylin/common/util/StringUtil.java
index f4aed14..9cd5164 100644
--- a/common/src/main/java/org/apache/kylin/common/util/StringUtil.java
+++ b/common/src/main/java/org/apache/kylin/common/util/StringUtil.java
@@ -22,8 +22,6 @@ import java.util.ArrayList;
import java.util.Collection;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 12/2/13 Time: 11:43 AM To
- * change this template use File | Settings | File Templates.
*/
public class StringUtil {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/common/src/test/java/org/apache/kylin/common/util/IdentityUtilTest.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/kylin/common/util/IdentityUtilTest.java b/common/src/test/java/org/apache/kylin/common/util/IdentityUtilTest.java
index 99385f6..7e802a4 100644
--- a/common/src/test/java/org/apache/kylin/common/util/IdentityUtilTest.java
+++ b/common/src/test/java/org/apache/kylin/common/util/IdentityUtilTest.java
@@ -8,7 +8,6 @@ import org.junit.Test;
import java.util.List;
/**
- * Created by Hongbin Ma(Binmahone) on 5/14/15.
*/
public class IdentityUtilTest {
@Test
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
index a5bec21..2f96ceb 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
@@ -62,8 +62,6 @@ import org.apache.kylin.metadata.model.TableDesc;
import org.apache.kylin.metadata.model.TblColRef;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 10:40 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class CubeDesc extends RootPersistentEntity {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/DimensionDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/DimensionDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/DimensionDesc.java
index 85fe45b..6a189b7 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/DimensionDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/DimensionDesc.java
@@ -33,8 +33,6 @@ import org.apache.kylin.metadata.model.TableDesc;
import org.apache.kylin.metadata.model.TblColRef;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 10:40 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class DimensionDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnDesc.java
index 0ded680..793bf06 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnDesc.java
@@ -27,8 +27,6 @@ import org.apache.kylin.metadata.model.MeasureDesc;
import org.apache.kylin.metadata.model.FunctionDesc;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/30/13 Time: 10:57 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class HBaseColumnDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnFamilyDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnFamilyDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnFamilyDesc.java
index 0e6f60d..2497ccf 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnFamilyDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/HBaseColumnFamilyDesc.java
@@ -18,15 +18,13 @@
package org.apache.kylin.cube.model;
-import java.util.Arrays;
-
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility;
import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.Arrays;
+
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/30/13 Time: 10:41 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class HBaseColumnFamilyDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/HBaseMappingDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/HBaseMappingDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/HBaseMappingDesc.java
index f7eb20e..477d276 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/HBaseMappingDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/HBaseMappingDesc.java
@@ -30,8 +30,6 @@ import org.apache.kylin.metadata.model.MeasureDesc;
import org.apache.kylin.metadata.model.FunctionDesc;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 10:44 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class HBaseMappingDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/HierarchyDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/HierarchyDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/HierarchyDesc.java
index 588c2f3..c0c941b 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/HierarchyDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/HierarchyDesc.java
@@ -24,8 +24,6 @@ import com.fasterxml.jackson.annotation.JsonProperty;
import org.apache.kylin.metadata.model.TblColRef;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 10:46 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class HierarchyDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/v1/CubeDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/v1/CubeDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/v1/CubeDesc.java
index 1564899..82cc2cd 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/v1/CubeDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/v1/CubeDesc.java
@@ -64,8 +64,6 @@ import org.apache.kylin.metadata.model.TableDesc;
import org.apache.kylin.metadata.model.TblColRef;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 10:40 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class CubeDesc extends RootPersistentEntity {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/v1/DimensionDesc.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/v1/DimensionDesc.java b/cube/src/main/java/org/apache/kylin/cube/model/v1/DimensionDesc.java
index da0d0fa..11cb355 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/v1/DimensionDesc.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/v1/DimensionDesc.java
@@ -31,8 +31,6 @@ import org.apache.kylin.metadata.model.TableDesc;
import org.apache.kylin.metadata.model.TblColRef;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 10:40 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class DimensionDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/cube/src/main/java/org/apache/kylin/cube/model/validation/SourceTableMetadataValidator.java
----------------------------------------------------------------------
diff --git a/cube/src/main/java/org/apache/kylin/cube/model/validation/SourceTableMetadataValidator.java b/cube/src/main/java/org/apache/kylin/cube/model/validation/SourceTableMetadataValidator.java
index 54e9d76..e2fc505 100644
--- a/cube/src/main/java/org/apache/kylin/cube/model/validation/SourceTableMetadataValidator.java
+++ b/cube/src/main/java/org/apache/kylin/cube/model/validation/SourceTableMetadataValidator.java
@@ -23,8 +23,6 @@ import org.apache.kylin.metadata.model.TableDesc;
/**
* Validate Table metadata from source.
* <p/>
- * User: lukhan Date: 12/2/13 Time: 10:45 AM To change this template use File |
- * Settings | File Templates.
*/
public class SourceTableMetadataValidator {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/model/ColumnDesc.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/model/ColumnDesc.java b/metadata/src/main/java/org/apache/kylin/metadata/model/ColumnDesc.java
index 203d304..11564d2 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/model/ColumnDesc.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/model/ColumnDesc.java
@@ -29,8 +29,6 @@ import com.fasterxml.jackson.annotation.JsonProperty;
/**
* Column Metadata from Source. All name should be uppercase.
* <p/>
- * User: lukhan Date: 10/15/13 Time: 9:07 AM To change this template use File |
- * Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class ColumnDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/model/FunctionDesc.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/model/FunctionDesc.java b/metadata/src/main/java/org/apache/kylin/metadata/model/FunctionDesc.java
index 7c85a08..ab4d1cc 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/model/FunctionDesc.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/model/FunctionDesc.java
@@ -25,8 +25,6 @@ import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Collection;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/26/13 Time: 1:30 PM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class FunctionDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/model/JoinDesc.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/model/JoinDesc.java b/metadata/src/main/java/org/apache/kylin/metadata/model/JoinDesc.java
index a2d6176..da907b9 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/model/JoinDesc.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/model/JoinDesc.java
@@ -18,15 +18,13 @@
package org.apache.kylin.metadata.model;
-import java.util.Arrays;
-
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility;
import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.Arrays;
+
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 10/14/13 Time: 2:16 PM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class JoinDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/model/MeasureDesc.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/model/MeasureDesc.java b/metadata/src/main/java/org/apache/kylin/metadata/model/MeasureDesc.java
index ee4a972..e05ecf5 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/model/MeasureDesc.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/model/MeasureDesc.java
@@ -23,8 +23,6 @@ import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility;
import com.fasterxml.jackson.annotation.JsonProperty;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 10:41 AM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/model/ParameterDesc.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/model/ParameterDesc.java b/metadata/src/main/java/org/apache/kylin/metadata/model/ParameterDesc.java
index dd73558..14a073f 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/model/ParameterDesc.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/model/ParameterDesc.java
@@ -18,19 +18,16 @@
package org.apache.kylin.metadata.model;
-import java.io.UnsupportedEncodingException;
-import java.util.Arrays;
-import java.util.List;
-
-import org.apache.hadoop.util.StringUtils;
-
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility;
import com.fasterxml.jackson.annotation.JsonProperty;
+import org.apache.hadoop.util.StringUtils;
+
+import java.io.UnsupportedEncodingException;
+import java.util.Arrays;
+import java.util.List;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/30/13 Time: 2:46 PM To
- * change this template use File | Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class ParameterDesc {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/model/TableDesc.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/model/TableDesc.java b/metadata/src/main/java/org/apache/kylin/metadata/model/TableDesc.java
index 95a1d81..4bc9df3 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/model/TableDesc.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/model/TableDesc.java
@@ -18,9 +18,6 @@
package org.apache.kylin.metadata.model;
-import java.util.Arrays;
-import java.util.Comparator;
-
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility;
import com.fasterxml.jackson.annotation.JsonProperty;
@@ -28,11 +25,11 @@ import org.apache.kylin.common.persistence.ResourceStore;
import org.apache.kylin.common.persistence.RootPersistentEntity;
import org.apache.kylin.common.util.StringSplitter;
+import java.util.Arrays;
+import java.util.Comparator;
+
/**
* Table Metadata from Source. All name should be uppercase.
- * <p/>
- * User: lukhan Date: 10/15/13 Time: 9:06 AM To change this template use File |
- * Settings | File Templates.
*/
@JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class TableDesc extends RootPersistentEntity {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/model/TblColRef.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/model/TblColRef.java b/metadata/src/main/java/org/apache/kylin/metadata/model/TblColRef.java
index cbc6ce5..caac52a 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/model/TblColRef.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/model/TblColRef.java
@@ -21,8 +21,6 @@ package org.apache.kylin.metadata.model;
import org.apache.commons.lang.StringUtils;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/26/13 Time: 1:30 PM To
- * change this template use File | Settings | File Templates.
*/
public class TblColRef {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/main/java/org/apache/kylin/metadata/tuple/TeeTupleItrListener.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/tuple/TeeTupleItrListener.java b/metadata/src/main/java/org/apache/kylin/metadata/tuple/TeeTupleItrListener.java
index 5bf86df..dfc2625 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/tuple/TeeTupleItrListener.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/tuple/TeeTupleItrListener.java
@@ -3,7 +3,6 @@ package org.apache.kylin.metadata.tuple;
import java.util.List;
/**
- * Created by Hongbin Ma(Binmahone) on 5/13/15.
*/
public interface TeeTupleItrListener {
void notify(List<ITuple> duplicated,long createTime);
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/metadata/src/test/java/org/apache/kylin/metadata/MetadataManagerTest.java
----------------------------------------------------------------------
diff --git a/metadata/src/test/java/org/apache/kylin/metadata/MetadataManagerTest.java b/metadata/src/test/java/org/apache/kylin/metadata/MetadataManagerTest.java
index 3b65d97..e8fcad9 100644
--- a/metadata/src/test/java/org/apache/kylin/metadata/MetadataManagerTest.java
+++ b/metadata/src/test/java/org/apache/kylin/metadata/MetadataManagerTest.java
@@ -18,8 +18,7 @@
package org.apache.kylin.metadata;
-import java.util.List;
-
+import org.apache.kylin.common.util.LocalFileMetadataTestCase;
import org.apache.kylin.metadata.model.DataModelDesc;
import org.apache.kylin.metadata.model.TableDesc;
import org.junit.After;
@@ -27,13 +26,11 @@ import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
-import org.apache.kylin.common.util.LocalFileMetadataTestCase;
+import java.util.List;
-import static org.apache.kylin.metadata.MetadataManager.*;
+import static org.apache.kylin.metadata.MetadataManager.getInstance;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/24/13 Time: 2:38 PM To
- * change this template use File | Settings | File Templates.
*/
public class MetadataManagerTest extends LocalFileMetadataTestCase {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/server/src/main/java/org/apache/kylin/rest/controller/BasicController.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/kylin/rest/controller/BasicController.java b/server/src/main/java/org/apache/kylin/rest/controller/BasicController.java
index bb91ff7..3a6c530 100644
--- a/server/src/main/java/org/apache/kylin/rest/controller/BasicController.java
+++ b/server/src/main/java/org/apache/kylin/rest/controller/BasicController.java
@@ -18,10 +18,11 @@
package org.apache.kylin.rest.controller;
-import javax.servlet.http.HttpServletRequest;
-
+import org.apache.kylin.rest.exception.BadRequestException;
import org.apache.kylin.rest.exception.ForbiddenException;
+import org.apache.kylin.rest.exception.NotFoundException;
import org.apache.kylin.rest.response.ErrorResponse;
+import org.apache.kylin.rest.service.MetricsService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -30,13 +31,9 @@ import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.ResponseStatus;
-import org.apache.kylin.rest.exception.BadRequestException;
-import org.apache.kylin.rest.exception.NotFoundException;
-import org.apache.kylin.rest.service.MetricsService;
+import javax.servlet.http.HttpServletRequest;
/**
- * Created with IntelliJ IDEA. User: lukhan Date: 9/1/13 Time: 10:54 PM To
- * change this template use File | Settings | File Templates.
*/
public class BasicController {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/server/src/main/java/org/apache/kylin/rest/security/AclHBaseStorage.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/kylin/rest/security/AclHBaseStorage.java b/server/src/main/java/org/apache/kylin/rest/security/AclHBaseStorage.java
index 12cfc68..edddba1 100644
--- a/server/src/main/java/org/apache/kylin/rest/security/AclHBaseStorage.java
+++ b/server/src/main/java/org/apache/kylin/rest/security/AclHBaseStorage.java
@@ -5,7 +5,6 @@ import org.apache.hadoop.hbase.client.HTableInterface;
import java.io.IOException;
/**
- * Created by Hongbin Ma(Binmahone) on 5/19/15.
*/
public interface AclHBaseStorage {
String DEFAULT_TABLE_PREFIX = "kylin_metadata";
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/server/src/main/java/org/apache/kylin/rest/security/MockAclHBaseStorage.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/kylin/rest/security/MockAclHBaseStorage.java b/server/src/main/java/org/apache/kylin/rest/security/MockAclHBaseStorage.java
index f9c9e0c..1309510 100644
--- a/server/src/main/java/org/apache/kylin/rest/security/MockAclHBaseStorage.java
+++ b/server/src/main/java/org/apache/kylin/rest/security/MockAclHBaseStorage.java
@@ -9,7 +9,6 @@ import org.h2.util.StringUtils;
import java.io.IOException;
/**
- * Created by Hongbin Ma(Binmahone) on 5/19/15.
*/
public class MockAclHBaseStorage implements AclHBaseStorage {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/server/src/main/java/org/apache/kylin/rest/security/RealAclHBaseStorage.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/kylin/rest/security/RealAclHBaseStorage.java b/server/src/main/java/org/apache/kylin/rest/security/RealAclHBaseStorage.java
index 44e6f8f..553e157 100644
--- a/server/src/main/java/org/apache/kylin/rest/security/RealAclHBaseStorage.java
+++ b/server/src/main/java/org/apache/kylin/rest/security/RealAclHBaseStorage.java
@@ -10,7 +10,6 @@ import org.h2.util.StringUtils;
import java.io.IOException;
/**
- * Created by Hongbin Ma(Binmahone) on 5/19/15.
*/
public class RealAclHBaseStorage implements AclHBaseStorage {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/storage/src/main/java/org/apache/kylin/storage/ICachableStorageEngine.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/ICachableStorageEngine.java b/storage/src/main/java/org/apache/kylin/storage/ICachableStorageEngine.java
index e38350a..90c5c95 100644
--- a/storage/src/main/java/org/apache/kylin/storage/ICachableStorageEngine.java
+++ b/storage/src/main/java/org/apache/kylin/storage/ICachableStorageEngine.java
@@ -3,7 +3,6 @@ package org.apache.kylin.storage;
import com.google.common.collect.Range;
/**
- * Created by Hongbin Ma(Binmahone) on 5/14/15.
*/
public interface ICachableStorageEngine extends IStorageEngine {
/**
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java b/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
index 44e2033..441d7dc 100644
--- a/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
+++ b/storage/src/main/java/org/apache/kylin/storage/cache/AbstractCacheFledgedStorageEngine.java
@@ -16,7 +16,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Created by Hongbin Ma(Binmahone) on 5/13/15.
*/
public abstract class AbstractCacheFledgedStorageEngine implements IStorageEngine, TeeTupleItrListener {
private static final Logger logger = LoggerFactory.getLogger(AbstractCacheFledgedStorageEngine.class);
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
index d54c5e5..734a2dd 100644
--- a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
+++ b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedDynamicStorageEngine.java
@@ -22,7 +22,6 @@ import org.slf4j.LoggerFactory;
import java.util.List;
/**
- * Created by Hongbin Ma(Binmahone) on 5/11/15.
*/
public class CacheFledgedDynamicStorageEngine extends AbstractCacheFledgedStorageEngine {
private static final Logger logger = LoggerFactory.getLogger(CacheFledgedDynamicStorageEngine.class);
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
index 7a2b483..4082c74 100644
--- a/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
+++ b/storage/src/main/java/org/apache/kylin/storage/cache/CacheFledgedStaticStorageEngine.java
@@ -17,9 +17,6 @@ import org.slf4j.LoggerFactory;
import java.util.List;
-/**
- * Created by Hongbin Ma(Binmahone) on 5/11/15.
- */
public class CacheFledgedStaticStorageEngine extends AbstractCacheFledgedStorageEngine {
private static final Logger logger = LoggerFactory.getLogger(CacheFledgedStaticStorageEngine.class);
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/storage/src/test/java/org/apache/kylin/storage/test/DynamicCacheTest.java
----------------------------------------------------------------------
diff --git a/storage/src/test/java/org/apache/kylin/storage/test/DynamicCacheTest.java b/storage/src/test/java/org/apache/kylin/storage/test/DynamicCacheTest.java
index 3b587f1..3814902 100644
--- a/storage/src/test/java/org/apache/kylin/storage/test/DynamicCacheTest.java
+++ b/storage/src/test/java/org/apache/kylin/storage/test/DynamicCacheTest.java
@@ -26,7 +26,6 @@ import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
/**
- * Created by Hongbin Ma(Binmahone) on 5/14/15.
*/
public class DynamicCacheTest {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/storage/src/test/java/org/apache/kylin/storage/test/StaticCacheTest.java
----------------------------------------------------------------------
diff --git a/storage/src/test/java/org/apache/kylin/storage/test/StaticCacheTest.java b/storage/src/test/java/org/apache/kylin/storage/test/StaticCacheTest.java
index 11fb70b..112f612 100644
--- a/storage/src/test/java/org/apache/kylin/storage/test/StaticCacheTest.java
+++ b/storage/src/test/java/org/apache/kylin/storage/test/StaticCacheTest.java
@@ -24,7 +24,6 @@ import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
/**
- * Created by Hongbin Ma(Binmahone) on 5/14/15.
*/
public class StaticCacheTest {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7ca0aaab/storage/src/test/java/org/apache/kylin/storage/test/StorageMockUtils.java
----------------------------------------------------------------------
diff --git a/storage/src/test/java/org/apache/kylin/storage/test/StorageMockUtils.java b/storage/src/test/java/org/apache/kylin/storage/test/StorageMockUtils.java
index d6a6da1..a2a540e 100644
--- a/storage/src/test/java/org/apache/kylin/storage/test/StorageMockUtils.java
+++ b/storage/src/test/java/org/apache/kylin/storage/test/StorageMockUtils.java
@@ -9,7 +9,6 @@ import java.util.ArrayList;
import java.util.List;
/**
- * Created by Hongbin Ma(Binmahone) on 5/14/15.
*/
public class StorageMockUtils {
public static TupleInfo newTupleInfo(List<TblColRef> groups, List<FunctionDesc> aggregations) {