This is an automated email from the ASF dual-hosted git repository.
karan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 16517e348e6 Suppress CVE (#16851)
add 3b88b57d709 Add configurable final stages to MSQ ingestion queries
(#16699)
No new revisions were added by this update.
Summary of changes:
.../org/apache/druid/msq/exec/ControllerImpl.java | 391 ++-------------------
.../org/apache/druid/msq/guice/MSQSqlModule.java | 2 +
.../msq/guice/MSQTerminalStageSpecFactory.java | 21 +-
.../druid/msq/indexing/MSQCompactionRunner.java | 3 +-
.../destination/DataSourceMSQDestination.java | 23 +-
.../destination/SegmentGenerationStageSpec.java | 115 ++++++
.../destination/SegmentGenerationUtils.java | 374 ++++++++++++++++++++
.../indexing/destination/TerminalStageSpec.java | 16 +-
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 12 +-
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 19 +-
.../msq/util/PassthroughAggregatorFactory.java | 2 +-
.../druid/msq/exec/MSQParseExceptionsTest.java | 4 +-
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 3 -
.../msq/indexing/MSQCompactionRunnerTest.java | 6 +-
.../druid/msq/indexing/MSQControllerTaskTest.java | 1 +
.../destination/DataSourceMSQDestinationTest.java | 17 +
.../sql/resources/SqlStatementResourceTest.java | 1 +
.../org/apache/druid/msq/test/MSQTestBase.java | 5 +-
.../msq/test/MSQTestDelegateDataSegmentPusher.java | 2 +-
.../msq/util/SqlStatementResourceHelperTest.java | 1 +
20 files changed, 612 insertions(+), 406 deletions(-)
copy
sql/src/main/java/org/apache/druid/sql/calcite/planner/convertlet/DruidConvertletFactory.java
=>
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQTerminalStageSpecFactory.java
(58%)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/destination/SegmentGenerationStageSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/destination/SegmentGenerationUtils.java
copy
processing/src/main/java/org/apache/druid/query/metadata/metadata/ColumnIncluderator.java
=>
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/destination/TerminalStageSpec.java
(63%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
