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 <mahong...@apache.org> Authored: Fri Jun 24 16:19:05 2016 +0800 Committer: Hongbin Ma <mahong...@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;