IGNITE-15913 Merge SQL calcite running query registry to 3.0 (#648)
authorkorlov42 <korlov@gridgain.com>
Mon, 14 Feb 2022 14:58:42 +0000 (17:58 +0300)
committerGitHub <noreply@github.com>
Mon, 14 Feb 2022 14:58:42 +0000 (17:58 +0300)
commit25e46c8841dd0f772e2ccb6a8e67ee4797d32e9f
treed742c132ac759f2b9ca3e1384ab9891064670ec8
parenta6aa54b0159bd31f344b01fa33249cf21f6628f0
IGNITE-15913 Merge SQL calcite running query registry to 3.0 (#648)
27 files changed:
modules/core/src/main/java/org/apache/ignite/internal/util/CollectionUtils.java
modules/core/src/test/java/org/apache/ignite/internal/testframework/IgniteTestUtils.java
modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItRunningQueriesTest.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/Query.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryRegistry.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryRegistryImpl.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryState.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RemoteFragmentKey.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RootQuery.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RunningFragment.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RunningQuery.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExchangeService.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExchangeServiceImpl.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionContext.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionService.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImpl.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ddl/DdlCommandHandler.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/Outbox.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryCloseMessage.java [moved from modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/OutboxCloseMessage.java with 79% similarity]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/SqlQueryMessageGroup.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/DdlPlan.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PlanningContext.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PrepareService.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PrepareServiceImpl.java [new file with mode: 0644]
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/BaseQueryContext.java
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/BaseAggregateTest.java