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 2016/06/25 11:12:19 UTC
[18/18] kylin git commit: KYLIN-1821 Reformat all of the java files
and enable checkstyle to enforce code formatting
KYLIN-1821 Reformat all of the java files and enable checkstyle to enforce code formatting
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5d4982e2
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5d4982e2
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5d4982e2
Branch: refs/heads/master
Commit: 5d4982e247a2172d97d44c85309cef4b3dbfce09
Parents: f26f702
Author: Hongbin Ma <ma...@apache.org>
Authored: Fri Jun 24 16:19:05 2016 +0800
Committer: Hongbin Ma <ma...@apache.org>
Committed: Sat Jun 25 19:10:05 2016 +0800
----------------------------------------------------------------------
.../.settings/org.eclipse.core.resources.prefs | 5 +
assembly/.settings/org.eclipse.jdt.core.prefs | 379 +
assembly/.settings/org.eclipse.jdt.ui.prefs | 7 +
.../kylin/job/DeployLocalMetaToRemoteTest.java | 1 -
.../java/org/apache/kylin/job/DeployUtil.java | 6 +-
.../kylin/job/hadoop/invertedindex/IITest.java | 13 +-
.../kylin/job/streaming/KafkaDataLoader.java | 8 +-
.../streaming/StreamingTableDataGenerator.java | 1 +
.../calcite/sql2rel/SqlToRelConverter.java | 8302 ++++++++---------
checkstyle-suppressions.xml | 37 +
checkstyle.xml | 60 +
.../org/apache/kylin/common/KylinConfig.java | 32 +-
.../common/persistence/FileResourceStore.java | 2 +-
.../common/persistence/JsonSerializer.java | 2 +-
.../persistence/RootPersistentEntity.java | 13 -
.../common/restclient/AbstractRestCache.java | 2 +-
.../kylin/common/restclient/Broadcaster.java | 2 +-
.../common/restclient/SingleValueCache.java | 6 +-
.../apache/kylin/common/util/BytesSplitter.java | 15 +-
.../org/apache/kylin/common/util/BytesUtil.java | 4 +-
.../apache/kylin/common/util/Dictionary.java | 6 +-
.../kylin/common/util/ImmutableBitSet.java | 2 +-
.../kylin/common/util/ImplementationSwitch.java | 5 +-
.../common/util/LoggableCachedThreadPool.java | 4 +-
.../common/util/MemoryBudgetController.java | 3 +-
.../kylin/common/util/MyLogFormatter.java | 1 +
.../org/apache/kylin/common/util/Primes.java | 31 +-
.../org/apache/kylin/common/util/RangeUtil.java | 6 +-
.../org/apache/kylin/common/util/SSHClient.java | 13 +-
.../apache/kylin/common/util/StringUtil.java | 4 +-
.../apache/kylin/common/KylinConfigTest.java | 3 +-
.../common/persistence/ResourceStoreTest.java | 18 +-
.../common/util/AbstractKylinTestCase.java | 1 -
.../kylin/common/util/DateFormatTest.java | 5 +-
.../common/util/HBaseMetadataTestCase.java | 3 +-
.../apache/kylin/common/util/RangeUtilTest.java | 1 -
.../org/apache/kylin/cube/CubeInstance.java | 3 +-
.../java/org/apache/kylin/cube/CubeSegment.java | 13 +-
.../org/apache/kylin/cube/CubeValidator.java | 2 +-
.../kylin/cube/cli/CubeSignatureRefresher.java | 4 +-
.../kylin/cube/cli/DictionaryGeneratorCLI.java | 4 +-
.../kylin/cube/common/RowKeySplitter.java | 1 -
.../org/apache/kylin/cube/cuboid/Cuboid.java | 5 +-
.../kylin/cube/gridtable/CubeGridTable.java | 2 +-
.../gridtable/CuboidToGridTableMapping.java | 12 +-
.../kylin/cube/gridtable/TrimmedDimEnc.java | 6 +-
.../gridtable/TrimmedDimensionSerializer.java | 4 +-
.../inmemcubing/AbstractInMemCubeBuilder.java | 2 +-
.../cube/inmemcubing/CompoundCuboidWriter.java | 4 +-
.../cube/inmemcubing/ConcurrentDiskStore.java | 4 +-
.../kylin/cube/inmemcubing/ICuboidWriter.java | 6 +-
.../cube/inmemcubing/InMemCubeBuilder.java | 6 +-
.../InMemCubeBuilderInputConverter.java | 23 +-
.../cube/inmemcubing/InMemCubeBuilderUtils.java | 4 +-
.../kylin/cube/inmemcubing/MemDiskStore.java | 4 +-
.../kylin/cube/model/AggregationGroup.java | 3 +-
.../org/apache/kylin/cube/model/CubeDesc.java | 23 +-
.../apache/kylin/cube/model/DictionaryDesc.java | 12 +-
.../apache/kylin/cube/model/DimensionDesc.java | 2 +-
.../kylin/cube/model/HBaseColumnDesc.java | 4 +-
.../apache/kylin/cube/model/RowKeyColDesc.java | 3 +-
.../org/apache/kylin/cube/model/RowKeyDesc.java | 5 +-
.../kylin/cube/model/v1_4_0/CubeDesc.java | 12 +-
.../cube/model/v1_4_0/HBaseColumnDesc.java | 4 +-
.../model/v1_4_0/HBaseColumnFamilyDesc.java | 1 -
.../kylin/cube/model/v1_4_0/RowKeyDesc.java | 4 +-
.../model/validation/CubeMetadataValidator.java | 2 +-
.../cube/model/validation/IValidatorRule.java | 5 +-
.../model/validation/rule/DictionaryRule.java | 11 +-
.../model/validation/rule/FunctionRule.java | 3 +-
.../rule/IKylinValidationConstants.java | 28 -
.../common/MetadataVersionRefresher.java | 1 +
.../v1_4_0/CubeMetadataUpgrade_v_1_4_0.java | 2 -
.../kylin/gridtable/GTAggregateScanner.java | 6 +-
.../apache/kylin/gridtable/GTFilterScanner.java | 12 +-
.../java/org/apache/kylin/gridtable/GTInfo.java | 17 +-
.../gridtable/GTInvertedIndexOfColumn.java | 1 +
.../org/apache/kylin/gridtable/GTRecord.java | 2 -
.../org/apache/kylin/gridtable/GTScanRange.java | 2 +-
.../kylin/gridtable/GTScanRangePlanner.java | 15 +-
.../apache/kylin/gridtable/IGTCodeSystem.java | 2 +-
.../apache/kylin/gridtable/UnitTestSupport.java | 12 +-
.../gridtable/benchmark/GTScannerBenchmark.java | 20 +-
.../benchmark/GTScannerBenchmark2.java | 20 +-
.../benchmark/SortedGTRecordGenerator.java | 10 +-
.../org/apache/kylin/cube/CubeDescTest.java | 46 +-
.../org/apache/kylin/cube/CubeManagerTest.java | 11 +-
.../org/apache/kylin/cube/CubeSegmentsTest.java | 7 +-
.../kylin/cube/CubeSpecificConfigTest.java | 2 +-
.../kylin/cube/cuboid/CuboidSchedulerTest.java | 2 +-
.../apache/kylin/cube/cuboid/CuboidTest.java | 6 +-
.../cube/inmemcubing/MemDiskStoreTest.java | 2 +-
.../validation/rule/DictionaryRuleTest.java | 26 +-
.../gridtable/AggregationCacheMemSizeTest.java | 2 +-
.../gridtable/AggregationCacheSpillTest.java | 3 +-
.../kylin/gridtable/SimpleGridTableTest.java | 4 +-
.../gridtable/SimpleInvertedIndexTest.java | 5 +-
.../metadata/measure/MeasureCodecTest.java | 9 +-
.../metadata/measure/TopNMeasureTypeTest.java | 8 +-
.../apache/kylin/dict/AppendTrieDictionary.java | 79 +-
.../kylin/dict/BuildInFunctionTransformer.java | 2 +-
.../org/apache/kylin/dict/CachedTreeMap.java | 39 +-
.../apache/kylin/dict/DateStrDictionary.java | 4 +-
.../apache/kylin/dict/DictionaryGenerator.java | 8 +-
.../apache/kylin/dict/DictionaryManager.java | 31 +-
.../kylin/dict/GlobalDictionaryBuilder.java | 11 +-
.../dict/MultipleDictionaryValueEnumerator.java | 6 +-
.../kylin/dict/TableColumnValueEnumerator.java | 6 +-
.../apache/kylin/dict/TimeStrDictionary.java | 9 +-
.../org/apache/kylin/dict/TrieDictionary.java | 36 +-
.../kylin/dict/TrieDictionaryBuilder.java | 4 +-
.../kylin/dict/lookup/LookupStringTable.java | 18 +-
.../apache/kylin/dict/lookup/LookupTable.java | 12 +-
.../kylin/dict/lookup/SnapshotManager.java | 1 -
.../kylin/dict/AppendTrieDictionaryTest.java | 58 +-
.../apache/kylin/dict/NumberDictionaryTest.java | 13 +-
.../kylin/dict/lookup/LookupTableTest.java | 6 +-
.../java/org/apache/kylin/job/JobInstance.java | 1 +
.../org/apache/kylin/job/JoinedFlatTable.java | 3 -
.../org/apache/kylin/job/SchedulerFactory.java | 4 +-
.../kylin/job/common/ShellExecutable.java | 3 +-
.../kylin/job/dao/ExecutableOutputPO.java | 1 +
.../org/apache/kylin/job/dao/ExecutablePO.java | 1 +
.../kylin/job/engine/JobEngineConfig.java | 3 +-
.../kylin/job/execution/AbstractExecutable.java | 2 -
.../job/impl/threadpool/DefaultScheduler.java | 3 +-
.../kylin/dimension/AbstractDateDimEnc.java | 2 +-
.../kylin/dimension/DimensionEncoding.java | 12 +-
.../dimension/DimensionEncodingFactory.java | 4 +-
.../apache/kylin/dimension/FixedLenDimEnc.java | 8 +-
.../kylin/dimension/IDimensionEncodingMap.java | 4 +-
.../apache/kylin/dimension/IntegerDimEnc.java | 9 +-
.../kylin/measure/BufferedMeasureEncoder.java | 6 +-
.../apache/kylin/measure/MeasureAggregator.java | 6 +-
.../kylin/measure/MeasureAggregators.java | 2 +-
.../apache/kylin/measure/MeasureIngester.java | 6 +-
.../org/apache/kylin/measure/MeasureType.java | 36 +-
.../kylin/measure/basic/BasicMeasureType.java | 6 +-
.../kylin/measure/basic/BigDecimalIngester.java | 2 +-
.../kylin/measure/basic/DoubleIngester.java | 4 +-
.../kylin/measure/basic/LongIngester.java | 4 +-
.../kylin/measure/bitmap/BitmapCounter.java | 28 +-
.../bitmap/BitmapDistinctCountAggFunc.java | 46 +-
.../kylin/measure/bitmap/BitmapMeasureType.java | 12 +-
.../kylin/measure/bitmap/BitmapSerializer.java | 6 +-
.../dim/DimCountDistinctMeasureType.java | 2 +-
.../ExtendedColumnMeasureType.java | 1 -
.../measure/hllc/HyperLogLogPlusCounter.java | 4 +-
.../measure/hllc/HyperLogLogPlusTable.java | 14 +-
.../apache/kylin/measure/raw/RawAggregator.java | 10 +-
.../kylin/measure/raw/RawMeasureType.java | 11 +-
.../apache/kylin/measure/raw/RawSerializer.java | 10 +-
.../org/apache/kylin/measure/topn/Counter.java | 16 +-
.../measure/topn/DoubleDeltaSerializer.java | 19 +-
.../kylin/measure/topn/DoublyLinkedList.java | 5 +-
.../apache/kylin/measure/topn/TopNCounter.java | 36 +-
.../kylin/measure/topn/TopNMeasureType.java | 28 +-
.../kylin/metadata/MetadataConstants.java | 2 -
.../kylin/metadata/badquery/BadQueryEntry.java | 7 +
.../kylin/metadata/datatype/DataType.java | 5 +-
.../metadata/datatype/DataTypeSerializer.java | 6 +-
.../metadata/datatype/DateTimeSerializer.java | 2 +-
.../filter/BuildInFunctionTupleFilter.java | 1 -
.../metadata/filter/ColumnTupleFilter.java | 2 +-
.../metadata/filter/CompareTupleFilter.java | 1 -
.../kylin/metadata/filter/TupleFilter.java | 2 +-
.../metadata/filter/function/Functions.java | 2 +-
.../kylin/metadata/filter/function/Like.java | 127 +-
.../apache/kylin/metadata/model/ColumnDesc.java | 6 +-
.../kylin/metadata/model/DataModelDesc.java | 23 +-
.../metadata/model/ExternalFilterDesc.java | 1 -
.../kylin/metadata/model/FunctionDesc.java | 11 +-
.../kylin/metadata/model/IEngineAware.java | 2 +-
.../kylin/metadata/model/IStorageAware.java | 2 +-
.../kylin/metadata/model/MeasureDesc.java | 9 +-
.../kylin/metadata/model/ParameterDesc.java | 19 +-
.../kylin/metadata/model/PartitionDesc.java | 4 +-
.../apache/kylin/metadata/model/TableDesc.java | 2 +-
.../kylin/metadata/project/ProjectInstance.java | 8 +-
.../metadata/realization/CapabilityResult.java | 12 +-
.../metadata/realization/IRealization.java | 2 +-
.../realization/IRealizationConstants.java | 4 +-
.../realization/IRealizationSegment.java | 8 +-
.../org/apache/kylin/metadata/tuple/Tuple.java | 8 +-
.../apache/kylin/dimension/DateDimEncTest.java | 2 +-
.../apache/kylin/dimension/TimeDimEncTest.java | 4 +-
.../measure/bitmap/BitmapAggregatorTest.java | 4 +-
.../kylin/measure/bitmap/BitmapCounterTest.java | 4 +-
.../measure/bitmap/BitmapSerializerTest.java | 2 +-
.../measure/hll/HyperLogLogCounterTest.java | 3 +-
.../kylin/measure/raw/RawAggregatorTest.java | 2 +-
.../kylin/measure/raw/RawSerializerTest.java | 2 +-
.../measure/topn/DoubleDeltaSerializerTest.java | 3 +-
.../measure/topn/TopNCounterBasicTest.java | 6 +-
.../topn/TopNCounterCombinationTest.java | 6 +-
.../kylin/measure/topn/TopNCounterTest.java | 41 +-
.../kylin/metadata/MetadataManagerTest.java | 2 +-
.../badquery/BadQueryHistoryManagerTest.java | 5 +-
.../datatype/BigDecimalSerializerTest.java | 2 +-
.../storage/gtrecord/CubeSegmentScanner.java | 4 +-
.../storage/gtrecord/CubeTupleConverter.java | 16 +-
.../gtrecord/SequentialCubeTupleIterator.java | 13 +-
.../kylin/storage/hybrid/HybridInstance.java | 7 +-
.../apache/kylin/storage/StorageMockUtils.java | 2 -
.../apache/kylin/storage/cache/EhcacheTest.java | 21 +-
.../storage/translate/ColumnValueRangeTest.java | 3 +-
.../org/apache/kylin/engine/mr/CubingJob.java | 29 +-
.../kylin/engine/mr/DFSFileTableReader.java | 2 +-
.../org/apache/kylin/engine/mr/IMROutput.java | 2 -
.../kylin/engine/mr/JobBuilderSupport.java | 2 -
.../engine/mr/common/AbstractHadoopJob.java | 2 +-
.../kylin/engine/mr/common/BatchConstants.java | 12 +-
.../kylin/engine/mr/common/CubeStatsReader.java | 25 +-
.../kylin/engine/mr/common/CuboidShardUtil.java | 1 -
.../kylin/engine/mr/common/CuboidStatsUtil.java | 24 +-
.../mr/common/HadoopJobStatusChecker.java | 2 +
.../engine/mr/common/HadoopShellExecutable.java | 5 +-
.../engine/mr/common/HadoopStatusChecker.java | 5 +
.../engine/mr/common/HadoopStatusGetter.java | 80 +-
.../engine/mr/common/MapReduceExecutable.java | 17 +-
.../kylin/engine/mr/invertedindex/IIJob.java | 10 +-
.../mr/invertedindex/InvertedIndexMapper.java | 4 +-
.../mr/invertedindex/InvertedIndexReducer.java | 11 +-
.../UpdateIIInfoAfterBuildStep.java | 13 +-
.../kylin/engine/mr/steps/BaseCuboidJob.java | 4 +-
.../engine/mr/steps/BaseCuboidMapperBase.java | 8 +-
.../apache/kylin/engine/mr/steps/CuboidJob.java | 6 +-
.../mr/steps/FactDistinctColumnsCombiner.java | 4 +-
.../engine/mr/steps/FactDistinctColumnsJob.java | 7 +-
.../mr/steps/FactDistinctColumnsMapperBase.java | 10 +-
.../mr/steps/FactDistinctColumnsReducer.java | 23 +-
.../mr/steps/FactDistinctHiveColumnsMapper.java | 5 +-
.../engine/mr/steps/HiveToBaseCuboidMapper.java | 1 -
.../kylin/engine/mr/steps/InMemCuboidJob.java | 4 +-
.../engine/mr/steps/InMemCuboidReducer.java | 6 +-
.../mr/steps/MapContextGTRecordWriter.java | 4 +-
.../engine/mr/steps/MergeCuboidMapper.java | 6 +-
.../engine/mr/steps/MergeDictionaryStep.java | 5 +-
.../engine/mr/steps/MergeStatisticsStep.java | 7 +-
.../engine/mr/steps/MetadataCleanupJob.java | 12 +-
.../kylin/engine/mr/steps/NDCuboidMapper.java | 4 +-
.../engine/mr/steps/SaveStatisticsStep.java | 1 -
.../mr/steps/UpdateCubeInfoAfterBuildStep.java | 1 -
.../mr/steps/UpdateCubeInfoAfterMergeStep.java | 6 -
.../kylin/engine/mr/steps/CubeReducerTest.java | 3 +-
.../kylin/engine/mr/steps/CubeSamplingTest.java | 2 +-
.../steps/FactDistinctColumnsReducerTest.java | 2 +-
.../engine/mr/steps/MergeCuboidMapperTest.java | 2 +-
.../engine/mr/steps/NDCuboidMapperTest.java | 4 +-
.../.settings/org.eclipse.core.resources.prefs | 5 +
.../.settings/org.eclipse.jdt.core.prefs | 379 +
engine-spark/.settings/org.eclipse.jdt.ui.prefs | 7 +
.../apache/kylin/engine/spark/SparkCubing.java | 4 +-
.../kylin/engine/spark/SparkCuboidWriter.java | 3 +-
.../kylin/engine/spark/SparkExecutable.java | 9 +-
.../engine/spark/cube/BufferedCuboidWriter.java | 13 +-
.../spark/cube/DefaultTupleConverter.java | 2 +-
.../spark/cube/ListBackedCuboidWriter.java | 17 +-
.../kylin/engine/spark/cube/TupleConverter.java | 3 +-
.../kylin/engine/spark/util/IteratorUtils.java | 15 +-
.../spark/cube/BufferedCuboidWriterTest.java | 13 +-
.../engine/spark/util/IteratorUtilsTest.java | 16 +-
.../.settings/org.eclipse.core.resources.prefs | 5 +
.../.settings/org.eclipse.jdt.core.prefs | 379 +
.../.settings/org.eclipse.jdt.ui.prefs | 7 +
.../engine/streaming/IStreamingOutput.java | 2 +-
.../streaming/OneOffStreamingBuilder.java | 4 +-
.../engine/streaming/StreamingBatchBuilder.java | 2 +-
.../engine/streaming/StreamingManager.java | 2 +-
.../kylin/engine/streaming/cli/MonitorCLI.java | 2 +-
.../engine/streaming/cli/StreamingCLI.java | 5 +-
.../streaming/cube/StreamingCubeBuilder.java | 30 +-
.../engine/streaming/util/StreamingUtils.java | 5 +-
.../invertedindex/IICapabilityChecker.java | 10 +-
.../apache/kylin/invertedindex/IIManager.java | 1 -
.../apache/kylin/invertedindex/IISegment.java | 3 +-
.../kylin/invertedindex/index/SliceBuilder.java | 14 +-
.../kylin/invertedindex/model/IIDesc.java | 3 +-
.../invertedindex/model/IIKeyValueCodec.java | 2 +-
.../invertedindex/util/IIDictionaryBuilder.java | 2 +-
.../kylin/invertedindex/IIDescManagerTest.java | 1 -
.../apache/kylin/invertedindex/IIDescTest.java | 1 -
.../kylin/invertedindex/IIInstanceTest.java | 4 -
.../invertedindex/InvertedIndexLocalTest.java | 7 +-
.../java/org/apache/kylin/jdbc/KylinClient.java | 7 +
.../java/org/apache/kylin/jdbc/KylinMeta.java | 2 +-
.../apache/kylin/jdbc/json/SQLResponseStub.java | 4 +-
.../jdbc/util/DefaultX509TrustManager.java | 4 +-
.../apache/kylin/jdbc/util/Log4jConfigurer.java | 2 +-
.../java/org/apache/kylin/jdbc/DriverTest.java | 2 +-
.../.settings/org.eclipse.core.resources.prefs | 5 +
kylin-it/.settings/org.eclipse.jdt.core.prefs | 379 +
kylin-it/.settings/org.eclipse.jdt.ui.prefs | 7 +
.../kylin/cube/ITDictionaryManagerTest.java | 10 +-
.../org/apache/kylin/jdbc/ITJDBCDriverTest.java | 10 +-
.../kylin/provision/BuildCubeWithEngine.java | 12 +-
.../kylin/provision/BuildIIWithEngine.java | 3 +-
.../org/apache/kylin/query/ITIIQueryTest.java | 1 -
.../apache/kylin/query/ITKylinQueryTest.java | 5 +-
.../apache/kylin/query/ITMassInQueryTest.java | 2 -
.../source/hive/ITSnapshotManagerTest.java | 2 +-
.../hbase/ii/ITInvertedIndexHBaseTest.java | 2 +-
pom.xml | 28 +
.../kylin/query/enumerator/OLAPEnumerator.java | 2 +-
.../apache/kylin/query/relnode/OLAPContext.java | 4 +-
.../kylin/query/relnode/OLAPFilterRel.java | 4 +-
.../apache/kylin/query/relnode/OLAPSortRel.java | 2 +-
.../apache/kylin/query/routing/QueryRouter.java | 1 -
.../apache/kylin/query/schema/OLAPTable.java | 2 +-
.../aggregate/DimCountDistinctAggFuncTest.java | 2 +-
.../kylin/rest/controller/CubeController.java | 10 +-
.../kylin/rest/controller/JobController.java | 2 +-
.../kylin/rest/controller/ModelController.java | 10 +-
.../rest/controller/ProjectController.java | 11 +-
.../kylin/rest/controller/QueryController.java | 8 +-
.../rest/controller/StreamingController.java | 55 +-
.../kylin/rest/controller/TableController.java | 47 +-
.../kylin/rest/controller/UserController.java | 5 +-
.../kylin/rest/model/SelectedColumnMeta.java | 2 +-
.../rest/request/ExternalFilterRequest.java | 2 -
.../kylin/rest/request/HiveTableRequest.java | 4 +-
.../kylin/rest/request/JobBuildRequest.java | 4 +-
.../kylin/rest/request/JobBuildRequest2.java | 4 +-
.../kylin/rest/request/PrepareSqlRequest.java | 4 +-
.../kylin/rest/request/StreamingRequest.java | 2 -
.../rest/security/AclPermissionFactory.java | 2 +
.../security/KylinAuthenticationProvider.java | 28 +-
.../kylin/rest/security/LdapProvider.java | 8 +-
.../rest/security/MockAclHBaseStorage.java | 6 +-
.../security/PasswordPlaceholderConfigurer.java | 11 +-
.../rest/security/SAMLUserDetailsService.java | 1 -
.../kylin/rest/service/AccessService.java | 4 +
.../apache/kylin/rest/service/AclService.java | 1 +
.../kylin/rest/service/BadQueryDetector.java | 7 +-
.../apache/kylin/rest/service/CacheService.java | 4 +-
.../kylin/rest/service/DiagnosisService.java | 2 +-
.../kylin/rest/service/ExtFilterService.java | 14 +-
.../apache/kylin/rest/service/JobService.java | 1 -
.../kylin/rest/service/KafkaConfigService.java | 23 +-
.../kylin/rest/service/ProjectService.java | 8 +-
.../apache/kylin/rest/service/QueryService.java | 4 +-
.../kylin/rest/service/StreamingService.java | 18 +-
.../apache/kylin/rest/service/UserService.java | 4 +-
.../org/apache/kylin/rest/util/QueryUtil.java | 16 +-
.../rest/controller/CubeControllerTest.java | 9 +-
.../rest/controller/JobControllerTest.java | 2 +-
.../rest/controller/QueryControllerTest.java | 4 +-
.../rest/service/BadQueryDetectorTest.java | 3 +-
.../kylin/rest/service/CacheServiceTest.java | 5 +-
.../kylin/rest/service/CubeServiceTest.java | 2 +-
.../kylin/rest/service/JobServiceTest.java | 2 +-
.../kylin/rest/service/QueryServiceTest.java | 2 +-
.../source/hive/CreateFlatHiveTableStep.java | 11 +-
.../kylin/source/hive/HiveCmdBuilder.java | 2 +-
.../apache/kylin/source/hive/HiveMRInput.java | 1 -
.../source/hive/HiveSourceTableLoader.java | 3 +-
.../apache/kylin/source/hive/HqlExecutable.java | 5 +-
.../cardinality/ColumnCardinalityMapper.java | 5 +-
.../cardinality/ColumnCardinalityReducer.java | 3 +-
.../HiveColumnCardinalityUpdateJob.java | 16 +-
.../kylin/source/hive/HiveCmdBuilderTest.java | 10 +-
.../ColumnCardinalityReducerTest.java | 3 +-
.../.settings/org.eclipse.core.resources.prefs | 5 +
.../.settings/org.eclipse.jdt.core.prefs | 379 +
source-kafka/.settings/org.eclipse.jdt.ui.prefs | 7 +
.../kafka/ByteBufferBackedInputStream.java | 3 +-
.../kylin/source/kafka/KafkaStreamingInput.java | 21 +-
.../kylin/source/kafka/StreamingParser.java | 4 +-
.../source/kafka/StringStreamingParser.java | 4 +-
.../source/kafka/TimedJsonStreamParser.java | 32 +-
.../source/kafka/config/KafkaClusterConfig.java | 5 +-
.../kylin/source/kafka/config/KafkaConfig.java | 4 +-
.../kafka/diagnose/KafkaInputAnalyzer.java | 14 +-
.../source/kafka/diagnose/KafkaVerify.java | 8 +-
.../kylin/source/kafka/util/KafkaRequester.java | 26 +-
.../source/kafka/util/KafkaSampleProducer.java | 22 +-
.../kylin/source/kafka/util/KafkaUtils.java | 16 +-
.../kylin/storage/hbase/HBaseResourceStore.java | 4 +-
.../common/coprocessor/CoprocessorBehavior.java | 2 +-
.../common/coprocessor/FilterDecorator.java | 2 +-
.../hbase/cube/HBaseScannerBenchmark.java | 2 +-
.../storage/hbase/cube/SimpleHBaseStore.java | 6 +-
.../hbase/cube/v1/CubeSegmentTupleIterator.java | 6 +-
.../observer/AggregationScanner.java | 2 +-
.../observer/ObserverAggregators.java | 2 +-
.../v1/filter/generated/FilterProtosExt.java | 2499 +++--
.../hbase/cube/v2/CubeHBaseEndpointRPC.java | 3 +-
.../storage/hbase/cube/v2/CubeHBaseRPC.java | 4 +-
.../coprocessor/endpoint/CubeVisitService.java | 8 +-
.../endpoint/generated/CubeVisitProtos.java | 8609 +++++++++---------
.../storage/hbase/ii/IICreateHFileMapper.java | 3 +-
.../storage/hbase/ii/IICreateHTableJob.java | 6 +-
.../endpoint/EndpointAggregationCache.java | 2 +-
.../endpoint/EndpointAggregators.java | 2 +-
.../endpoint/EndpointTupleIterator.java | 10 +-
.../ii/coprocessor/endpoint/IIEndpoint.java | 4 +-
.../coprocessor/endpoint/LocalDictionary.java | 2 +-
.../endpoint/generated/IIProtos.java | 7327 ++++++++-------
.../storage/hbase/steps/CreateHTableJob.java | 2 +-
.../kylin/storage/hbase/steps/CubeHFileJob.java | 2 +-
.../storage/hbase/steps/CubeHTableUtil.java | 4 +-
.../storage/hbase/steps/DeprecatedGCStep.java | 1 -
.../storage/hbase/steps/HBaseCuboidWriter.java | 23 +-
.../hbase/steps/HBaseStreamingOutput.java | 5 +-
.../steps/HDFSPathGarbageCollectionStep.java | 7 +-
.../kylin/storage/hbase/steps/MergeGCStep.java | 5 +-
.../hbase/steps/RangeKeyDistributionJob.java | 2 -
.../hbase/steps/RangeKeyDistributionMapper.java | 1 -
.../steps/RangeKeyDistributionReducer.java | 7 +-
.../storage/hbase/steps/RowValueDecoder.java | 2 +-
.../hbase/steps/SequenceFileCuboidWriter.java | 8 +-
.../storage/hbase/util/CleanHtableCLI.java | 1 -
.../storage/hbase/util/CubeMigrationCLI.java | 423 +-
.../hbase/util/CubeMigrationCheckCLI.java | 61 +-
.../hbase/util/GridTableHBaseBenchmark.java | 1 +
.../kylin/storage/hbase/util/HBaseClean.java | 6 +-
.../kylin/storage/hbase/util/HBaseUsage.java | 1 -
.../storage/hbase/util/HbaseStreamingInput.java | 1 -
.../storage/hbase/util/HiveCmdBuilder.java | 66 +-
.../hbase/util/HtableAlterMetadataCLI.java | 1 -
.../kylin/storage/hbase/util/RowCounterCLI.java | 1 -
.../storage/hbase/util/StorageCleanupJob.java | 7 +-
.../storage/hbase/util/UpdateHTableHostCLI.java | 2 +-
.../hbase/common/FuzzyValueCombinationTest.java | 2 +-
.../observer/AggregateRegionObserverTest.java | 7 +-
.../observer/RowAggregatorsTest.java | 2 +-
.../cube/v1/filter/TestFuzzyRowFilterV2.java | 36 +-
.../endpoint/EndpointAggregationTest.java | 17 +-
.../storage/hbase/steps/CreateHTableTest.java | 2 +-
.../hbase/steps/CubeHFileMapper2Test.java | 2 -
.../hbase/steps/RowValueDecoderTest.java | 2 +-
.../hbase/steps/SandboxMetastoreCLI.java | 4 +-
tool/.settings/org.eclipse.core.resources.prefs | 5 +
tool/.settings/org.eclipse.jdt.core.prefs | 379 +
tool/.settings/org.eclipse.jdt.ui.prefs | 7 +
.../apache/kylin/tool/CubeMetaExtractor.java | 1 -
.../org/apache/kylin/tool/DiagnosisInfoCLI.java | 2 +-
.../apache/kylin/tool/JobDiagnosisInfoCLI.java | 19 +-
.../kylin/tool/JobTaskCounterExtractor.java | 30 +-
.../org/apache/kylin/tool/util/ToolUtil.java | 1 -
440 files changed, 17193 insertions(+), 15948 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/.settings/org.eclipse.core.resources.prefs
----------------------------------------------------------------------
diff --git a/assembly/.settings/org.eclipse.core.resources.prefs b/assembly/.settings/org.eclipse.core.resources.prefs
new file mode 100644
index 0000000..365bbd6
--- /dev/null
+++ b/assembly/.settings/org.eclipse.core.resources.prefs
@@ -0,0 +1,5 @@
+eclipse.preferences.version=1
+encoding//src/main/java=UTF-8
+encoding//src/main/resources=UTF-8
+encoding//src/test/java=UTF-8
+encoding/<project>=UTF-8
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/.settings/org.eclipse.jdt.core.prefs
----------------------------------------------------------------------
diff --git a/assembly/.settings/org.eclipse.jdt.core.prefs b/assembly/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 0000000..a903301
--- /dev/null
+++ b/assembly/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,379 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.annotation.inheritNullAnnotations=disabled
+org.eclipse.jdt.core.compiler.annotation.missingNonNullByDefaultAnnotation=ignore
+org.eclipse.jdt.core.compiler.annotation.nonnull=org.eclipse.jdt.annotation.NonNull
+org.eclipse.jdt.core.compiler.annotation.nonnullbydefault=org.eclipse.jdt.annotation.NonNullByDefault
+org.eclipse.jdt.core.compiler.annotation.nullable=org.eclipse.jdt.annotation.Nullable
+org.eclipse.jdt.core.compiler.annotation.nullanalysis=disabled
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=1.7
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
+org.eclipse.jdt.core.compiler.problem.annotationSuperInterface=warning
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.autoboxing=ignore
+org.eclipse.jdt.core.compiler.problem.comparingIdentical=warning
+org.eclipse.jdt.core.compiler.problem.deadCode=warning
+org.eclipse.jdt.core.compiler.problem.deprecation=warning
+org.eclipse.jdt.core.compiler.problem.deprecationInDeprecatedCode=disabled
+org.eclipse.jdt.core.compiler.problem.deprecationWhenOverridingDeprecatedMethod=disabled
+org.eclipse.jdt.core.compiler.problem.discouragedReference=warning
+org.eclipse.jdt.core.compiler.problem.emptyStatement=ignore
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.problem.explicitlyClosedAutoCloseable=ignore
+org.eclipse.jdt.core.compiler.problem.fallthroughCase=ignore
+org.eclipse.jdt.core.compiler.problem.fatalOptionalError=disabled
+org.eclipse.jdt.core.compiler.problem.fieldHiding=ignore
+org.eclipse.jdt.core.compiler.problem.finalParameterBound=warning
+org.eclipse.jdt.core.compiler.problem.finallyBlockNotCompletingNormally=warning
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.hiddenCatchBlock=warning
+org.eclipse.jdt.core.compiler.problem.includeNullInfoFromAsserts=disabled
+org.eclipse.jdt.core.compiler.problem.incompatibleNonInheritedInterfaceMethod=warning
+org.eclipse.jdt.core.compiler.problem.incompleteEnumSwitch=warning
+org.eclipse.jdt.core.compiler.problem.indirectStaticAccess=ignore
+org.eclipse.jdt.core.compiler.problem.localVariableHiding=ignore
+org.eclipse.jdt.core.compiler.problem.methodWithConstructorName=warning
+org.eclipse.jdt.core.compiler.problem.missingDefaultCase=ignore
+org.eclipse.jdt.core.compiler.problem.missingDeprecatedAnnotation=ignore
+org.eclipse.jdt.core.compiler.problem.missingEnumCaseDespiteDefault=disabled
+org.eclipse.jdt.core.compiler.problem.missingHashCodeMethod=ignore
+org.eclipse.jdt.core.compiler.problem.missingOverrideAnnotation=ignore
+org.eclipse.jdt.core.compiler.problem.missingOverrideAnnotationForInterfaceMethodImplementation=enabled
+org.eclipse.jdt.core.compiler.problem.missingSerialVersion=warning
+org.eclipse.jdt.core.compiler.problem.missingSynchronizedOnInheritedMethod=ignore
+org.eclipse.jdt.core.compiler.problem.noEffectAssignment=warning
+org.eclipse.jdt.core.compiler.problem.noImplicitStringConversion=warning
+org.eclipse.jdt.core.compiler.problem.nonExternalizedStringLiteral=ignore
+org.eclipse.jdt.core.compiler.problem.nonnullParameterAnnotationDropped=warning
+org.eclipse.jdt.core.compiler.problem.nullAnnotationInferenceConflict=error
+org.eclipse.jdt.core.compiler.problem.nullReference=warning
+org.eclipse.jdt.core.compiler.problem.nullSpecViolation=error
+org.eclipse.jdt.core.compiler.problem.nullUncheckedConversion=warning
+org.eclipse.jdt.core.compiler.problem.overridingPackageDefaultMethod=warning
+org.eclipse.jdt.core.compiler.problem.parameterAssignment=ignore
+org.eclipse.jdt.core.compiler.problem.possibleAccidentalBooleanAssignment=ignore
+org.eclipse.jdt.core.compiler.problem.potentialNullReference=ignore
+org.eclipse.jdt.core.compiler.problem.potentiallyUnclosedCloseable=ignore
+org.eclipse.jdt.core.compiler.problem.rawTypeReference=warning
+org.eclipse.jdt.core.compiler.problem.redundantNullAnnotation=warning
+org.eclipse.jdt.core.compiler.problem.redundantNullCheck=ignore
+org.eclipse.jdt.core.compiler.problem.redundantSpecificationOfTypeArguments=ignore
+org.eclipse.jdt.core.compiler.problem.redundantSuperinterface=ignore
+org.eclipse.jdt.core.compiler.problem.reportMethodCanBePotentiallyStatic=ignore
+org.eclipse.jdt.core.compiler.problem.reportMethodCanBeStatic=ignore
+org.eclipse.jdt.core.compiler.problem.specialParameterHidingField=disabled
+org.eclipse.jdt.core.compiler.problem.staticAccessReceiver=warning
+org.eclipse.jdt.core.compiler.problem.suppressOptionalErrors=disabled
+org.eclipse.jdt.core.compiler.problem.suppressWarnings=enabled
+org.eclipse.jdt.core.compiler.problem.syntacticNullAnalysisForFields=disabled
+org.eclipse.jdt.core.compiler.problem.syntheticAccessEmulation=ignore
+org.eclipse.jdt.core.compiler.problem.typeParameterHiding=warning
+org.eclipse.jdt.core.compiler.problem.unavoidableGenericTypeProblems=enabled
+org.eclipse.jdt.core.compiler.problem.uncheckedTypeOperation=warning
+org.eclipse.jdt.core.compiler.problem.unclosedCloseable=warning
+org.eclipse.jdt.core.compiler.problem.undocumentedEmptyBlock=ignore
+org.eclipse.jdt.core.compiler.problem.unhandledWarningToken=warning
+org.eclipse.jdt.core.compiler.problem.unnecessaryElse=ignore
+org.eclipse.jdt.core.compiler.problem.unnecessaryTypeCheck=ignore
+org.eclipse.jdt.core.compiler.problem.unqualifiedFieldAccess=ignore
+org.eclipse.jdt.core.compiler.problem.unusedDeclaredThrownException=ignore
+org.eclipse.jdt.core.compiler.problem.unusedDeclaredThrownExceptionExemptExceptionAndThrowable=enabled
+org.eclipse.jdt.core.compiler.problem.unusedDeclaredThrownExceptionIncludeDocCommentReference=enabled
+org.eclipse.jdt.core.compiler.problem.unusedDeclaredThrownExceptionWhenOverriding=disabled
+org.eclipse.jdt.core.compiler.problem.unusedImport=warning
+org.eclipse.jdt.core.compiler.problem.unusedLabel=warning
+org.eclipse.jdt.core.compiler.problem.unusedLocal=warning
+org.eclipse.jdt.core.compiler.problem.unusedObjectAllocation=ignore
+org.eclipse.jdt.core.compiler.problem.unusedParameter=ignore
+org.eclipse.jdt.core.compiler.problem.unusedParameterIncludeDocCommentReference=enabled
+org.eclipse.jdt.core.compiler.problem.unusedParameterWhenImplementingAbstract=disabled
+org.eclipse.jdt.core.compiler.problem.unusedParameterWhenOverridingConcrete=disabled
+org.eclipse.jdt.core.compiler.problem.unusedPrivateMember=warning
+org.eclipse.jdt.core.compiler.problem.unusedTypeParameter=ignore
+org.eclipse.jdt.core.compiler.problem.unusedWarningToken=warning
+org.eclipse.jdt.core.compiler.problem.varargsArgumentNeedCast=warning
+org.eclipse.jdt.core.compiler.source=1.7
+org.eclipse.jdt.core.formatter.align_type_members_on_columns=false
+org.eclipse.jdt.core.formatter.alignment_for_arguments_in_allocation_expression=16
+org.eclipse.jdt.core.formatter.alignment_for_arguments_in_annotation=0
+org.eclipse.jdt.core.formatter.alignment_for_arguments_in_enum_constant=16
+org.eclipse.jdt.core.formatter.alignment_for_arguments_in_explicit_constructor_call=16
+org.eclipse.jdt.core.formatter.alignment_for_arguments_in_method_invocation=16
+org.eclipse.jdt.core.formatter.alignment_for_arguments_in_qualified_allocation_expression=16
+org.eclipse.jdt.core.formatter.alignment_for_assignment=0
+org.eclipse.jdt.core.formatter.alignment_for_binary_expression=16
+org.eclipse.jdt.core.formatter.alignment_for_compact_if=16
+org.eclipse.jdt.core.formatter.alignment_for_conditional_expression=80
+org.eclipse.jdt.core.formatter.alignment_for_enum_constants=0
+org.eclipse.jdt.core.formatter.alignment_for_expressions_in_array_initializer=16
+org.eclipse.jdt.core.formatter.alignment_for_method_declaration=0
+org.eclipse.jdt.core.formatter.alignment_for_multiple_fields=16
+org.eclipse.jdt.core.formatter.alignment_for_parameters_in_constructor_declaration=16
+org.eclipse.jdt.core.formatter.alignment_for_parameters_in_method_declaration=16
+org.eclipse.jdt.core.formatter.alignment_for_resources_in_try=80
+org.eclipse.jdt.core.formatter.alignment_for_selector_in_method_invocation=16
+org.eclipse.jdt.core.formatter.alignment_for_superclass_in_type_declaration=16
+org.eclipse.jdt.core.formatter.alignment_for_superinterfaces_in_enum_declaration=16
+org.eclipse.jdt.core.formatter.alignment_for_superinterfaces_in_type_declaration=16
+org.eclipse.jdt.core.formatter.alignment_for_throws_clause_in_constructor_declaration=16
+org.eclipse.jdt.core.formatter.alignment_for_throws_clause_in_method_declaration=16
+org.eclipse.jdt.core.formatter.alignment_for_union_type_in_multicatch=16
+org.eclipse.jdt.core.formatter.blank_lines_after_imports=1
+org.eclipse.jdt.core.formatter.blank_lines_after_package=1
+org.eclipse.jdt.core.formatter.blank_lines_before_field=0
+org.eclipse.jdt.core.formatter.blank_lines_before_first_class_body_declaration=0
+org.eclipse.jdt.core.formatter.blank_lines_before_imports=1
+org.eclipse.jdt.core.formatter.blank_lines_before_member_type=1
+org.eclipse.jdt.core.formatter.blank_lines_before_method=1
+org.eclipse.jdt.core.formatter.blank_lines_before_new_chunk=1
+org.eclipse.jdt.core.formatter.blank_lines_before_package=0
+org.eclipse.jdt.core.formatter.blank_lines_between_import_groups=1
+org.eclipse.jdt.core.formatter.blank_lines_between_type_declarations=1
+org.eclipse.jdt.core.formatter.brace_position_for_annotation_type_declaration=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_anonymous_type_declaration=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_array_initializer=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_block=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_block_in_case=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_constructor_declaration=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_enum_constant=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_enum_declaration=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_method_declaration=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_switch=end_of_line
+org.eclipse.jdt.core.formatter.brace_position_for_type_declaration=end_of_line
+org.eclipse.jdt.core.formatter.comment.clear_blank_lines_in_block_comment=false
+org.eclipse.jdt.core.formatter.comment.clear_blank_lines_in_javadoc_comment=false
+org.eclipse.jdt.core.formatter.comment.format_block_comments=false
+org.eclipse.jdt.core.formatter.comment.format_header=false
+org.eclipse.jdt.core.formatter.comment.format_html=true
+org.eclipse.jdt.core.formatter.comment.format_javadoc_comments=false
+org.eclipse.jdt.core.formatter.comment.format_line_comments=false
+org.eclipse.jdt.core.formatter.comment.format_source_code=true
+org.eclipse.jdt.core.formatter.comment.indent_parameter_description=true
+org.eclipse.jdt.core.formatter.comment.indent_root_tags=true
+org.eclipse.jdt.core.formatter.comment.insert_new_line_before_root_tags=insert
+org.eclipse.jdt.core.formatter.comment.insert_new_line_for_parameter=insert
+org.eclipse.jdt.core.formatter.comment.line_length=80
+org.eclipse.jdt.core.formatter.comment.new_lines_at_block_boundaries=true
+org.eclipse.jdt.core.formatter.comment.new_lines_at_javadoc_boundaries=true
+org.eclipse.jdt.core.formatter.comment.preserve_white_space_between_code_and_line_comments=false
+org.eclipse.jdt.core.formatter.compact_else_if=true
+org.eclipse.jdt.core.formatter.continuation_indentation=2
+org.eclipse.jdt.core.formatter.continuation_indentation_for_array_initializer=2
+org.eclipse.jdt.core.formatter.disabling_tag=@formatter\:off
+org.eclipse.jdt.core.formatter.enabling_tag=@formatter\:on
+org.eclipse.jdt.core.formatter.format_guardian_clause_on_one_line=false
+org.eclipse.jdt.core.formatter.format_line_comment_starting_on_first_column=true
+org.eclipse.jdt.core.formatter.indent_body_declarations_compare_to_annotation_declaration_header=true
+org.eclipse.jdt.core.formatter.indent_body_declarations_compare_to_enum_constant_header=true
+org.eclipse.jdt.core.formatter.indent_body_declarations_compare_to_enum_declaration_header=true
+org.eclipse.jdt.core.formatter.indent_body_declarations_compare_to_type_header=true
+org.eclipse.jdt.core.formatter.indent_breaks_compare_to_cases=true
+org.eclipse.jdt.core.formatter.indent_empty_lines=false
+org.eclipse.jdt.core.formatter.indent_statements_compare_to_block=true
+org.eclipse.jdt.core.formatter.indent_statements_compare_to_body=true
+org.eclipse.jdt.core.formatter.indent_switchstatements_compare_to_cases=true
+org.eclipse.jdt.core.formatter.indent_switchstatements_compare_to_switch=false
+org.eclipse.jdt.core.formatter.indentation.size=4
+org.eclipse.jdt.core.formatter.insert_new_line_after_annotation_on_field=insert
+org.eclipse.jdt.core.formatter.insert_new_line_after_annotation_on_local_variable=insert
+org.eclipse.jdt.core.formatter.insert_new_line_after_annotation_on_method=insert
+org.eclipse.jdt.core.formatter.insert_new_line_after_annotation_on_package=insert
+org.eclipse.jdt.core.formatter.insert_new_line_after_annotation_on_parameter=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_after_annotation_on_type=insert
+org.eclipse.jdt.core.formatter.insert_new_line_after_label=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_after_opening_brace_in_array_initializer=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_at_end_of_file_if_missing=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_before_catch_in_try_statement=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_before_closing_brace_in_array_initializer=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_before_else_in_if_statement=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_before_finally_in_try_statement=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_before_while_in_do_statement=do not insert
+org.eclipse.jdt.core.formatter.insert_new_line_in_empty_annotation_declaration=insert
+org.eclipse.jdt.core.formatter.insert_new_line_in_empty_anonymous_type_declaration=insert
+org.eclipse.jdt.core.formatter.insert_new_line_in_empty_block=insert
+org.eclipse.jdt.core.formatter.insert_new_line_in_empty_enum_constant=insert
+org.eclipse.jdt.core.formatter.insert_new_line_in_empty_enum_declaration=insert
+org.eclipse.jdt.core.formatter.insert_new_line_in_empty_method_body=insert
+org.eclipse.jdt.core.formatter.insert_new_line_in_empty_type_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_after_and_in_type_parameter=insert
+org.eclipse.jdt.core.formatter.insert_space_after_assignment_operator=insert
+org.eclipse.jdt.core.formatter.insert_space_after_at_in_annotation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_at_in_annotation_type_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_binary_operator=insert
+org.eclipse.jdt.core.formatter.insert_space_after_closing_angle_bracket_in_type_arguments=insert
+org.eclipse.jdt.core.formatter.insert_space_after_closing_angle_bracket_in_type_parameters=insert
+org.eclipse.jdt.core.formatter.insert_space_after_closing_brace_in_block=insert
+org.eclipse.jdt.core.formatter.insert_space_after_closing_paren_in_cast=insert
+org.eclipse.jdt.core.formatter.insert_space_after_colon_in_assert=insert
+org.eclipse.jdt.core.formatter.insert_space_after_colon_in_case=insert
+org.eclipse.jdt.core.formatter.insert_space_after_colon_in_conditional=insert
+org.eclipse.jdt.core.formatter.insert_space_after_colon_in_for=insert
+org.eclipse.jdt.core.formatter.insert_space_after_colon_in_labeled_statement=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_allocation_expression=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_annotation=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_array_initializer=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_constructor_declaration_parameters=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_constructor_declaration_throws=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_enum_constant_arguments=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_enum_declarations=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_explicitconstructorcall_arguments=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_for_increments=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_for_inits=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_method_declaration_parameters=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_method_declaration_throws=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_method_invocation_arguments=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_multiple_field_declarations=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_multiple_local_declarations=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_parameterized_type_reference=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_superinterfaces=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_type_arguments=insert
+org.eclipse.jdt.core.formatter.insert_space_after_comma_in_type_parameters=insert
+org.eclipse.jdt.core.formatter.insert_space_after_ellipsis=insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_angle_bracket_in_parameterized_type_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_angle_bracket_in_type_arguments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_angle_bracket_in_type_parameters=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_brace_in_array_initializer=insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_bracket_in_array_allocation_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_bracket_in_array_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_annotation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_cast=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_catch=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_constructor_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_enum_constant=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_for=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_if=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_method_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_method_invocation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_parenthesized_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_switch=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_synchronized=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_try=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_opening_paren_in_while=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_postfix_operator=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_prefix_operator=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_question_in_conditional=insert
+org.eclipse.jdt.core.formatter.insert_space_after_question_in_wildcard=do not insert
+org.eclipse.jdt.core.formatter.insert_space_after_semicolon_in_for=insert
+org.eclipse.jdt.core.formatter.insert_space_after_semicolon_in_try_resources=insert
+org.eclipse.jdt.core.formatter.insert_space_after_unary_operator=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_and_in_type_parameter=insert
+org.eclipse.jdt.core.formatter.insert_space_before_assignment_operator=insert
+org.eclipse.jdt.core.formatter.insert_space_before_at_in_annotation_type_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_before_binary_operator=insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_angle_bracket_in_parameterized_type_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_angle_bracket_in_type_arguments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_angle_bracket_in_type_parameters=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_brace_in_array_initializer=insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_bracket_in_array_allocation_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_bracket_in_array_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_annotation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_cast=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_catch=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_constructor_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_enum_constant=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_for=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_if=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_method_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_method_invocation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_parenthesized_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_switch=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_synchronized=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_try=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_closing_paren_in_while=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_colon_in_assert=insert
+org.eclipse.jdt.core.formatter.insert_space_before_colon_in_case=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_colon_in_conditional=insert
+org.eclipse.jdt.core.formatter.insert_space_before_colon_in_default=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_colon_in_for=insert
+org.eclipse.jdt.core.formatter.insert_space_before_colon_in_labeled_statement=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_allocation_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_annotation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_array_initializer=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_constructor_declaration_parameters=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_constructor_declaration_throws=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_enum_constant_arguments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_enum_declarations=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_explicitconstructorcall_arguments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_for_increments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_for_inits=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_method_declaration_parameters=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_method_declaration_throws=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_method_invocation_arguments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_multiple_field_declarations=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_multiple_local_declarations=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_parameterized_type_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_superinterfaces=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_type_arguments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_comma_in_type_parameters=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_ellipsis=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_angle_bracket_in_parameterized_type_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_angle_bracket_in_type_arguments=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_angle_bracket_in_type_parameters=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_annotation_type_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_anonymous_type_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_array_initializer=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_block=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_constructor_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_enum_constant=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_enum_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_method_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_switch=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_brace_in_type_declaration=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_bracket_in_array_allocation_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_bracket_in_array_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_bracket_in_array_type_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_annotation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_annotation_type_member_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_catch=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_constructor_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_enum_constant=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_for=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_if=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_method_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_method_invocation=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_parenthesized_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_switch=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_synchronized=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_try=insert
+org.eclipse.jdt.core.formatter.insert_space_before_opening_paren_in_while=insert
+org.eclipse.jdt.core.formatter.insert_space_before_parenthesized_expression_in_return=insert
+org.eclipse.jdt.core.formatter.insert_space_before_parenthesized_expression_in_throw=insert
+org.eclipse.jdt.core.formatter.insert_space_before_postfix_operator=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_prefix_operator=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_question_in_conditional=insert
+org.eclipse.jdt.core.formatter.insert_space_before_question_in_wildcard=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_semicolon=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_semicolon_in_for=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_semicolon_in_try_resources=do not insert
+org.eclipse.jdt.core.formatter.insert_space_before_unary_operator=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_brackets_in_array_type_reference=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_empty_braces_in_array_initializer=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_empty_brackets_in_array_allocation_expression=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_empty_parens_in_annotation_type_member_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_empty_parens_in_constructor_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_empty_parens_in_enum_constant=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_empty_parens_in_method_declaration=do not insert
+org.eclipse.jdt.core.formatter.insert_space_between_empty_parens_in_method_invocation=do not insert
+org.eclipse.jdt.core.formatter.join_lines_in_comments=true
+org.eclipse.jdt.core.formatter.join_wrapped_lines=true
+org.eclipse.jdt.core.formatter.keep_else_statement_on_same_line=false
+org.eclipse.jdt.core.formatter.keep_empty_array_initializer_on_one_line=false
+org.eclipse.jdt.core.formatter.keep_imple_if_on_one_line=false
+org.eclipse.jdt.core.formatter.keep_then_statement_on_same_line=false
+org.eclipse.jdt.core.formatter.lineSplit=999
+org.eclipse.jdt.core.formatter.never_indent_block_comments_on_first_column=false
+org.eclipse.jdt.core.formatter.never_indent_line_comments_on_first_column=false
+org.eclipse.jdt.core.formatter.number_of_blank_lines_at_beginning_of_method_body=0
+org.eclipse.jdt.core.formatter.number_of_empty_lines_to_preserve=1
+org.eclipse.jdt.core.formatter.put_empty_statement_on_new_line=true
+org.eclipse.jdt.core.formatter.tabulation.char=space
+org.eclipse.jdt.core.formatter.tabulation.size=4
+org.eclipse.jdt.core.formatter.use_on_off_tags=false
+org.eclipse.jdt.core.formatter.use_tabs_only_for_leading_indentations=false
+org.eclipse.jdt.core.formatter.wrap_before_binary_operator=true
+org.eclipse.jdt.core.formatter.wrap_before_or_operator_multicatch=true
+org.eclipse.jdt.core.formatter.wrap_outer_expressions_when_nested=true
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/.settings/org.eclipse.jdt.ui.prefs
----------------------------------------------------------------------
diff --git a/assembly/.settings/org.eclipse.jdt.ui.prefs b/assembly/.settings/org.eclipse.jdt.ui.prefs
new file mode 100644
index 0000000..dece0e6
--- /dev/null
+++ b/assembly/.settings/org.eclipse.jdt.ui.prefs
@@ -0,0 +1,7 @@
+eclipse.preferences.version=1
+formatter_profile=_Space Indent & Long Lines
+formatter_settings_version=12
+org.eclipse.jdt.ui.ignorelowercasenames=true
+org.eclipse.jdt.ui.importorder=java;javax;org;com;
+org.eclipse.jdt.ui.ondemandthreshold=99
+org.eclipse.jdt.ui.staticondemandthreshold=1
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/src/test/java/org/apache/kylin/job/DeployLocalMetaToRemoteTest.java
----------------------------------------------------------------------
diff --git a/assembly/src/test/java/org/apache/kylin/job/DeployLocalMetaToRemoteTest.java b/assembly/src/test/java/org/apache/kylin/job/DeployLocalMetaToRemoteTest.java
index 8494607..a6c2f01 100644
--- a/assembly/src/test/java/org/apache/kylin/job/DeployLocalMetaToRemoteTest.java
+++ b/assembly/src/test/java/org/apache/kylin/job/DeployLocalMetaToRemoteTest.java
@@ -24,7 +24,6 @@ import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.kylin.common.KylinConfig;
-import org.apache.kylin.common.util.AbstractKylinTestCase;
import org.apache.kylin.common.util.ClassUtil;
import org.apache.kylin.common.util.HBaseMetadataTestCase;
import org.junit.After;
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java
----------------------------------------------------------------------
diff --git a/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java b/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java
index a0a9f88..22fe48a 100644
--- a/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java
+++ b/assembly/src/test/java/org/apache/kylin/job/DeployUtil.java
@@ -26,9 +26,6 @@ import java.io.IOException;
import java.io.InputStream;
import java.util.List;
-import kafka.message.Message;
-import kafka.message.MessageAndOffset;
-
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.kylin.common.KylinConfig;
@@ -56,6 +53,9 @@ import org.slf4j.LoggerFactory;
import com.google.common.collect.Lists;
+import kafka.message.Message;
+import kafka.message.MessageAndOffset;
+
public class DeployUtil {
private static final Logger logger = LoggerFactory.getLogger(DeployUtil.class);
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
----------------------------------------------------------------------
diff --git a/assembly/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java b/assembly/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
index da25143..3390586 100644
--- a/assembly/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
+++ b/assembly/src/test/java/org/apache/kylin/job/hadoop/invertedindex/IITest.java
@@ -29,11 +29,6 @@ import java.util.Set;
import javax.annotation.Nullable;
-
-import com.google.common.base.Function;
-import kafka.message.Message;
-import kafka.message.MessageAndOffset;
-
import org.apache.commons.lang.NotImplementedException;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.HRegionInfo;
@@ -47,6 +42,7 @@ import org.apache.kylin.invertedindex.IIInstance;
import org.apache.kylin.invertedindex.IIManager;
import org.apache.kylin.invertedindex.IISegment;
import org.apache.kylin.invertedindex.index.Slice;
+import org.apache.kylin.invertedindex.index.SliceBuilder;
import org.apache.kylin.invertedindex.index.TableRecordInfo;
import org.apache.kylin.invertedindex.index.TableRecordInfoDigest;
import org.apache.kylin.invertedindex.model.IIDesc;
@@ -54,7 +50,6 @@ import org.apache.kylin.invertedindex.model.IIKeyValueCodec;
import org.apache.kylin.invertedindex.model.IIKeyValueCodecWithState;
import org.apache.kylin.invertedindex.model.IIRow;
import org.apache.kylin.invertedindex.model.KeyValueCodec;
-import org.apache.kylin.invertedindex.index.SliceBuilder;
import org.apache.kylin.metadata.filter.ColumnTupleFilter;
import org.apache.kylin.metadata.filter.CompareTupleFilter;
import org.apache.kylin.metadata.filter.ConstantTupleFilter;
@@ -77,9 +72,13 @@ import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
+import com.google.common.base.Function;
import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
+import kafka.message.Message;
+import kafka.message.MessageAndOffset;
+
/**
*/
public class IITest extends LocalFileMetadataTestCase {
@@ -91,7 +90,7 @@ public class IITest extends LocalFileMetadataTestCase {
List<IIRow> iiRows;
final String[] inputData = new String[] { //
- "FP-non GTC,0,15,145970,0,28,Toys,2008-10-08 07:18:40,USER_Y,Toys & Hobbies,Models & Kits,Automotive,0,Ebay,USER_S,15,Professional-Other,2012-08-16,2012-08-11,0,2012-08-16,145970,10000329,26.8551,0", //
+ "FP-non GTC,0,15,145970,0,28,Toys,2008-10-08 07:18:40,USER_Y,Toys & Hobbies,Models & Kits,Automotive,0,Ebay,USER_S,15,Professional-Other,2012-08-16,2012-08-11,0,2012-08-16,145970,10000329,26.8551,0", //
"ABIN,0,-99,43479,0,21,Photo,2012-09-11 20:26:04,USER_Y,Cameras & Photo,Film Photography,Other,0,Ebay,USER_S,-99,Not Applicable,2012-08-16,2012-08-11,0,2012-08-16,43479,10000807,26.2474,0", //
"ABIN,0,16,80053,0,12,Computers,2012-06-19 21:15:09,USER_Y,Computers/Tablets & Networking,MonitorProjectors & Accs,Monitors,0,Ebay,USER_S,16,Consumer-Other,2012-08-16,2012-08-11,0,2012-08-16,80053,10000261,94.2273,0" };
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
----------------------------------------------------------------------
diff --git a/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java b/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
index 31fc670..5242ff2 100644
--- a/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
+++ b/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
@@ -23,10 +23,6 @@ import java.util.Properties;
import javax.annotation.Nullable;
-import kafka.javaapi.producer.Producer;
-import kafka.producer.KeyedMessage;
-import kafka.producer.ProducerConfig;
-
import org.apache.commons.lang.StringUtils;
import org.apache.kylin.source.kafka.config.BrokerConfig;
import org.apache.kylin.source.kafka.config.KafkaClusterConfig;
@@ -35,6 +31,10 @@ import com.google.common.base.Function;
import com.google.common.collect.Collections2;
import com.google.common.collect.Lists;
+import kafka.javaapi.producer.Producer;
+import kafka.producer.KeyedMessage;
+import kafka.producer.ProducerConfig;
+
/**
* Load prepared data into kafka(for test use)
*/
http://git-wip-us.apache.org/repos/asf/kylin/blob/5d4982e2/assembly/src/test/java/org/apache/kylin/job/streaming/StreamingTableDataGenerator.java
----------------------------------------------------------------------
diff --git a/assembly/src/test/java/org/apache/kylin/job/streaming/StreamingTableDataGenerator.java b/assembly/src/test/java/org/apache/kylin/job/streaming/StreamingTableDataGenerator.java
index 734c982..e955847 100644
--- a/assembly/src/test/java/org/apache/kylin/job/streaming/StreamingTableDataGenerator.java
+++ b/assembly/src/test/java/org/apache/kylin/job/streaming/StreamingTableDataGenerator.java
@@ -32,6 +32,7 @@ import org.slf4j.LoggerFactory;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
+
import com.google.common.base.Preconditions;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;