You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by cw...@apache.org on 2023/08/11 19:47:23 UTC
[druid] branch master updated (c8a11702db -> afe22907a5)
This is an automated email from the ASF dual-hosted git repository.
cwylie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from c8a11702db Support broadcast segmetns (#14789)
add afe22907a5 Calcite upgrade 1.35 (#14510)
No new revisions were added by this update.
Summary of changes:
docs/api-reference/sql-jdbc.md | 55 +-
docs/querying/sql-aggregations.md | 4 +-
.../DoublesSketchApproxQuantileSqlAggregator.java | 14 +-
...DoublesSketchListArgBaseOperatorConversion.java | 5 +-
.../sql/DoublesSketchSqlAggregatorTest.java | 7 +-
...dBucketsHistogramQuantileSqlAggregatorTest.java | 7 +-
.../histogram/sql/QuantileSqlAggregatorTest.java | 7 +-
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 3 +-
.../org/apache/druid/msq/exec/MSQSelectTest.java | 16 +-
.../variance/sql/VarianceSqlAggregatorTest.java | 34 +-
licenses.yaml | 74 ++-
pom.xml | 36 +-
.../org/apache/druid/error/DruidException.java | 6 +
.../java/org/apache/druid/query/DataSource.java | 3 +-
...nestDataSource.java => FilteredDataSource.java} | 122 ++---
.../org/apache/druid/query/UnnestDataSource.java | 10 +-
.../druid/segment/FilteredStorageAdapter.java | 145 +++++
.../druid/segment/UnnestSegmentReference.java | 120 ----
.../druid/segment/WrappedSegmentReference.java} | 54 +-
.../apache/druid/query/FilteredDataSourceTest.java | 153 ++++++
.../apache/druid/query/QueryRunnerTestHelper.java | 17 +
.../query/scan/UnnestScanQueryRunnerTest.java | 68 +++
sql/pom.xml | 17 +-
sql/src/main/codegen/config.fmpp | 375 +------------
sql/src/main/codegen/includes/common.ftl | 10 +-
sql/src/main/codegen/includes/from.ftl | 605 ++++++++++-----------
sql/src/main/codegen/includes/insert.ftl | 3 +-
sql/src/main/codegen/includes/replace.ftl | 5 +-
.../calcite/prepare/BaseDruidSqlValidator.java | 6 +-
.../sql/avatica/AbstractDruidJdbcStatement.java | 25 +-
.../builtin/EarliestLatestBySqlAggregator.java | 27 +-
...qlAggregator.java => LiteralSqlAggregator.java} | 66 +--
.../aggregation/builtin/StringSqlAggregator.java | 33 +-
.../aggregation/builtin/SumSqlAggregator.java | 89 +--
.../expression/BasicOperandTypeChecker.java | 229 ++++++++
.../calcite/expression/OperatorConversions.java | 31 +-
.../builtin/NestedDataOperatorConversions.java | 110 ++--
...nversion.java => SearchOperatorConversion.java} | 66 ++-
.../external/BaseUserDefinedTableMacro.java | 124 ++---
.../sql/calcite/external/DruidTableMacro.java | 18 +-
.../external/DruidUserDefinedTableMacro.java | 1 -
.../druid/sql/calcite/external/Externals.java | 45 +-
.../external/SchemaAwareUserDefinedTableMacro.java | 28 +-
.../sql/calcite/parser/DruidSqlParserUtils.java | 55 +-
.../druid/sql/calcite/planner/CalcitePlanner.java | 295 ++++++----
.../sql/calcite/planner/CalciteRulesManager.java | 227 ++++----
.../apache/druid/sql/calcite/planner/Calcites.java | 23 +-
.../sql/calcite/planner/DruidOperatorTable.java | 21 +-
.../druid/sql/calcite/planner/DruidPlanner.java | 63 ++-
.../sql/calcite/planner/DruidSqlValidator.java | 6 +-
.../druid/sql/calcite/planner/DruidTypeSystem.java | 18 +-
.../druid/sql/calcite/planner/PlannerContext.java | 8 +
.../druid/sql/calcite/planner/PlannerFactory.java | 36 +-
.../druid/sql/calcite/planner/QueryHandler.java | 2 +-
.../calcite/planner/RelParameterizerShuttle.java | 14 +
.../calcite/planner/SqlParameterizerShuttle.java | 2 +-
.../sql/calcite/rel/DruidCorrelateUnnestRel.java | 204 ++++++-
.../druid/sql/calcite/rel/DruidJoinQueryRel.java | 6 -
.../apache/druid/sql/calcite/rel/DruidQuery.java | 8 +-
.../druid/sql/calcite/rel/DruidUnnestRel.java | 19 +-
.../org/apache/druid/sql/calcite/rel/Grouping.java | 2 +-
.../druid/sql/calcite/rel/PartialDruidQuery.java | 1 +
.../apache/druid/sql/calcite/rel/Projection.java | 6 +-
.../rule/CorrelateFilterLTransposeRule.java | 67 ---
.../sql/calcite/rule/DruidCorrelateUnnestRule.java | 119 ++--
.../sql/calcite/rule/DruidFilterUnnestRule.java | 6 +-
.../druid/sql/calcite/rule/DruidJoinRule.java | 2 +-
.../sql/calcite/rule/DruidRelToDruidRule.java | 6 +-
.../apache/druid/sql/calcite/rule/DruidRules.java | 5 +-
.../rule/FilterJoinExcludePushToChildRule.java | 40 +-
.../druid/sql/calcite/rule/GroupByRules.java | 7 +-
.../rule/ProjectAggregatePruneUnusedCallRule.java | 6 +-
.../druid/sql/calcite/rule/SortCollapseRule.java | 2 +-
.../logical/DruidAggregateCaseToFilterRule.java | 2 +-
.../druid/sql/calcite/table/DatasourceTable.java | 2 +-
.../apache/druid/sql/calcite/table/DruidTable.java | 35 ++
.../druid/sql/calcite/table/InlineTable.java | 2 +-
.../druid/sql/calcite/table/LookupTable.java | 2 +-
.../druid/sql/calcite/view/DruidViewMacro.java | 2 +-
.../org/apache/druid/sql/SqlStatementTest.java | 6 +-
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 12 +-
.../druid/sql/avatica/DruidStatementTest.java | 8 +-
.../druid/sql/calcite/CalciteArraysQueryTest.java | 340 ++++++++----
.../druid/sql/calcite/CalciteJoinQueryTest.java | 154 +++---
.../sql/calcite/CalciteNestedDataQueryTest.java | 5 +-
.../sql/calcite/CalciteParameterQueryTest.java | 12 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 311 ++++++-----
.../druid/sql/calcite/CalciteReplaceDmlTest.java | 5 +-
.../druid/sql/calcite/CalciteWindowQueryTest.java | 8 +
.../calcite/DecoupledPlanningCalciteQueryTest.java | 30 +
.../expression/OperatorConversionsTest.java | 15 +-
.../calcite/parser/DruidSqlParserUtilsTest.java | 207 +++++--
.../sql/calcite/parser/DruidSqlUnparseTest.java | 12 +-
.../org/apache/druid/sql/http/SqlResourceTest.java | 2 +-
...mExternalWithoutSecuritySupport-logicalPlan.txt | 2 +-
.../expected/ingest/httpExtern-logicalPlan.txt | 2 +-
.../ingest/insertFromExternal-logicalPlan.txt | 2 +-
.../ingest/insertWithClusteredBy-logicalPlan.txt | 2 +-
.../ingest/insertWithPartitionedBy-logicalPlan.txt | 2 +-
.../expected/ingest/localExtern-logicalPlan.txt | 2 +-
.../calcite/tests/window/simpleSum.sqlTest | 2 +-
.../wikipediaAggregationsMultipleOrdering.sqlTest | 2 +-
.../window/wikipediaCumulativeOrdered.sqlTest | 7 +-
.../window/wikipediaFramedAggregations.sqlTest | 2 +-
.../tests/window/wikipediaSimplePartition.sqlTest | 32 +-
.../wikipediaSimplePartitionInitialSort.sqlTest | 16 +-
106 files changed, 3128 insertions(+), 2266 deletions(-)
copy processing/src/main/java/org/apache/druid/query/{UnnestDataSource.java => FilteredDataSource.java} (59%)
create mode 100644 processing/src/main/java/org/apache/druid/segment/FilteredStorageAdapter.java
delete mode 100644 processing/src/main/java/org/apache/druid/segment/UnnestSegmentReference.java
copy processing/src/{test/java/org/apache/druid/segment/TestSegmentForAs.java => main/java/org/apache/druid/segment/WrappedSegmentReference.java} (53%)
create mode 100644 processing/src/test/java/org/apache/druid/query/FilteredDataSourceTest.java
copy sql/src/main/java/org/apache/druid/sql/calcite/aggregation/builtin/{SimpleSqlAggregator.java => LiteralSqlAggregator.java} (51%)
create mode 100644 sql/src/main/java/org/apache/druid/sql/calcite/expression/BasicOperandTypeChecker.java
copy sql/src/main/java/org/apache/druid/sql/calcite/expression/builtin/{RepeatOperatorConversion.java => SearchOperatorConversion.java} (52%)
delete mode 100644 sql/src/main/java/org/apache/druid/sql/calcite/rule/CorrelateFilterLTransposeRule.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org