This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 141c214b469 docs: add note about finalizeaggregations for sql-based
ingestion (#15631)
add 5d1e66b8f96 Allow broker to use catalog for datasource schemas for SQL
queries (#15469)
No new revisions were added by this update.
Summary of changes:
extensions-core/druid-catalog/pom.xml | 112 +++-------
.../druid/catalog/guice/CatalogBrokerModule.java | 100 +++++++++
.../catalog/http/CatalogListenerResource.java | 18 ++
.../apache/druid/catalog/http/CatalogResource.java | 3 +-
.../druid/catalog/sql/LiveCatalogResolver.java | 216 +++++++++++++++++++
.../druid/catalog/sync/CachedMetadataCatalog.java | 41 ++++
.../apache/druid/catalog/sync/CatalogClient.java | 4 +-
.../druid/catalog/sync/CatalogUpdateListener.java | 2 +
.../druid/catalog/sync/CatalogUpdateNotifier.java | 16 +-
.../druid/catalog/sync/CatalogUpdateReceiver.java | 56 +++++
.../org.apache.druid.initialization.DruidModule | 1 +
.../apache/druid/catalog/sql/CatalogQueryTest.java | 124 +++++++++++
.../apache/druid/catalog/sql/LiveCatalogTest.java | 228 +++++++++++++++++++++
.../druid/catalog/storage/TableManagerTest.java | 4 +-
.../druid/catalog/sync/CatalogCacheTest.java | 154 ++++++++++++++
.../apache/druid/catalog/sync/CatalogSyncTest.java | 28 +--
.../apache/druid/catalog/sync/MockCatalogSync.java | 10 +
.../server/http/catalog/CatalogResourceTest.java | 6 +-
.../druid/server/http/catalog/EditorTest.java | 12 +-
.../ingest/insertFromTable-logicalPlan.txt | 3 +
.../insertWithCatalogClusteredBy-logicalPlan.txt | 4 +
.../insertWithCatalogClusteredBy2-logicalPlan.txt | 4 +
.../ingest/insertWithClusteredBy-logicalPlan.txt | 4 +
.../ingest/insertWithClusteredBy2-logicalPlan.txt | 4 +
.../org/apache/druid/msq/test/MSQTestBase.java | 3 +-
.../catalog/model/table/S3InputSourceDefnTest.java | 32 +--
.../apache/druid/catalog/model/CatalogUtils.java | 2 +-
.../org/apache/druid/catalog/model/ColumnSpec.java | 41 ++--
.../org/apache/druid/catalog/model/Columns.java | 102 +++++----
.../org/apache/druid/catalog/model/TableId.java | 5 +
.../catalog/model/facade/DatasourceFacade.java | 83 ++++++++
.../catalog/model/facade/ExternalTableFacade.java | 3 +-
.../druid/catalog/model/facade/TableFacade.java | 6 +-
.../catalog/model/table/BaseInputSourceDefn.java | 2 +-
.../druid/catalog/model/table/DatasourceDefn.java | 12 +-
.../catalog/model/table/ExternalTableDefn.java | 5 +
.../model/table/FormattedInputSourceDefn.java | 4 +-
.../druid/catalog/model/table/TableBuilder.java | 2 +-
.../catalog/model/table/BaseExternTableTest.java | 4 +-
.../catalog/model/table/CsvInputFormatTest.java | 6 +-
.../catalog/model/table/DatasourceTableTest.java | 109 +++++-----
.../model/table/DelimitedInputFormatTest.java | 6 +-
.../catalog/model/table/ExternalTableTest.java | 28 +--
.../model/table/HttpInputSourceDefnTest.java | 36 ++--
.../model/table/InlineInputSourceDefnTest.java | 22 +-
.../catalog/model/table/JsonInputFormatTest.java | 6 +-
.../model/table/LocalInputSourceDefnTest.java | 32 +--
.../druid/sql/calcite/schema/DruidSchema.java | 10 +-
.../druid/sql/calcite/table/DatasourceTable.java | 129 +++++++++++-
.../druid/sql/calcite/IngestTableFunctionTest.java | 4 +-
.../druid/sql/calcite/SqlTestFrameworkConfig.java | 1 +
.../calcite/schema/DruidSchemaNoDataInitTest.java | 3 +-
.../sql/calcite/schema/InformationSchemaTest.java | 4 +-
.../druid/sql/calcite/schema/SystemSchemaTest.java | 3 +-
.../sql/calcite/util/QueryFrameworkUtils.java | 18 +-
.../druid/sql/calcite/util/SqlTestFramework.java | 8 +-
56 files changed, 1511 insertions(+), 374 deletions(-)
create mode 100644
extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/guice/CatalogBrokerModule.java
create mode 100644
extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sql/LiveCatalogResolver.java
create mode 100644
extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogUpdateReceiver.java
create mode 100644
extensions-core/druid-catalog/src/test/java/org/apache/druid/catalog/sql/CatalogQueryTest.java
create mode 100644
extensions-core/druid-catalog/src/test/java/org/apache/druid/catalog/sql/LiveCatalogTest.java
create mode 100644
extensions-core/druid-catalog/src/test/java/org/apache/druid/catalog/sync/CatalogCacheTest.java
create mode 100644
extensions-core/druid-catalog/src/test/resources/calcite/expected/ingest/insertFromTable-logicalPlan.txt
create mode 100644
extensions-core/druid-catalog/src/test/resources/calcite/expected/ingest/insertWithCatalogClusteredBy-logicalPlan.txt
create mode 100644
extensions-core/druid-catalog/src/test/resources/calcite/expected/ingest/insertWithCatalogClusteredBy2-logicalPlan.txt
create mode 100644
extensions-core/druid-catalog/src/test/resources/calcite/expected/ingest/insertWithClusteredBy-logicalPlan.txt
create mode 100644
extensions-core/druid-catalog/src/test/resources/calcite/expected/ingest/insertWithClusteredBy2-logicalPlan.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
