ASF Git Repos - druid.git/commit

author	Maytas Monsereenusorn <maytasm@apache.org>
	Fri, 8 Apr 2022 18:02:02 +0000 (11:02 -0700)
committer	GitHub <noreply@github.com>
	Fri, 8 Apr 2022 18:02:02 +0000 (11:02 -0700)
commit	8edea5a82dfdb34c3177c0efd7a79bae54751ab8
tree	628a4bc08841f230e51b2c219722c838f0ad0207	tree \| snapshot
parent	bf96ddf5bac50e5e9ae778eb28ee300fea6fc62f	commit \| diff

Add a new flag for ingestion to preserve existing metrics (#12185)

* add impl

* add impl

* fix checkstyle

* add impl

* add unit test

* fix stuff

* fix stuff

* fix stuff

* add unit test

* add more unit tests

* add more unit tests

* add IT

* add IT

* add IT

* add IT

* add ITs

* address comments

* fix test

* fix test

* fix test

* address comments

* address comments

* address comments

* fix conflict

* fix checkstyle

* address comments

* fix test

* fix checkstyle

* fix test

* fix test

* fix IT

26 files changed:

core/src/main/java/org/apache/druid/data/input/InputRowSchema.java		diff \| blob \| history
indexing-service/src/main/java/org/apache/druid/indexing/input/DruidInputSource.java		diff \| blob \| history
indexing-service/src/main/java/org/apache/druid/indexing/input/InputRowSchemas.java		diff \| blob \| history
indexing-service/src/test/java/org/apache/druid/indexing/common/task/ClientCompactionTaskQuerySerdeTest.java		diff \| blob \| history
indexing-service/src/test/java/org/apache/druid/indexing/input/DruidInputSourceTest.java		diff \| blob \| history
indexing-service/src/test/java/org/apache/druid/indexing/input/InputRowSchemasTest.java		diff \| blob \| history
integration-tests/pom.xml		diff \| blob \| history
integration-tests/src/main/java/org/apache/druid/testing/utils/CompactionUtil.java		diff \| blob \| history
integration-tests/src/test/java/org/apache/druid/tests/coordinator/duty/ITAutoCompactionTest.java		diff \| blob \| history
integration-tests/src/test/java/org/apache/druid/tests/coordinator/duty/ITAutoCompactionUpgradeTest.java		diff \| blob \| history
integration-tests/src/test/resources/indexer/wikipedia_index_no_rollup_preserve_metric.json	[new file with mode: 0644]	blob
integration-tests/src/test/resources/indexer/wikipedia_index_rollup_preserve_metric.json	[new file with mode: 0644]	blob
integration-tests/src/test/resources/indexer/wikipedia_index_sketch_queries.json	[new file with mode: 0644]	blob
processing/src/main/java/org/apache/druid/segment/incremental/AppendableIndexBuilder.java		diff \| blob \| history
processing/src/main/java/org/apache/druid/segment/incremental/IncrementalIndex.java		diff \| blob \| history
processing/src/main/java/org/apache/druid/segment/incremental/OnheapIncrementalIndex.java		diff \| blob \| history
processing/src/test/java/org/apache/druid/segment/data/IncrementalIndexTest.java		diff \| blob \| history
processing/src/test/java/org/apache/druid/segment/incremental/IncrementalIndexAdapterTest.java		diff \| blob \| history
processing/src/test/java/org/apache/druid/segment/incremental/OnheapIncrementalIndexBenchmark.java		diff \| blob \| history
server/src/main/java/org/apache/druid/client/indexing/ClientCompactionTaskQueryTuningConfig.java		diff \| blob \| history
server/src/main/java/org/apache/druid/server/coordinator/UserCompactionTaskQueryTuningConfig.java		diff \| blob \| history
server/src/test/java/org/apache/druid/server/coordinator/DataSourceCompactionConfigTest.java		diff \| blob \| history
server/src/test/java/org/apache/druid/server/coordinator/UserCompactionTaskQueryTuningConfigTest.java		diff \| blob \| history
server/src/test/java/org/apache/druid/server/coordinator/duty/CompactSegmentsTest.java		diff \| blob \| history
server/src/test/java/org/apache/druid/server/coordinator/duty/NewestSegmentFirstIteratorTest.java		diff \| blob \| history
server/src/test/java/org/apache/druid/server/coordinator/duty/NewestSegmentFirstPolicyTest.java		diff \| blob \| history

Apache Druid: a high performance real-time analytics database.

RSS Atom