This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-29033
in repository https://gitbox.apache.org/repos/asf/ignite.git
from 19c4fb3a4ca IGNITE-29033 After review 1.0
add e195b83e83e IGNITE-29005 Refactored Discovery network operations to
rely on session not plain socket (#13509) (#13509)
add d8826078f68 IGNITE-29011 SQL: Add result set size metrics for queries
- Fixes #13517.
add c5f8a52c59b IGNITE-29035 Fixed metrics documentation: broken tables,
dead links, time units, typos (#13548)
add 6f2a343d282 IGNITE-27822 Support recursive query for Calcite engine
(#13479)
add 63457695229 IGNITE-29037 Refactored Message Factory usage in TCP
Discovery implementations (#13551)
add da4f3456946 IGNITE-29034 SQL Calcite: Add support for FROM DUAL
queries (#13545)
add 9b457affcad Merge branch 'master' into ignite-29033
No new revisions were added by this update.
Summary of changes:
docs/_docs/monitoring-metrics/custom-metrics.adoc | 8 +-
.../monitoring-metrics/new-metrics-system.adoc | 21 +-
docs/_docs/monitoring-metrics/new-metrics.adoc | 44 ++--
docs/_docs/monitoring-metrics/system-views.adoc | 2 +-
.../_docs/perf-and-troubleshooting/sql-tuning.adoc | 2 +-
docs/_docs/persistence/change-data-capture.adoc | 4 +-
docs/_docs/tools/control-script.adoc | 6 +-
.../calcite/DistributedCalciteConfiguration.java | 33 +++
.../query/calcite/exec/ExecutionContext.java | 10 +
.../query/calcite/exec/ExecutionServiceImpl.java | 2 +
.../query/calcite/exec/LogicalRelImplementor.java | 20 ++
.../query/calcite/exec/rel/RecursiveCteState.java | 94 +++++++
.../query/calcite/exec/rel/RepeatUnionNode.java | 183 +++++++++++++
.../calcite/metadata/IgniteMdFragmentMapping.java | 12 +
.../processors/query/calcite/prepare/Cloner.java | 12 +
.../query/calcite/prepare/IgniteRelShuttle.java | 12 +
.../query/calcite/prepare/PlannerPhase.java | 4 +
.../query/calcite/prepare/PlanningContext.java | 41 +++
.../query/calcite/prepare/PrepareServiceImpl.java | 2 +
.../query/calcite/rel/IgniteHashIndexSpool.java | 19 ++
.../query/calcite/rel/IgniteIndexScan.java | 16 ++
...teValues.java => IgniteRecursiveTableScan.java} | 71 ++++--
.../query/calcite/rel/IgniteRelVisitor.java | 10 +
.../query/calcite/rel/IgniteRepeatUnion.java | 102 ++++++++
.../query/calcite/rel/IgniteSortedIndexSpool.java | 34 +++
.../query/calcite/rel/IgniteTableScan.java | 11 +
.../rel/ProjectableFilterableTableScan.java | 30 +++
.../rel/logical/IgniteLogicalIndexScan.java | 10 +
.../rel/logical/IgniteLogicalTableScan.java | 11 +
.../query/calcite/rule/RecursiveCteUtils.java | 218 ++++++++++++++++
...e.java => RecursiveTableScanConverterRule.java} | 47 ++--
.../calcite/rule/RepeatUnionConverterRule.java | 102 ++++++++
.../query/calcite/schema/IgniteSchema.java | 18 ++
.../CalciteQueryProcessorPropertiesTest.java | 52 ++++
.../integration/MemoryQuotasIntegrationTest.java | 18 ++
.../OperatorsExtensionIntegrationTest.java | 92 ++++++-
.../integration/RecursiveCteIntegrationTest.java | 208 +++++++++++++--
.../integration/ResultSetSizeMetricsTest.java | 130 ++++++++++
.../calcite/planner/RecursiveCtePlannerTest.java | 229 +++++++++++++++++
.../ignite/testsuites/IntegrationTestSuite.java | 2 +
.../apache/ignite/testsuites/PlannerTestSuite.java | 2 +
.../sql/hierarchy/test_recursive_hierarchy.test | 64 +++++
.../sql/hierarchy/test_recursive_sequence.test | 62 +++++
.../sql/hierarchy/test_recursive_subquery.test | 54 ++++
.../processors/cache/CacheMetricsImpl.java | 4 +-
.../transactions/TransactionMetricsAdapter.java | 8 +-
.../internal/processors/job/GridJobProcessor.java | 4 +-
.../query/running/RunningQueryManager.java | 25 ++
.../ignite/spi/discovery/tcp/ClientImpl.java | 127 ++++-----
.../ignite/spi/discovery/tcp/ServerImpl.java | 283 +++++++--------------
.../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 19 +-
.../spi/discovery/tcp/TcpDiscoveryIoSession.java | 179 +++++++++++--
.../tcp/TcpDiscoveryMessageSerializer.java | 9 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 233 ++++++++---------
.../ignite/internal/IgniteClientRejoinTest.java | 22 +-
.../IgniteDiscoveryMassiveNodeFailTest.java | 16 +-
.../cache/CacheMetricsCacheSizeTest.java | 3 +-
.../dht/IgniteCacheTopologySplitAbstractTest.java | 20 +-
.../processors/rest/RestProcessorHangTest.java | 8 +-
.../apache/ignite/spi/MessagesPluginProvider.java | 13 -
.../IgniteTcpCommunicationConnectOnInitTest.java | 28 +-
.../spi/discovery/tcp/BlockTcpDiscoverySpi.java | 9 +-
.../tcp/DiscoveryUnmarshalVulnerabilityTest.java | 2 +-
.../discovery/tcp/IgniteMetricsOverflowTest.java | 7 +-
.../discovery/tcp/MultiDataCenterSplitTest.java | 6 +-
.../spi/discovery/tcp/ReceivedMessagesTracker.java | 9 +-
...cpClientDiscoverySpiFailureTimeoutSelfTest.java | 17 +-
.../tcp/TcpClientDiscoverySpiSelfTest.java | 29 ++-
.../tcp/TcpClientDiscoveryUnresolvedHostTest.java | 23 +-
.../tcp/TcpDiscoveryCoordinatorFailureTest.java | 18 +-
.../discovery/tcp/TcpDiscoveryFailedJoinTest.java | 33 +--
.../tcp/TcpDiscoveryNetworkIssuesTest.java | 27 +-
.../TcpDiscoveryPendingMessageDeliveryTest.java | 13 +-
.../tcp/TcpDiscoverySpiFailureTimeoutSelfTest.java | 6 +-
.../tcp/TcpDiscoverySpiReconnectDelayTest.java | 8 +-
.../spi/discovery/tcp/TestTcpDiscoverySpi.java | 50 +---
.../processors/query/h2/H2ResultSetIterator.java | 2 +
.../query/h2/twostep/GridReduceQueryExecutor.java | 5 +
.../query/h2/twostep/ReduceIndexIterator.java | 6 +
79 files changed, 2617 insertions(+), 778 deletions(-)
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RecursiveCteState.java
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RepeatUnionNode.java
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/{IgniteValues.java
=> IgniteRecursiveTableScan.java} (50%)
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteRepeatUnion.java
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/RecursiveCteUtils.java
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/{ValuesConverterRule.java
=> RecursiveTableScanConverterRule.java} (57%)
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/RepeatUnionConverterRule.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/ResultSetSizeMetricsTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/RecursiveCtePlannerTest.java
create mode 100644
modules/calcite/src/test/sql/hierarchy/test_recursive_hierarchy.test
create mode 100644
modules/calcite/src/test/sql/hierarchy/test_recursive_sequence.test
create mode 100644
modules/calcite/src/test/sql/hierarchy/test_recursive_subquery.test