This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch catalog-feature
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 31d5ed162e IGNITE-19499 TableManager should listen CatalogService
events instead of configuration (#2500)
add 42d717ed93 IGNITE-18670: Sql. It is possible to reference aliases in
GROUP BY clause. (#2545)
add 22efe81f33 IGNITE-20354 Reduce code duplication in commit cleanup
(#2557)
add 6df2cc270a IGNITE-19791 Sql. Introduce SqlRowHandler that supports
binary tuple rows (#2512)
add 33e83aa9f5 IGNITE-17578 Transactions: async cleanup processing on tx
commit (#2529)
add a1fe0da528 IGNITE-20181: KV/Binary view public API should only throw
public exceptions (#2523)
add 61b28d67a4 IGNITE-14818 Implement compressed encoding for short type
in messaging. (#2544)
add de51d814b8 IGNITE-20351 Log response body in REST test if it fails
(#2553)
add 673a0a99a7 IGNITE-20149 Sql. Revise the use of the INTERNAL_ERR code
in the sql module (#2549)
new daf8a1c0e2 Merge branch 'ai-main' into catalog-feature
new 693f950b5b CATALOG-FEATURE after merge ai-main
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/ignite/lang/MarshallerException.java | 18 +-
.../ignite/lang/UnexpectedNullValueException.java | 3 +-
.../apache/ignite/sql/CursorClosedException.java | 2 +-
.../ignite/internal/IgniteExceptionArchTest.java | 2 -
.../client/handler/JdbcQueryEventHandlerImpl.java | 38 +-
.../ignite/lang/IgniteExceptionMapperUtil.java | 8 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 27 +-
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 6 +-
.../org/apache/ignite/network/NetworkMessage.java | 4 +-
.../network/serialization/MessageReader.java | 8 +
.../network/direct/DirectMarshallingUtils.java | 49 ---
.../network/direct/DirectMessageReader.java | 11 +
.../network/direct/DirectMessageWriter.java | 1 -
.../stream/DirectByteBufferStreamImplV1.java | 141 +++----
.../network/message/ClassDescriptorMessage.java | 4 +-
.../internal/network/netty/InboundDecoder.java | 72 ++--
.../PerSessionSerializationService.java | 2 +-
.../internal/network/netty/NettyServerTest.java | 4 +-
.../Table/SchemaValidationTest.cs | 16 +-
.../ignite/internal/raft/util/OptimizedStream.java | 7 -
.../rest/authentication/ItAuthenticationTest.java | 5 +-
.../ignite/internal/rest/ssl/ItRestSslTest.java | 27 +-
.../ignite/internal/sql/api/ItCommonApiTest.java | 4 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 141 +++----
.../internal/sql/api/ItSqlClientMetricsTest.java | 10 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 93 +++--
.../internal/sql/engine/ItCreateTableDdlTest.java | 1 +
.../internal/sql/engine/ItDataTypesTest.java | 5 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 7 +-
.../sql/engine/ItDynamicParameterTest.java | 9 +-
.../internal/sql/engine/ItLimitOffsetTest.java | 3 +
.../internal/sql/engine/ItSqlOperatorsTest.java | 7 +-
.../sql/aggregate/group/test_group_by.test | 17 +-
.../sql/aggregate/group/test_group_by.test_ignore | 16 +-
.../ignite/internal/schema/row/InternalTuple.java | 16 +
.../sql/engine/QueryCancelledException.java | 9 +
.../ignite/internal/sql/engine/QueryContext.java | 4 +-
.../internal/sql/engine/SqlQueryProcessor.java | 11 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 3 +-
.../engine/exec/ExecutionCancelledException.java | 38 --
.../sql/engine/exec/ExecutionServiceImpl.java | 21 +-
.../sql/engine/exec/QueryValidationException.java | 38 --
.../internal/sql/engine/exec/RowHandler.java | 24 ++
.../internal/sql/engine/exec/SqlRowHandler.java | 411 +++++++++++++++++++++
.../sql/engine/exec/TableRowConverterImpl.java | 50 ++-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 22 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 65 +++-
.../internal/sql/engine/exec/rel/AbstractNode.java | 4 +-
.../sql/engine/exec/rel/AsyncRootNode.java | 4 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 23 +-
.../internal/sql/engine/exec/rel/RootNode.java | 8 +-
.../sql/engine/exec/row/RowSchemaTypes.java | 24 ++
.../metadata/RemoteFragmentExecutionException.java | 7 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 4 +-
.../engine/util/SqlExceptionMapperProvider.java | 7 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 2 +-
.../engine/QueryTransactionWrapperSelfTest.java | 1 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 6 +-
.../exec/IdentityDistributionFunctionSelfTest.java | 18 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 1 +
.../sql/engine/exec/rel/AbstractExecutionTest.java | 8 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 2 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 2 +-
.../sql/engine/exec/row/SqlRowHandlerTest.java | 254 +++++++++++++
.../sql/engine/framework}/ArrayRowHandler.java | 22 +-
.../sql/engine/framework/TestBuilders.java | 1 -
.../internal/sql/engine/framework/TestNode.java | 1 -
.../sql/engine/planner/PlannerTimeoutTest.java | 1 +
.../sql/engine/util/HashFunctionsTest.java | 2 +-
.../internal/sql/engine/util/SqlTestUtils.java | 37 +-
...ItTxDistributedTestThreeNodesThreeReplicas.java | 8 +
...butedTestThreeNodesThreeReplicasCollocated.java | 8 +
.../ignite/internal/table/AbstractTableView.java | 34 +-
.../internal/table/KeyValueBinaryViewImpl.java | 46 +--
...aluePojoStreamerPartitionAwarenessProvider.java | 2 +-
.../ignite/internal/table/KeyValueViewImpl.java | 67 ++--
.../internal/table/RecordBinaryViewImpl.java | 49 +--
.../ignite/internal/table/RecordViewImpl.java | 59 +--
.../internal/table/TableViewRowConverter.java | 66 ++++
.../table/distributed/StorageUpdateHandler.java | 106 +++++-
.../table/distributed/raft/PartitionListener.java | 59 +--
.../replicator/PartitionReplicaListener.java | 80 ++--
.../table/distributed/replicator/PendingRows.java | 99 +++++
.../internal/table/distributed/IndexBaseTest.java | 12 +-
.../table/distributed/IndexCleanupTest.java | 13 +-
.../distributed/StorageUpdateHandlerTest.java | 2 +
.../apache/ignite/distributed/ItTxTestCluster.java | 8 +-
87 files changed, 1830 insertions(+), 807 deletions(-)
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/direct/DirectMarshallingUtils.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionCancelledException.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/QueryValidationException.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/SqlRowHandler.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/row/SqlRowHandlerTest.java
rename
modules/sql-engine/src/{main/java/org/apache/ignite/internal/sql/engine/exec =>
test/java/org/apache/ignite/internal/sql/engine/framework}/ArrayRowHandler.java
(82%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/TableViewRowConverter.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PendingRows.java
