This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a change to branch colocation
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 6e413c9f7aa Merge remote-tracking branch 'origin/main' into colocation
add cc406ed3c0a IGNITE-25456 Add noreplace flag to rpm config files (#5881)
add 6215c444467 IGNITE-25083 Sql. Extend aggregates explain output (#5844)
add b677df4eb95 IGNITE-25360 .NET: Fix streamer exception on empty key
(#5883)
add f9a917fbabc Bump com.google.protobuf:protobuf-java from 4.30.2 to
4.31.0 (#5851)
add 8fc0dcda156 IGNITE-25444 Start configuring ignite3.docker.image in
migration tools tests directly from the docker image build (#5869)
add a84f4c876f8 IGNITE-25441 Optimize Netty buffer usage in
ClientInboundMessageHandler (#5879)
add 3a424496af0 IGNITE-25459 Improve Configuration framework error
handling (#5882)
add 63620644c02 Merge remote-tracking branch 'origin/main' into colocation
No new revisions were added by this update.
Summary of changes:
.../migration-tools-integration-test.gradle | 3 +
.../tests/containers/Ignite3ClusterContainer.java | 20 +-
.../config/ClusterLoadsConfigTest.java | 3 +-
.../internal/client/proto/ClientMessagePacker.java | 23 --
.../handler/ClientInboundMessageHandler.java | 277 +++++++++------------
...NotificationSender.java => ResponseWriter.java} | 13 +-
.../cluster/ClientClusterGetNodesRequest.java | 21 +-
.../compute/ClientComputeCancelRequest.java | 8 +-
.../ClientComputeChangePriorityRequest.java | 9 +-
.../ClientComputeExecuteColocatedRequest.java | 53 ++--
.../ClientComputeExecuteMapReduceRequest.java | 15 +-
.../ClientComputeExecutePartitionedRequest.java | 23 +-
.../compute/ClientComputeExecuteRequest.java | 7 +-
.../compute/ClientComputeGetStateRequest.java | 7 +-
.../requests/jdbc/ClientJdbcCancelRequest.java | 8 +-
.../requests/jdbc/ClientJdbcCloseRequest.java | 8 +-
.../jdbc/ClientJdbcColumnMetadataRequest.java | 8 +-
.../requests/jdbc/ClientJdbcConnectRequest.java | 8 +-
.../jdbc/ClientJdbcExecuteBatchRequest.java | 18 +-
.../requests/jdbc/ClientJdbcExecuteRequest.java | 21 +-
.../requests/jdbc/ClientJdbcFetchRequest.java | 8 +-
.../requests/jdbc/ClientJdbcFinishTxRequest.java | 14 +-
.../requests/jdbc/ClientJdbcHasMoreRequest.java | 8 +-
.../jdbc/ClientJdbcPreparedStmntBatchRequest.java | 19 +-
.../jdbc/ClientJdbcPrimaryKeyMetadataRequest.java | 8 +-
.../jdbc/ClientJdbcSchemasMetadataRequest.java | 8 +-
.../jdbc/ClientJdbcTableMetadataRequest.java | 8 +-
.../requests/sql/ClientSqlCancelRequest.java | 7 +-
.../requests/sql/ClientSqlCursorCloseRequest.java | 8 +-
.../sql/ClientSqlCursorNextPageRequest.java | 24 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 50 ++--
.../requests/sql/ClientSqlExecuteRequest.java | 101 ++++----
.../sql/ClientSqlExecuteScriptRequest.java | 39 ++-
.../sql/ClientSqlQueryMetadataRequest.java | 24 +-
.../requests/table/ClientSchemasGetRequest.java | 54 ++--
.../table/ClientStreamerBatchSendRequest.java | 60 +++--
...ClientStreamerWithReceiverBatchSendRequest.java | 46 ++--
.../handler/requests/table/ClientTableCommon.java | 191 ++++----------
.../table/ClientTableGetQualifiedRequest.java | 8 +-
.../requests/table/ClientTableGetRequest.java | 8 +-
...entTablePartitionPrimaryReplicasGetRequest.java | 9 +-
.../table/ClientTablesGetQualifiedRequest.java | 8 +-
.../requests/table/ClientTablesGetRequest.java | 8 +-
.../table/ClientTupleContainsAllKeysRequest.java | 34 +--
.../table/ClientTupleContainsKeyRequest.java | 30 +--
.../table/ClientTupleDeleteAllExactRequest.java | 28 +--
.../table/ClientTupleDeleteAllRequest.java | 28 +--
.../table/ClientTupleDeleteExactRequest.java | 30 +--
.../requests/table/ClientTupleDeleteRequest.java | 30 +--
.../requests/table/ClientTupleGetAllRequest.java | 30 +--
.../table/ClientTupleGetAndDeleteRequest.java | 28 +--
.../table/ClientTupleGetAndReplaceRequest.java | 28 +--
.../table/ClientTupleGetAndUpsertRequest.java | 28 +--
.../requests/table/ClientTupleGetRequest.java | 28 +--
.../table/ClientTupleInsertAllRequest.java | 28 +--
.../requests/table/ClientTupleInsertRequest.java | 30 +--
.../table/ClientTupleReplaceExactRequest.java | 35 +--
.../requests/table/ClientTupleReplaceRequest.java | 30 +--
.../requests/table/ClientTupleRequestBase.java | 120 +++++++++
.../table/ClientTupleUpsertAllRequest.java | 28 +--
.../requests/table/ClientTupleUpsertRequest.java | 28 +--
.../requests/table/ClientTuplesRequestBase.java | 114 +++++++++
...blePartitionPrimaryReplicasNodesGetRequest.java | 12 +-
.../requests/tx/ClientTransactionBeginRequest.java | 31 ++-
.../tx/ClientTransactionCommitRequest.java | 20 +-
.../tx/ClientTransactionRollbackRequest.java | 16 +-
.../configuration/ConfigurationChanger.java | 98 ++++----
.../internal/hlc/HybridTimestampTracker.java | 50 ++--
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 4 +-
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 15 ++
.../Table/RecordViewBinaryTests.cs | 2 +-
.../Table/SchemaValidationTest.cs | 6 +-
.../Table/Serialization/TupleSerializerHandler.cs | 5 +
modules/sql-engine/build.gradle | 2 +-
.../integrationTest/sql/group1/explain/scan.test | 4 +-
.../sql/engine/prepare/ExplainRelAsTextWriter.java | 11 +-
.../src/test/resources/tpcds/plan/q64.plan | 12 +-
.../src/test/resources/tpch/plan/q1.plan | 4 +-
.../src/test/resources/tpch/plan/q21.plan | 2 +-
.../src/test/resources/tpch/plan/q5.plan | 2 +-
.../src/test/resources/tpch/plan/q7.plan | 2 +-
.../src/test/resources/tpch/plan/q9.plan | 2 +-
packaging/build.gradle | 4 +-
packaging/db/build.gradle | 3 +-
84 files changed, 1163 insertions(+), 1150 deletions(-)
copy
modules/client-handler/src/main/java/org/apache/ignite/client/handler/{NotificationSender.java
=> ResponseWriter.java} (79%)
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/ClientTupleRequestBase.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/ClientTuplesRequestBase.java
