This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-18535
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 97f5ee226c Minors after review.
add b28b886b62 IGNITE-19042 Handling uninitialized values of distribution
zone meta storage keys on saving data nodes to meta storage. (#1797)
add db4de73f36 IGNITE-19062 Add handlers to flow pipeline (#1814)
add 358f33a27f IGNITE-17607 C++ Compute API (#1820)
add 4136fcfcd9 IGNITE-19045 .NET: Refactor SslStreamFactory to use
SslClientAuthenticationOptions (#1817)
add 1bff41d9e0 IGNITE-19070 Remove stale TODO (#1818)
add 91fd5e2808 IGNITE-18653: Sql. The number of dynamic parameters can be
checked once (#1732)
add 5eebe133b3 IGNITE-18291 Enhance C++ Binary Tuple code (#1594)
add 32d38b8a7a IGNITE-19079 ExecutionTimeout in ItIgniteNodeRestartTest
tests disabling (#1822)
add 2eff589aa1 IGNITE-18949 .NET: Enable NuGet package validation (#1827)
add cf61893fa9 IGNITE-19084: Fix openapi schema of
AuthenticationProviderConfigDto (#1825)
add 071397031d IGNITE-19074: Don't cache API clients in the CLI (#1826)
add b87aef7902 IGNITE-18943 Disable the set of endpoints for
non-initialized cluster (#1812)
add 0489a9e3eb IGNITE-16948 Multichannel message transfer (#1780)
add 1748b82247 IGNITE-18880 Add server-side client metrics (#1766)
add bf90ed4121 IGNITE-19094 Fix flaky IgniteWorkerTest#testUpdateHeartbeat
(#1834)
add d2a9706329 IGNITE-19069 .NET: Fix TestReconnectAfterFullClusterRestart
flakiness (#1828)
add fc7af583a4 Merge branch 'main' into ignite-18535
No new revisions were added by this update.
Summary of changes:
.../internal/cli/CliIntegrationTestBase.java | 3 +-
.../cli/call/metric/ItMetricCallsTest.java | 3 +-
.../commands/metric/ItNodeMetricCommandTest.java | 3 +-
.../internal/rest/ItGeneratedRestClientTest.java | 3 +-
.../cli/call/cluster/status/ClusterStatusCall.java | 2 +-
.../internal/cli/call/unit/DeployUnitCall.java | 4 +
.../internal/cli/call/unit/ListUnitCall.java | 2 +-
.../internal/cli/call/unit/UndeployUnitCall.java | 3 +-
.../internal/cli/call/unit/UnitStatusCall.java | 2 +-
.../node/metric/NodeMetricDisableCommand.java | 2 +
.../node/metric/NodeMetricDisableReplCommand.java | 2 +
.../node/metric/NodeMetricEnableCommand.java | 2 +
.../node/metric/NodeMetricEnableReplCommand.java | 2 +
.../node/metric/NodeMetricListCommand.java | 2 +
.../node/metric/NodeMetricListReplCommand.java | 2 +
.../cli/commands/unit/UnitDeployCommand.java | 2 +
.../cli/commands/unit/UnitListCommand.java | 2 +
.../cli/commands/unit/UnitStatusCommand.java | 2 +
.../cli/commands/unit/UnitUndeployCommand.java | 2 +
.../ignite/internal/cli/core/ApiClientFactory.java | 6 +-
.../ClusterNotInitializedExceptionHandler.java | 2 +-
.../cli/core/flow/builder/FlowBuilder.java | 41 ++
.../cli/core/flow/builder/FlowBuilderImpl.java | 30 +-
.../internal/cli/commands/flow/FlowTest.java | 10 +
.../client/proto/ClientMessageDecoder.java | 6 +-
modules/client-handler/build.gradle | 2 +
.../client/handler/ItClientHandlerMetricsTest.java | 156 +++++++
.../ignite/client/handler/ItClientHandlerTest.java | 8 +-
.../client/handler/ItClientHandlerTestUtils.java | 119 ++++++
.../client/handler/ItSslClientHandlerTest.java | 63 +--
.../apache/ignite/client/handler/TestServer.java | 22 +-
.../client/handler/ClientHandlerMetricSource.java | 399 ++++++++++++++++++
.../ignite/client/handler/ClientHandlerModule.java | 53 ++-
.../handler/ClientInboundMessageHandler.java | 80 +++-
.../ignite/client/handler/IdleChannelHandler.java | 6 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 54 +--
.../ClientConnectorConfigurationSchema.java | 4 +
.../cluster/ClientClusterGetNodesRequest.java | 2 +
.../requests/sql/ClientSqlExecuteRequest.java | 20 +-
.../handler/requests/sql/ClientSqlResultSet.java | 21 +-
.../requests/tx/ClientTransactionBeginRequest.java | 7 +-
.../tx/ClientTransactionCommitRequest.java | 9 +-
.../tx/ClientTransactionRollbackRequest.java | 9 +-
modules/client/build.gradle | 1 +
.../ignite/internal/client/TcpIgniteClient.java | 3 +
.../java/org/apache/ignite/client/MetricsTest.java | 153 +++++++
.../ignite/client/TestClientHandlerModule.java | 12 +-
.../java/org/apache/ignite/client/TestServer.java | 31 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 6 +-
.../apache/ignite/client/fakes/FakeCompute.java | 84 ++++
.../apache/ignite/client/fakes/FakeSession.java | 2 +-
.../management/ClusterManagementGroupManager.java | 2 +-
.../internal/deployunit/DeploymentManagerImpl.java | 12 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 +
.../internal/util/worker/IgniteWorkerTest.java | 2 +-
.../distributionzones/DistributionZoneManager.java | 14 +-
.../distributionzones/DistributionZonesUtil.java | 63 ++-
.../DistributionZoneManagerScaleUpTest.java | 30 ++
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 36 +-
.../org/apache/ignite/network/ChannelType.java | 127 ++++++
.../ignite/network/ChannelTypeAlreadyExist.java} | 20 +-
.../apache/ignite/network/MessagingService.java | 100 ++++-
.../org/apache/ignite/network/ChannelTypeTest.java | 70 ++++
modules/network/build.gradle | 1 +
.../network/netty/ItConnectionManagerTest.java | 77 ++--
.../internal/network/netty/ConnectionManager.java | 69 ++--
.../internal/network/netty/ConnectorKey.java | 72 ++++
.../ignite/internal/network/netty/NettySender.java | 19 +-
.../recovery/RecoveryClientHandshakeManager.java | 14 +-
... => RecoveryClientHandshakeManagerFactory.java} | 2 +-
.../recovery/RecoveryServerHandshakeManager.java | 19 +-
.../ignite/network/DefaultMessagingService.java | 40 +-
.../internal/network/netty/NettyClientTest.java | 2 +-
.../network/DefaultMessagingServiceTest.java | 136 ++++++-
modules/platforms/cpp/CMakeLists.txt | 4 +-
modules/platforms/cpp/cmake/ignite_test.cmake | 2 +-
modules/platforms/cpp/ignite/client/CMakeLists.txt | 5 +
.../cpp/ignite/client/compute/compute.cpp | 93 +++++
.../platforms/cpp/ignite/client/compute/compute.h | 144 +++++++
.../ignite/client/detail/argument_check_utils.h | 65 +++
.../cpp/ignite/client/detail/client_data_type.h | 190 +++++++++
.../cpp/ignite/client/detail/client_operation.h | 9 +
.../ignite/client/detail/compute/compute_impl.cpp | 130 ++++++
.../ignite/client/detail/compute/compute_impl.h | 79 ++++
.../ignite/client/detail/ignite_client_impl.cpp | 49 +++
.../cpp/ignite/client/detail/ignite_client_impl.h | 20 +
.../cpp/ignite/client/detail/node_connection.cpp | 4 +-
.../cpp/ignite/client/detail/sql/result_set_impl.h | 4 +-
.../cpp/ignite/client/detail/sql/sql_impl.cpp | 5 +-
.../cpp/ignite/client/detail/sql/sql_impl.h | 1 -
.../cpp/ignite/client/detail/table/schema.h | 19 +-
.../cpp/ignite/client/detail/table/table_impl.cpp | 220 +---------
.../cpp/ignite/client/detail/table/table_impl.h | 19 +
.../cpp/ignite/client/detail/table/tables_impl.cpp | 2 +-
.../client/detail/transaction/transactions_impl.h | 1 -
.../platforms/cpp/ignite/client/detail/utils.cpp | 449 ++++++++++++++++-----
modules/platforms/cpp/ignite/client/detail/utils.h | 38 +-
.../platforms/cpp/ignite/client/ignite_client.cpp | 13 +
.../platforms/cpp/ignite/client/ignite_client.h | 26 +-
.../end_point.h => client/network/cluster_node.h} | 89 ++--
modules/platforms/cpp/ignite/client/primitive.h | 74 +++-
.../platforms/cpp/ignite/client/primitive_test.cpp | 55 ++-
.../cpp/ignite/client/sql/column_metadata.h | 8 +-
.../cpp/ignite/client/table/key_value_view.cpp | 59 +--
.../cpp/ignite/client/table/key_value_view.h | 2 -
.../cpp/ignite/client/table/record_view.cpp | 32 +-
.../cpp/ignite/client/table/record_view.h | 2 -
modules/platforms/cpp/ignite/client/table/table.h | 2 +-
modules/platforms/cpp/ignite/common/CMakeLists.txt | 4 +
modules/platforms/cpp/ignite/common/bytes_view.h | 26 +-
.../cpp/ignite/{network => common}/end_point.h | 2 +-
modules/platforms/cpp/ignite/common/ignite_date.h | 14 +-
.../common/{ignite_date.h => ignite_duration.h} | 64 ++-
modules/platforms/cpp/ignite/common/ignite_error.h | 14 +-
.../common/{ignite_date.h => ignite_period.h} | 64 +--
modules/platforms/cpp/ignite/common/ignite_time.h | 14 +-
.../sql/sql_column_type.h => common/ignite_type.h} | 18 +-
modules/platforms/cpp/ignite/common/uuid.h | 13 +-
.../platforms/cpp/ignite/network/async_handler.h | 2 +-
.../network/detail/linux/connecting_context.h | 7 +-
.../network/detail/linux/linux_async_client.h | 8 +-
.../detail/linux/linux_async_worker_thread.h | 11 +-
.../ignite/network/detail/win/win_async_client.h | 8 +-
.../platforms/cpp/ignite/schema/ignite_type.cpp | 80 ----
modules/platforms/cpp/ignite/schema/ignite_type.h | 79 ----
.../cpp/ignite/{schema => tuple}/CMakeLists.txt | 2 -
.../{schema => tuple}/binary_tuple_builder.cpp | 121 +++++-
.../{schema => tuple}/binary_tuple_builder.h | 206 ++++++++--
.../ignite/{schema => tuple}/binary_tuple_header.h | 6 +-
.../{schema => tuple}/binary_tuple_parser.cpp | 76 +++-
.../ignite/{schema => tuple}/binary_tuple_parser.h | 62 ++-
.../ignite/{schema => tuple}/binary_tuple_schema.h | 14 +-
.../cpp/ignite/{schema => tuple}/column_info.h | 17 +-
.../cpp/ignite/{schema => tuple}/tuple_assembler.h | 0
.../cpp/ignite/{schema => tuple}/tuple_test.cpp | 36 +-
.../platforms/cpp/ignite/{schema => tuple}/types.h | 15 +-
.../platforms/cpp/tests/client-test/CMakeLists.txt | 1 +
.../cpp/tests/client-test/compute_test.cpp | 308 ++++++++++++++
.../cpp/tests/client-test/ignite_runner_suite.h | 11 +
.../platforms/cpp/tests/client-test/sql_test.cpp | 8 +-
.../cpp/tests/client-test/transactions_test.cpp | 2 +-
.../dotnet/Apache.Ignite.Tests/ReconnectTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/SslTests.cs | 65 ++-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 5 +
.../dotnet/Apache.Ignite/ISslStreamFactory.cs | 3 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 5 +
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 4 +-
.../Apache.Ignite/Internal/IgniteClientInternal.cs | 4 +
.../Apache.Ignite/Internal/SocketEndpoint.cs | 5 +
.../dotnet/Apache.Ignite/SslStreamFactory.cs | 72 +---
modules/rest-api/openapi/openapi.yaml | 14 +-
.../AuthenticationProviderConfigDto.java | 18 +-
.../ItNodeOnlyEndpointsFilterInitializedTest.java | 74 ++++
...tNodeOnlyEndpointsFilterNotInitializedTest.java | 105 +++++
.../apache/ignite/internal/rest/RestComponent.java | 12 +-
.../authentication/NodeOnlyEndpointsFilter.java | 89 ++++
.../rest/ItNotInitializedClusterRestTest.java | 24 +-
.../runner/app/ItIgniteNodeRestartTest.java | 2 +
.../app/client/ItAbstractThinClientTest.java | 1 +
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 4 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 4 +-
.../sql/engine/ClusterPerClassIntegrationTest.java | 2 +-
.../sql/engine/ItDynamicParameterTest.java | 3 +-
.../ignite/internal/sql/engine/ItUuidTest.java | 2 +-
.../internal/sql/engine/util/QueryChecker.java | 3 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 5 +-
.../ignite/internal/sql/api/SessionImpl.java | 18 +-
.../ignite/internal/sql/engine/QueryContext.java | 80 +++-
.../internal/sql/engine/SqlQueryProcessor.java | 87 +++-
.../ignite/internal/sql/engine/SqlQueryType.java | 24 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 8 +-
.../internal/sql/engine/prepare/DdlPlan.java | 5 +-
.../internal/sql/engine/prepare/ExplainPlan.java | 5 +-
.../internal/sql/engine/prepare/FragmentPlan.java | 6 +-
.../internal/sql/engine/prepare/IgnitePlanner.java | 21 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 87 +---
.../sql/engine/prepare/MultiStepDmlPlan.java | 5 +-
.../sql/engine/prepare/MultiStepQueryPlan.java | 5 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 34 +-
.../internal/sql/engine/prepare/QueryPlan.java | 11 +-
.../internal/sql/engine/sql/IgniteSqlParser.java | 162 ++++++++
.../ignite/internal/sql/engine/sql/ParseMode.java | 48 +++
.../internal/sql/engine/sql/ParseResult.java} | 37 +-
.../internal/sql/engine/sql/ScriptParseResult.java | 63 +++
.../sql/engine/sql/StatementParseResult.java | 78 ++++
.../ignite/internal/sql/engine/util/Commons.java | 93 ++---
.../internal/sql/engine/util/IgniteResource.java | 3 -
.../sql/engine/benchmarks/TpchParseBenchmark.java | 6 +-
.../engine/benchmarks/TpchPrepareBenchmark.java | 7 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 12 +-
.../engine/framework/ClusterServiceFactory.java | 11 +-
.../internal/sql/engine/framework/TestNode.java | 12 +-
.../sql/engine/sql/AbstractDdlParserTest.java | 12 +-
.../sql/DistributionZoneSqlDdlParserTest.java | 38 +-
.../engine/sql/IgniteSqlDecimalLiteralTest.java | 11 +-
.../sql/engine/sql/IgniteSqlParserTest.java | 62 +++
.../internal/sql/engine/sql/SqlDdlParserTest.java | 50 +--
197 files changed, 5573 insertions(+), 1678 deletions(-)
create mode 100644
modules/client-handler/src/integrationTest/java/org/apache/ignite/client/handler/ItClientHandlerMetricsTest.java
create mode 100644
modules/client-handler/src/integrationTest/java/org/apache/ignite/client/handler/ItClientHandlerTestUtils.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientHandlerMetricSource.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/MetricsTest.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeCompute.java
create mode 100644
modules/network-api/src/main/java/org/apache/ignite/network/ChannelType.java
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryValidator.java
=>
network-api/src/main/java/org/apache/ignite/network/ChannelTypeAlreadyExist.java}
(63%)
create mode 100644
modules/network-api/src/test/java/org/apache/ignite/network/ChannelTypeTest.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/netty/ConnectorKey.java
rename
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/{RecoveryClientHandhakeManagerFactory.java
=> RecoveryClientHandshakeManagerFactory.java} (96%)
create mode 100644 modules/platforms/cpp/ignite/client/compute/compute.cpp
create mode 100644 modules/platforms/cpp/ignite/client/compute/compute.h
create mode 100644
modules/platforms/cpp/ignite/client/detail/argument_check_utils.h
create mode 100644
modules/platforms/cpp/ignite/client/detail/client_data_type.h
create mode 100644
modules/platforms/cpp/ignite/client/detail/compute/compute_impl.cpp
create mode 100644
modules/platforms/cpp/ignite/client/detail/compute/compute_impl.h
create mode 100644
modules/platforms/cpp/ignite/client/detail/ignite_client_impl.cpp
copy modules/platforms/cpp/ignite/{network/end_point.h =>
client/network/cluster_node.h} (50%)
rename modules/platforms/cpp/ignite/{network => common}/end_point.h (99%)
copy modules/platforms/cpp/ignite/common/{ignite_date.h => ignite_duration.h}
(58%)
copy modules/platforms/cpp/ignite/common/{ignite_date.h => ignite_period.h}
(59%)
rename modules/platforms/cpp/ignite/{client/sql/sql_column_type.h =>
common/ignite_type.h} (81%)
delete mode 100644 modules/platforms/cpp/ignite/schema/ignite_type.cpp
delete mode 100644 modules/platforms/cpp/ignite/schema/ignite_type.h
rename modules/platforms/cpp/ignite/{schema => tuple}/CMakeLists.txt (97%)
rename modules/platforms/cpp/ignite/{schema => tuple}/binary_tuple_builder.cpp
(76%)
rename modules/platforms/cpp/ignite/{schema => tuple}/binary_tuple_builder.h
(76%)
rename modules/platforms/cpp/ignite/{schema => tuple}/binary_tuple_header.h
(88%)
rename modules/platforms/cpp/ignite/{schema => tuple}/binary_tuple_parser.cpp
(78%)
rename modules/platforms/cpp/ignite/{schema => tuple}/binary_tuple_parser.h
(75%)
rename modules/platforms/cpp/ignite/{schema => tuple}/binary_tuple_schema.h
(85%)
rename modules/platforms/cpp/ignite/{schema => tuple}/column_info.h (69%)
rename modules/platforms/cpp/ignite/{schema => tuple}/tuple_assembler.h (100%)
rename modules/platforms/cpp/ignite/{schema => tuple}/tuple_test.cpp (97%)
rename modules/platforms/cpp/ignite/{schema => tuple}/types.h (75%)
create mode 100644 modules/platforms/cpp/tests/client-test/compute_test.cpp
create mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/ItNodeOnlyEndpointsFilterInitializedTest.java
create mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/ItNodeOnlyEndpointsFilterNotInitializedTest.java
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/authentication/NodeOnlyEndpointsFilter.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlParser.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/ParseMode.java
rename
modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/SerializationResult.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/ParseResult.java}
(52%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/ScriptParseResult.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/StatementParseResult.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlParserTest.java
