You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/11/26 10:03:33 UTC
[ignite-3] branch ignite-15784 updated (fd73877 -> 47b2268)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15784
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from fd73877 Fix tests.
add 26025e8 IGNITE-15912 Merge SQL calcite query contexts refactoring to 3.0 (#454)
add 2b472d2 fix style
add fe2421f IGNITE-15893 Extend table views test coverage. (#450)
add 8a384c0 IGNITE-15965 Fix a race between cluster start and setting the local member (#463)
add 77145a9 IGNITE-15972 Improve network processor error message (#465)
add 53ef6e3 IGNITE-15700 Rename tableName -> name function (#459)
add 4572913 IGNITE-15838 Integrate plugin system in current SQL engine (#464)
add ecc2037 IGNITE-15307 Reuse Netty infrastructure from network module in thin client handler (#466)
add 2abd5b9 IGNITE-15727 DDL to Internal TableManager API reveal - Fixes #441.
add ea0a828 IGNITE-15724 Do not allow to start several meta storage raft groups. Fixes #461
add 587776d IGNITE-15729 Fixed problem with starting node from cli. Fixes #470
add c60b8f5 IGNITE-15132 Reuse Netty infrastructure from network module in REST module (#469)
add 8ab0d1d IGNITE-15971 Fix problems with dynamic configuration (#467)
add 69992a5 IGNITE-16005 Disabled flaky test (SqlExampleTest)
add 47b2268 Merge branch 'main' into ignite-15784
No new revisions were added by this update.
Summary of changes:
examples/config/ignite-config.json | 1 +
.../ignite/example/sql/jdbc/SqlExamplesTest.java | 6 +-
...tion.java => ColumnAlreadyExistsException.java} | 12 +-
...ption.java => IndexAlreadyExistsException.java} | 12 +-
.../ignite/lang/TableAlreadyExistsException.java | 8 +-
.../main/java/org/apache/ignite/table/Table.java | 2 +-
.../processors/query/calcite/QueryCancel.java | 92 +++
...SqlCursor.java => QueryCancelledException.java} | 21 +-
.../query/calcite/SqlQueryProcessor.java | 62 +-
.../query/calcite/exec/ExchangeServiceImpl.java | 15 +-
.../query/calcite/exec/ExecutionContext.java | 79 ++-
.../query/calcite/exec/ExecutionServiceImpl.java | 138 +++--
.../query/calcite/exec/LogicalRelImplementor.java | 28 +-
.../calcite/exec/exp/agg/AccumulatorsFactory.java | 3 +-
.../ExternalConvention.java} | 26 +-
.../query/calcite/extension/SqlExtension.java | 47 +-
.../query/calcite/externalize/RelJson.java | 7 +-
.../query/calcite/externalize/RelJsonReader.java | 23 +-
.../query/calcite/externalize/RelJsonWriter.java | 7 +-
.../calcite/metadata/IgniteMdFragmentMapping.java | 122 ++--
.../query/calcite/metadata/IgniteMetadata.java | 8 +-
.../query/calcite/metadata/RelMetadataQueryEx.java | 7 +-
.../calcite/prepare/AbstractMultiStepPlan.java | 5 +-
.../processors/query/calcite/prepare/Cloner.java | 214 +------
.../processors/query/calcite/prepare/Fragment.java | 32 +-
.../query/calcite/prepare/FragmentPlan.java | 3 +-
.../query/calcite/prepare/IgniteRelShuttle.java | 6 +
.../query/calcite/prepare/MappingQueryContext.java | 62 ++
.../query/calcite/prepare/MultiStepPlan.java | 3 +-
.../query/calcite/prepare/PlannerPhase.java | 302 +++++----
.../query/calcite/prepare/PlanningContext.java | 213 +------
.../query/calcite/prepare/QueryPlanCache.java | 11 +-
.../query/calcite/prepare/QueryPlanCacheImpl.java | 5 +-
.../query/calcite/prepare/QueryTemplate.java | 17 +-
.../processors/query/calcite/prepare/Splitter.java | 7 +
...{IgniteTrimExchange.java => IgniteGateway.java} | 95 +--
.../query/calcite/rel/IgniteRelVisitor.java | 5 +
.../query/calcite/schema/IgniteTable.java | 4 +
.../query/calcite/schema/IgniteTableImpl.java | 4 +-
.../query/calcite/schema/InternalIgniteTable.java | 4 +-
.../query/calcite/schema/SchemaHolder.java | 5 +-
.../query/calcite/schema/SchemaHolderImpl.java | 52 +-
.../processors/query/calcite/trait/TraitUtils.java | 105 ++--
.../query/calcite/util/AbstractQueryContext.java} | 27 +-
.../query/calcite/util/BaseQueryContext.java | 246 ++++++++
.../processors/query/calcite/util/Commons.java | 22 +-
.../query/calcite/util/IgniteMethod.java | 5 +-
.../processors/query/calcite/util/TypeUtils.java | 5 +-
.../query/calcite/StopCalciteModuleTest.java | 2 +-
.../query/calcite/exec/RuntimeSortedIndexTest.java | 15 +-
.../calcite/exec/rel/AbstractExecutionTest.java | 15 +-
.../query/calcite/planner/AbstractPlannerTest.java | 43 +-
.../query/calcite/planner/PlannerTest.java | 146 ++---
.../query/calcite/planner/UnionPlannerTest.java | 1 -
modules/client-handler/pom.xml | 5 +
.../ignite/client/handler/ItClientHandlerTest.java | 20 +-
.../ignite/client/handler/ClientHandlerModule.java | 53 +-
.../handler/requests/sql/JdbcMetadataCatalog.java | 26 +-
.../requests/table/ClientTablesGetRequest.java | 2 +-
.../ignite/internal/client/table/ClientTable.java | 2 +-
.../apache/ignite/client/AbstractClientTest.java | 44 +-
.../org/apache/ignite/client/ClientTableTest.java | 2 +-
.../org/apache/ignite/client/ClientTablesTest.java | 10 +-
.../org/apache/ignite/client/ReconnectTest.java | 129 ++--
.../java/org/apache/ignite/client/TestServer.java | 96 +++
.../ignite/client/fakes/FakeInternalTable.java | 2 +-
.../configuration/processor/ItProcessorTest.java | 12 +
.../ConfigurationSchemaWithWrongPostfix.java} | 14 +-
.../configuration/processor/Processor.java | 184 +++---
.../configuration/ConfigurationChanger.java | 30 +-
.../configuration/ConfigurationManager.java | 4 -
.../configuration/ConfigurationRegistry.java | 44 +-
.../asm/ConfigurationAsmGenerator.java | 20 +-
.../internal/configuration/tree/InnerNode.java | 35 +-
.../configuration/util/ConfigurationFlattener.java | 10 +-
.../configuration/util/ConfigurationUtil.java | 11 +-
.../configuration/ConfigurationRegistryTest.java | 19 +
.../ConfigurationAnyListenerTest.java | 4 +-
.../notifications/ConfigurationListenerTest.java | 60 +-
.../java/org/apache/ignite/logger/NullLogger.java | 173 ++++++
.../client/ItMetaStorageServiceTest.java | 3 +-
.../internal/metastorage/MetaStorageManager.java | 8 +
.../ItTransferableObjectProcessorTest.java | 27 +-
.../processor/TransferableObjectProcessor.java | 28 +-
.../ignite/network/ClusterServiceFactory.java | 37 --
modules/network/pom.xml | 10 +
.../network/netty/ItConnectionManagerTest.java | 60 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 30 +-
.../network/scalecube/ItNodeRestartsTest.java | 3 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 3 +-
.../ignite/utils/ClusterServiceTestUtils.java | 26 +-
.../internal/network/netty/ConnectionManager.java | 18 +-
.../ignite/internal/network/netty/NettyServer.java | 176 +-----
.../ignite/network/NettyBootstrapFactory.java | 149 +++++
.../scalecube/ScaleCubeClusterServiceFactory.java | 81 ++-
.../scalecube/ScaleCubeMessagingService.java | 2 +-
.../scalecube/ScaleCubeTopologyService.java | 22 +-
.../internal/network/netty/NettyServerTest.java | 81 +--
.../apache/ignite/internal/raft/ItLozaTest.java | 3 +-
.../service/ItAbstractListenerSnapshotTest.java | 3 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 3 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 2 +-
modules/rest/pom.xml | 5 +
.../java/org/apache/ignite/rest/RestModule.java | 47 +-
.../ignite/internal/calcite/ItIndexSpoolTest.java | 2 +-
.../internal/calcite/ItSqlExtensionTest.java | 69 +++
.../internal/calcite/extension/TestExtension.java | 168 +++++
.../calcite/extension/TestFilterConverterRule.java | 59 ++
.../calcite/extension/TestPhysFilter.java} | 82 ++-
.../calcite/extension/TestPhysTableScan.java} | 59 +-
.../internal/calcite/extension/TestTableImpl.java | 101 +++
.../internal/runner/app/IgniteCliRunnerTest.java | 27 +-
.../ignite/internal/runner/app/ItIgnitionTest.java | 36 +-
.../internal/runner/app/ItTablesApiTest.java | 398 +++++++++++-
.../runner/app/ItThinClientConnectionTest.java | 2 +-
...processors.query.calcite.extension.SqlExtension | 1 +
.../integrationTest/resources}/ignite-config.json | 3 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 37 +-
.../org/apache/ignite/internal/schema/Columns.java | 5 +
.../schema/marshaller/RecordMarshallerTest.java | 16 +-
.../ignite/distributed/ItDistributedTableTest.java | 3 +-
.../distributed/ItInternalTableScanTest.java | 3 +-
.../ignite/internal/table/InternalTable.java | 2 +-
.../apache/ignite/internal/table/TableImpl.java | 4 +-
.../internal/table/distributed/TableManager.java | 280 ++++-----
.../distributed/storage/InternalTableImpl.java | 2 +-
.../internal/table/event/TableEventParameters.java | 2 +-
.../internal/table/InteropOperationsTest.java | 674 +++++++++++++++++++++
.../table/impl/DummyInternalTableImpl.java | 2 +-
parent/pom.xml | 32 +-
130 files changed, 4200 insertions(+), 2114 deletions(-)
copy modules/api/src/main/java/org/apache/ignite/lang/{TableAlreadyExistsException.java => ColumnAlreadyExistsException.java} (67%)
copy modules/api/src/main/java/org/apache/ignite/lang/{TableAlreadyExistsException.java => IndexAlreadyExistsException.java} (68%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/QueryCancel.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{SqlCursor.java => QueryCancelledException.java} (67%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{rel/IgniteConvention.java => extension/ExternalConvention.java} (59%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MappingQueryContext.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/{IgniteTrimExchange.java => IgniteGateway.java} (53%)
copy modules/{api/src/main/java/org/apache/ignite/schema/definition/index/SortedIndexDefinition.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/AbstractQueryContext.java} (63%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/BaseQueryContext.java
create mode 100644 modules/client/src/test/java/org/apache/ignite/client/TestServer.java
copy modules/configuration-annotation-processor/src/{main/java/org/apache/ignite/internal/configuration/processor/ProcessorException.java => integrationTest/resources/org/apache/ignite/internal/configuration/processor/ConfigurationSchemaWithWrongPostfix.java} (76%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/logger/NullLogger.java
delete mode 100644 modules/network-api/src/main/java/org/apache/ignite/network/ClusterServiceFactory.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/NettyBootstrapFactory.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItSqlExtensionTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestExtension.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestFilterConverterRule.java
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteFilter.java => runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestPhysFilter.java} (64%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteSingleHashAggregate.java => runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestPhysTableScan.java} (50%)
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestTableImpl.java
create mode 100644 modules/runner/src/integrationTest/resources/META-INF/services/org.apache.ignite.internal.processors.query.calcite.extension.SqlExtension
copy {examples/config => modules/runner/src/integrationTest/resources}/ignite-config.json (83%)
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/InteropOperationsTest.java