From bd0756e36021452c8d13b92af26a819b973be5c6 Mon Sep 17 00:00:00 2001 From: cheddar Date: Fri, 30 Aug 2013 18:58:28 -0500 Subject: [PATCH] More stuff moved, things still compiling and tests still passing. Yay! --- common/pom.xml | 3 +- .../druid/config/ConfigManagerConfig.java | 20 ------- .../com/metamx/druid/config/ConfigSerde.java | 9 --- .../com/metamx/druid/utils/SocketUtil.java | 39 ------------- .../druid/collections}/CombiningIterable.java | 4 +- .../druid/collections}/CombiningIterator.java | 4 +- .../druid/collections}/CountingMap.java | 4 +- .../druid/collections}/IntList.java | 4 +- .../collections}/OrderedMergeIterator.java | 4 +- .../collections}/OrderedMergeSequence.java | 4 +- .../druid/collections}/ResourceHolder.java | 4 +- .../druid/collections}/StupidPool.java | 4 +- .../collections}/StupidResourceHolder.java | 4 +- .../druid/common}/config/ConfigManager.java | 23 +++++++- .../common/config/ConfigManagerConfig.java | 39 +++++++++++++ .../io/druid/common/config/ConfigSerde.java | 28 +++++++++ .../common}/config/JacksonConfigManager.java | 4 +- .../common}/guava/CombiningSequence.java | 4 +- .../druid/common}/guava/DSuppliers.java | 2 +- .../common}/guava/FileOutputSupplier.java | 4 +- .../druid/common}/guava/GuavaUtils.java | 4 +- .../druid/common}/guava/Runnables.java | 4 +- .../common}/guava/ThreadRenamingCallable.java | 4 +- .../common}/guava/ThreadRenamingRunnable.java | 4 +- .../druid/common}/utils/CompressionUtils.java | 4 +- .../druid/common}/utils/JodaUtils.java | 4 +- .../druid/common}/utils/PropUtils.java | 4 +- .../druid/common}/utils/SerializerUtils.java | 6 +- .../io/druid/common/utils/SocketUtil.java | 58 +++++++++++++++++++ .../metamx => io}/druid/concurrent/Execs.java | 4 +- .../druid/data}/input/InputRow.java | 4 +- .../druid/data}/input/MapBasedInputRow.java | 4 +- .../druid/data}/input/MapBasedRow.java | 5 +- .../druid => io/druid/data}/input/Row.java | 4 +- .../druid => io/druid/data}/input/Rows.java | 4 +- .../metamx => io}/druid/db/DbConnector.java | 4 +- .../druid/db/DbConnectorConfig.java | 4 +- .../druid/db/DbTablesConfig.java | 21 ++++++- .../druid/guice/guice/DbConnectorModule.java | 6 +- .../guice/JacksonConfigManagerModule.java | 10 ++-- .../guice/guice/JacksonConfigProvider.java | 4 +- .../druid/timeline}/LogicalSegment.java | 2 +- .../druid/timeline}/TimelineObjectHolder.java | 4 +- .../timeline}/VersionedIntervalTimeline.java | 10 ++-- .../partition/ImmutablePartitionHolder.java | 4 +- .../partition/IntegerPartitionChunk.java | 4 +- .../partition/LinearPartitionChunk.java | 21 ++++++- .../partition/NumberedPartitionChunk.java | 4 +- .../timeline}/partition/PartitionChunk.java | 4 +- .../timeline}/partition/PartitionHolder.java | 4 +- .../SingleElementPartitionChunk.java | 4 +- .../partition/StringPartitionChunk.java | 4 +- .../druid/collections}/IntListTest.java | 4 +- .../druid/collections}/IteratorShell.java | 4 +- .../OrderedMergeIteratorTest.java | 4 +- .../OrderedMergeSequenceTest.java | 4 +- .../common}/guava/CombiningSequenceTest.java | 4 +- .../druid/common}/utils/JodaUtilsTest.java | 4 +- .../VersionedIntervalTimelineTest.java | 14 ++--- .../partition/IntegerPartitionChunkTest.java | 6 +- .../partition/StringPartitionChunkTest.java | 6 +- .../examples/flights/FlightsConverter.java | 4 +- .../flights/FlightsFirehoseFactory.java | 2 +- .../examples/rand/RandomFirehoseFactory.java | 23 +++++++- .../TwitterSpritzerFirehoseFactory.java | 23 +++++++- .../web/InputSupplierUpdateStream.java | 4 +- .../examples/web/WebFirehoseFactory.java | 8 +-- .../examples/web/WebFirehoseFactoryTest.java | 4 +- .../metamx/druid/indexer/DbUpdaterJob.java | 4 +- .../druid/indexer/DeterminePartitionsJob.java | 4 +- .../indexer/HadoopDruidIndexerConfig.java | 6 +- .../indexer/HadoopDruidIndexerMapper.java | 2 +- .../druid/indexer/IndexGeneratorJob.java | 2 +- .../java/com/metamx/druid/indexer/Utils.java | 4 +- .../indexer/updater/DbUpdaterJobSpec.java | 4 +- .../indexer/HadoopDruidIndexerConfigTest.java | 6 +- .../granularity/ArbitraryGranularityTest.java | 5 +- .../granularity/UniformGranularityTest.java | 5 +- .../index/EventReceiverFirehoseFactory.java | 2 +- .../common/index/StaticS3FirehoseFactory.java | 2 +- .../indexing/common/task/AppendTask.java | 4 +- .../indexing/common/task/HadoopIndexTask.java | 2 +- .../task/IndexDeterminePartitionsTask.java | 2 +- .../common/task/IndexGeneratorTask.java | 2 +- .../common/task/RealtimeIndexTask.java | 2 +- .../indexing/coordinator/DbTaskStorage.java | 4 +- .../coordinator/IndexerDBCoordinator.java | 8 +-- .../coordinator/ThreadPoolTaskRunner.java | 2 +- .../config/IndexerDbConnectorConfig.java | 5 +- .../http/IndexerCoordinatorResource.java | 2 +- .../http/OldIndexerCoordinatorResource.java | 21 ++++++- .../indexing/worker/WorkerTaskMonitor.java | 2 +- .../worker/executor/ExecutorLifecycle.java | 21 ++++++- .../indexing/common/task/TaskSerdeTest.java | 6 +- .../common/task/VersionConverterTaskTest.java | 2 +- .../coordinator/RemoteTaskRunnerTest.java | 4 +- .../coordinator/TaskLifecycleTest.java | 8 +-- .../scaling/EC2AutoScalingStrategyTest.java | 6 +- .../SimpleResourceManagementStrategyTest.java | 4 +- .../indexing/worker/TaskAnnouncementTest.java | 2 +- processing/pom.xml | 9 +++ .../io/druid/data/input/InputRowParser.java | 1 - .../druid/data/input/MapInputRowParser.java | 2 - .../data/input/ProtoBufInputRowParser.java | 1 - .../data/input/StringInputRowParser.java | 1 - .../io}/druid/jackson/AggregatorsModule.java | 22 +++---- .../jackson/CommaListJoinDeserializer.java | 4 +- .../jackson/CommaListJoinSerializer.java | 4 +- .../druid/jackson/DefaultObjectMapper.java | 2 +- .../DruidDefaultSerializersModule.java | 2 +- .../java/io}/druid/jackson/JacksonModule.java | 2 +- .../java/io}/druid/jackson/JodaStuff.java | 4 +- .../druid/jackson/QueryGranularityModule.java | 2 +- .../java/io/druid/query/QueryToolChest.java | 2 +- .../druid/query/ResultMergeQueryRunner.java | 2 +- .../query}/aggregation/CountAggregator.java | 4 +- .../aggregation/CountAggregatorFactory.java | 5 +- .../aggregation/CountBufferAggregator.java | 4 +- .../aggregation/DoubleSumAggregator.java | 3 +- .../DoubleSumAggregatorFactory.java | 5 +- .../DoubleSumBufferAggregator.java | 3 +- .../druid/query}/aggregation/Histogram.java | 2 +- .../aggregation/HistogramAggregator.java | 3 +- .../HistogramAggregatorFactory.java | 5 +- .../HistogramBufferAggregator.java | 3 +- .../query}/aggregation/HistogramVisual.java | 2 +- .../aggregation/JavaScriptAggregator.java | 3 +- .../JavaScriptAggregatorFactory.java | 5 +- .../JavaScriptBufferAggregator.java | 3 +- .../query}/aggregation/LongSumAggregator.java | 3 +- .../aggregation/LongSumAggregatorFactory.java | 5 +- .../aggregation/LongSumBufferAggregator.java | 3 +- .../query}/aggregation/MaxAggregator.java | 3 +- .../aggregation/MaxAggregatorFactory.java | 5 +- .../aggregation/MaxBufferAggregator.java | 3 +- .../query}/aggregation/MinAggregator.java | 3 +- .../aggregation/MinAggregatorFactory.java | 5 +- .../aggregation/MinBufferAggregator.java | 3 +- .../query}/aggregation/NoopAggregator.java | 4 +- .../aggregation/NoopBufferAggregator.java | 4 +- .../ToLowerCaseAggregatorFactory.java | 5 +- .../post/ArithmeticPostAggregator.java | 2 +- .../post/ConstantPostAggregator.java | 2 +- .../post/FieldAccessPostAggregator.java | 2 +- .../io/druid/query/groupby/GroupByQuery.java | 2 +- .../groupby/GroupByQueryQueryToolChest.java | 6 +- .../groupby/having/AlwaysHavingSpec.java | 2 +- .../query/groupby/having/AndHavingSpec.java | 2 +- .../groupby/having/EqualToHavingSpec.java | 2 +- .../groupby/having/GreaterThanHavingSpec.java | 2 +- .../query/groupby/having/HavingSpec.java | 2 +- .../groupby/having/LessThanHavingSpec.java | 2 +- .../query/groupby/having/NotHavingSpec.java | 2 +- .../query/groupby/having/OrHavingSpec.java | 2 +- .../groupby/orderby/DefaultLimitSpec.java | 2 +- .../query/groupby/orderby/LimitSpec.java | 2 +- .../query/groupby/orderby/NoopLimitSpec.java | 2 +- .../SegmentMetadataQueryQueryToolChest.java | 4 +- .../search/SearchQueryQueryToolChest.java | 2 +- .../spec/MultipleIntervalSegmentSpec.java | 2 +- .../spec/MultipleSpecificSegmentSpec.java | 2 +- .../TimeBoundaryQueryQueryToolChest.java | 4 +- .../TimeseriesQueryQueryToolChest.java | 2 +- .../io/druid/segment/CompressedPools.java | 4 +- .../main/java/io/druid/segment/IndexIO.java | 4 +- .../java/io/druid/segment/IndexMerger.java | 12 ++-- .../java/io/druid/segment/MetricHolder.java | 2 +- .../data/CompressedFloatsIndexedSupplier.java | 4 +- .../CompressedFloatsSupplierSerializer.java | 4 +- .../data/CompressedLongsIndexedSupplier.java | 4 +- .../CompressedLongsSupplierSerializer.java | 4 +- .../data/CompressedObjectStrategy.java | 2 +- .../data/InMemoryCompressedFloats.java | 4 +- .../segment/data/InMemoryCompressedLongs.java | 4 +- .../segment/data/IntBufferIndexedInts.java | 2 +- .../segment/incremental/IncrementalIndex.java | 6 +- .../SpatialDimensionRowFormatter.java | 2 +- .../segment/serde/ComplexMetricExtractor.java | 2 +- .../collections/CombiningIterableTest.java | 1 - .../data/input/InputRowParserSerdeTest.java | 3 +- .../input/ProtoBufInputRowParserTest.java | 1 - .../granularity}/QueryGranularityTest.java | 7 +-- .../jackson/DefaultObjectMapperTest.java | 2 +- .../test/java/io/druid/query/QueriesTest.java | 10 ++-- .../aggregation/CountAggregatorTest.java | 2 +- .../aggregation/DoubleSumAggregatorTest.java | 2 +- .../aggregation/HistogramAggregatorTest.java | 4 +- .../query/aggregation}/HistogramTest.java | 5 +- .../aggregation/JavaScriptAggregatorTest.java | 4 +- .../aggregation/LongSumAggregatorTest.java | 2 +- .../query}/aggregation/MaxAggregatorTest.java | 2 +- .../aggregation/MetricSelectorUtils.java | 2 +- .../query}/aggregation/MinAggregatorTest.java | 2 +- .../aggregation/TestFloatMetricSelector.java | 2 +- .../post/ArithmeticPostAggregatorTest.java | 4 +- .../post/ConstantPostAggregatorTest.java | 2 +- .../post/FieldAccessPostAggregatorTest.java | 4 +- .../query/groupby/having/HavingSpecTest.java | 6 +- .../query/spec/QuerySegmentSpecTest.java | 2 +- .../TimeBoundaryQueryQueryToolChestTest.java | 2 +- .../timeseries/TimeseriesBinaryFnTest.java | 10 ++-- ...ompressedFloatsSupplierSerializerTest.java | 2 +- ...CompressedLongsSupplierSerializerTest.java | 2 +- .../segment/data/IncrementalIndexTest.java | 4 +- .../druid/realtime/DbSegmentPublisher.java | 2 +- .../com/metamx/druid/realtime/Indexer.java | 4 +- .../druid/realtime/RealtimeManager.java | 2 +- .../firehose/ClippedFirehoseFactory.java | 21 ++++++- .../druid/realtime/firehose/Firehose.java | 4 +- .../druid/realtime/firehose/IrcDecoder.java | 21 ++++++- .../realtime/firehose/IrcFirehoseFactory.java | 4 +- .../firehose/KafkaFirehoseFactory.java | 2 +- .../realtime/firehose/PredicateFirehose.java | 21 ++++++- .../firehose/RabbitMQFirehoseFactory.java | 2 +- .../firehose/TimedShutoffFirehoseFactory.java | 21 ++++++- .../firehose/WikipediaIrcDecoder.java | 4 +- .../plumber/RealtimePlumberSchool.java | 10 ++-- .../metamx/druid/realtime/plumber/Sink.java | 2 +- .../guice/DbSegmentPublisherProvider.java | 2 +- .../druid/realtime/RealtimeManagerTest.java | 6 +- .../plumber/RealtimePlumberSchoolTest.java | 2 +- .../druid/realtime/plumber/SinkTest.java | 4 +- .../com/metamx/druid/sql/antlr4/DruidSQL.g4 | 14 ++--- .../druid/coordination/ServerManager.java | 10 ++-- .../metamx/druid/db/DatabaseRuleManager.java | 3 +- .../druid/db/DatabaseRuleManagerProvider.java | 2 + .../druid/db/DatabaseSegmentManager.java | 9 +-- .../db/DatabaseSegmentManagerProvider.java | 2 + .../druid/loading/HdfsDataSegmentPuller.java | 2 +- .../druid/loading/HdfsDataSegmentPusher.java | 2 +- .../druid/loading/LocalDataSegmentPuller.java | 2 +- .../druid/loading/LocalDataSegmentPusher.java | 2 +- .../druid/loading/S3DataSegmentPuller.java | 2 +- .../druid/loading/S3DataSegmentPusher.java | 2 +- .../cassandra/CassandraDataSegmentPuller.java | 2 +- .../cassandra/CassandraDataSegmentPusher.java | 2 +- .../com/metamx/druid/master/DruidMaster.java | 4 +- .../druid/master/DruidMasterCleanup.java | 4 +- .../druid/master/DruidMasterLogger.java | 2 +- .../master/DruidMasterSegmentMerger.java | 6 +- .../com/metamx/druid/master/MasterStats.java | 4 +- .../metamx/druid/metrics/MetricsModule.java | 2 +- .../druid/query/group/GroupByQueryEngine.java | 8 +-- .../group/GroupByQueryRunnerFactory.java | 2 +- .../io/druid/client/BrokerServerView.java | 6 +- .../druid/client/CachingClusteredClient.java | 6 +- .../java/io/druid/client/DataSegment.java | 4 +- .../io/druid/client/ServerInventoryView.java | 2 +- .../io/druid/client/TimelineServerView.java | 2 +- .../io/druid/guice/guice/AnnouncerModule.java | 2 +- .../guice/guice/DruidProcessingModule.java | 4 +- .../main/java/io/druid/server/DruidNode.java | 2 +- .../http/MasterSegmentSettingsResource.java | 3 +- .../initialization/Initialization.java | 2 +- .../server/shard/shard/LinearShardSpec.java | 6 +- .../server/shard/shard/NoneShardSpec.java | 6 +- .../server/shard/shard/NumberedShardSpec.java | 6 +- .../druid/server/shard/shard/ShardSpec.java | 4 +- .../shard/shard/SingleDimensionShardSpec.java | 6 +- .../java/io/druid/server/sql/SQLRunner.java | 4 +- .../SegmentChangeRequestDropTest.java | 2 +- .../SegmentChangeRequestLoadTest.java | 2 +- .../druid/coordination/ZkCoordinatorTest.java | 4 +- .../druid/db/DatabaseSegmentManagerTest.java | 5 +- .../index/brita/SpatialFilterBonusTest.java | 6 +- .../druid/index/brita/SpatialFilterTest.java | 6 +- .../druid/index/v1/IndexMergerTest.java | 2 +- .../com/metamx/druid/index/v1/TestIndex.java | 2 +- .../druid/query/QueryRunnerTestHelper.java | 12 ++-- .../query/group/GroupByQueryRunnerTest.java | 10 ++-- .../GroupByTimeseriesQueryRunnerTest.java | 6 +- .../TimeseriesQueryRunnerBonusTest.java | 4 +- .../timeseries/TimeseriesQueryRunnerTest.java | 6 +- .../java/io/druid/client/DataSegmentTest.java | 2 +- .../client/BatchServerInventoryViewTest.java | 2 +- .../client/selector/ServerSelectorTest.java | 2 +- .../curator/announcement/AnnouncerTest.java | 2 +- .../CuratorInventoryManagerTest.java | 2 +- .../BatchDataSegmentAnnouncerTest.java | 2 +- .../shard/shard/NumberedShardSpecTest.java | 4 +- .../shard/SingleDimensionShardSpecTest.java | 4 +- .../src/main/java/io/druid/cli/CliPeon.java | 2 +- .../java/io/druid/cli/ServerRunnable.java | 21 ++++++- .../initialization}/LogLevelAdjuster.java | 4 +- .../LogLevelAdjusterMBean.java | 4 +- 285 files changed, 857 insertions(+), 620 deletions(-) delete mode 100644 common/src/main/java/com/metamx/druid/config/ConfigManagerConfig.java delete mode 100644 common/src/main/java/com/metamx/druid/config/ConfigSerde.java delete mode 100644 common/src/main/java/com/metamx/druid/utils/SocketUtil.java rename common/src/main/java/{com/metamx/druid => io/druid/collections}/CombiningIterable.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/collections}/CombiningIterator.java (96%) rename common/src/main/java/{com/metamx/druid/collect => io/druid/collections}/CountingMap.java (95%) rename common/src/main/java/{com/metamx/druid => io/druid/collections}/IntList.java (97%) rename common/src/main/java/{com/metamx/druid/collect => io/druid/collections}/OrderedMergeIterator.java (98%) rename common/src/main/java/{com/metamx/druid/collect => io/druid/collections}/OrderedMergeSequence.java (98%) rename common/src/main/java/{com/metamx/druid/collect => io/druid/collections}/ResourceHolder.java (91%) rename common/src/main/java/{com/metamx/druid/collect => io/druid/collections}/StupidPool.java (96%) rename common/src/main/java/{com/metamx/druid/collect => io/druid/collections}/StupidResourceHolder.java (93%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/config/ConfigManager.java (90%) create mode 100644 common/src/main/java/io/druid/common/config/ConfigManagerConfig.java create mode 100644 common/src/main/java/io/druid/common/config/ConfigSerde.java rename common/src/main/java/{com/metamx/druid => io/druid/common}/config/JacksonConfigManager.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/guava/CombiningSequence.java (98%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/guava/DSuppliers.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/guava/FileOutputSupplier.java (94%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/guava/GuavaUtils.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/guava/Runnables.java (93%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/guava/ThreadRenamingCallable.java (94%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/guava/ThreadRenamingRunnable.java (93%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/utils/CompressionUtils.java (98%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/utils/JodaUtils.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/utils/PropUtils.java (95%) rename common/src/main/java/{com/metamx/druid => io/druid/common}/utils/SerializerUtils.java (98%) create mode 100644 common/src/main/java/io/druid/common/utils/SocketUtil.java rename common/src/main/java/{com/metamx => io}/druid/concurrent/Execs.java (95%) rename common/src/main/java/{com/metamx/druid => io/druid/data}/input/InputRow.java (96%) rename common/src/main/java/{com/metamx/druid => io/druid/data}/input/MapBasedInputRow.java (94%) rename common/src/main/java/{com/metamx/druid => io/druid/data}/input/MapBasedRow.java (98%) rename common/src/main/java/{com/metamx/druid => io/druid/data}/input/Row.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/data}/input/Rows.java (94%) rename common/src/main/java/{com/metamx => io}/druid/db/DbConnector.java (98%) rename common/src/main/java/{com/metamx => io}/druid/db/DbConnectorConfig.java (96%) rename common/src/main/java/{com/metamx => io}/druid/db/DbTablesConfig.java (73%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/LogicalSegment.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/TimelineObjectHolder.java (95%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/VersionedIntervalTimeline.java (98%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/ImmutablePartitionHolder.java (93%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/IntegerPartitionChunk.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/LinearPartitionChunk.java (66%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/NumberedPartitionChunk.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/PartitionChunk.java (96%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/PartitionHolder.java (97%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/SingleElementPartitionChunk.java (96%) rename common/src/main/java/{com/metamx/druid => io/druid/timeline}/partition/StringPartitionChunk.java (97%) rename common/src/test/java/{com/metamx/druid => io/druid/collections}/IntListTest.java (95%) rename common/src/test/java/{com/metamx/druid/collect => io/druid/collections}/IteratorShell.java (93%) rename common/src/test/java/{com/metamx/druid/collect => io/druid/collections}/OrderedMergeIteratorTest.java (98%) rename common/src/test/java/{com/metamx/druid/collect => io/druid/collections}/OrderedMergeSequenceTest.java (98%) rename common/src/test/java/{com/metamx/druid => io/druid/common}/guava/CombiningSequenceTest.java (98%) rename common/src/test/java/{com/metamx/druid => io/druid/common}/utils/JodaUtilsTest.java (97%) rename common/src/test/java/{com/metamx/druid => io/druid/timeline}/VersionedIntervalTimelineTest.java (99%) rename common/src/test/java/{com/metamx/druid => io/druid/timeline}/partition/IntegerPartitionChunkTest.java (94%) rename common/src/test/java/{com/metamx/druid => io/druid/timeline}/partition/StringPartitionChunkTest.java (94%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/AggregatorsModule.java (76%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/CommaListJoinDeserializer.java (94%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/CommaListJoinSerializer.java (95%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/DefaultObjectMapper.java (98%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/DruidDefaultSerializersModule.java (99%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/JacksonModule.java (98%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/JodaStuff.java (98%) rename {common/src/main/java/com/metamx => processing/src/main/java/io}/druid/jackson/QueryGranularityModule.java (98%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/CountAggregator.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/CountAggregatorFactory.java (93%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/CountBufferAggregator.java (93%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/DoubleSumAggregator.java (95%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/DoubleSumAggregatorFactory.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/DoubleSumBufferAggregator.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/Histogram.java (99%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/HistogramAggregator.java (95%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/HistogramAggregatorFactory.java (96%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/HistogramBufferAggregator.java (96%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/HistogramVisual.java (98%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/JavaScriptAggregator.java (95%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/JavaScriptAggregatorFactory.java (97%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/JavaScriptBufferAggregator.java (95%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/LongSumAggregator.java (95%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/LongSumAggregatorFactory.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/LongSumBufferAggregator.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/MaxAggregator.java (95%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/MaxAggregatorFactory.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/MaxBufferAggregator.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/MinAggregator.java (95%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/MinAggregatorFactory.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/MinBufferAggregator.java (94%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/NoopAggregator.java (93%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/NoopBufferAggregator.java (92%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/ToLowerCaseAggregatorFactory.java (93%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/post/ArithmeticPostAggregator.java (98%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/post/ConstantPostAggregator.java (97%) rename {common/src/main/java/io/druid/query/aggregation => processing/src/main/java/io/druid/query}/aggregation/post/FieldAccessPostAggregator.java (97%) rename {common/src/test/java/com/metamx/druid => processing/src/test/java/io/druid/granularity}/QueryGranularityTest.java (98%) rename {common/src/test/java/com/metamx => processing/src/test/java/io}/druid/jackson/DefaultObjectMapperTest.java (97%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/CountAggregatorTest.java (97%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/DoubleSumAggregatorTest.java (98%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/HistogramAggregatorTest.java (97%) rename {common/src/test/java/com/metamx/druid/histogram => processing/src/test/java/io/druid/query/aggregation}/HistogramTest.java (94%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/JavaScriptAggregatorTest.java (98%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/LongSumAggregatorTest.java (98%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/MaxAggregatorTest.java (97%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/MetricSelectorUtils.java (96%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/MinAggregatorTest.java (97%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/TestFloatMetricSelector.java (96%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/post/ArithmeticPostAggregatorTest.java (96%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/post/ConstantPostAggregatorTest.java (97%) rename {common/src/test/java/io/druid/query/aggregation => processing/src/test/java/io/druid/query}/aggregation/post/FieldAccessPostAggregatorTest.java (93%) rename {common/src/main/java/com/metamx/druid/log => services/src/main/java/io/druid/initialization}/LogLevelAdjuster.java (96%) rename {common/src/main/java/com/metamx/druid/log => services/src/main/java/io/druid/initialization}/LogLevelAdjusterMBean.java (91%) diff --git a/common/pom.xml b/common/pom.xml index fba4b3c660e..1716a004688 100644 --- a/common/pom.xml +++ b/common/pom.xml @@ -1,7 +1,7 @@