This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-19497
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit a8b59f67a7 Fix typo in javadoc.
omit 3836abd914 Fix test.
omit e3ad8acd90 Fix test.
omit c954f4b037 wip.
omit 1c4f1e9a54 fix tests.
omit 051f4e5be3 fix tests.
omit bda7329ca2 Fix platforms tests
omit 82f29f1da2 fix imports.
new f03ccfc596 Fix platforms tests
new f419bc02b3 fix tests.
add e51f3d9799 [IGNITE-19785] Sql. Rework execution of 2-phase aggregates
(#2312)
add 9f5c135ea7 IGNITE-19953 Fix --verbose/-v option in CLI interactive
mode (#2419)
add da612fd99a IGNITE-19841 Add tests for schema validation consistency in
client and embedded API (#2421)
add 8e37291b97 IGNITE-19108 Check connection during REPL session in CLI
(#2359)
add f4c33ff66f IGNITE-14865 Sql. Public SQL API should only throw public
exceptions (#2345)
add ee06eb1bc0 IGNITE-19978 Java client: Change Gradle dependencies from
implementation to api (#2427)
add 4dd4743579 IGNITE-20152 Fix PartitionAwarenessTest.startServer2
flakiness (#2430)
add 47bf25dedd IGNITE-19877 Sql. Fix not allowed CAST operations - Fixes
#2368.
add e490bfe781 IGNITE-20056 .NET: Track observable timestamp (#2426)
add ae8c6c5011 IGNITE-19947 Sql. Fix CAST(n AS DECIMAL(precision, scale))
behaviour for scale > precision issues (#2396)
add 0e0ba6a3ca IGNITE-20180 Fix flaky ItTablePersistenceTest#testSnapshot
(#2428)
add 5a812c5586 Merge branch 'main' into catalog-feature
new f0dff0b01f Merge branch 'catalog-feature' into ignite-19497
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (a8b59f67a7)
\
N -- N -- N refs/heads/ignite-19497 (f0dff0b01f)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 3 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:
.../org/apache/ignite/sql/SqlBatchException.java | 6 +-
...liCommandTestNotInitializedIntegrationBase.java | 12 +-
.../cli/commands/ItConnectionHeartbeatTest.java | 142 +++++++++
.../repl/executor/ItIgnitePicocliCommandsTest.java | 7 +-
.../apache/ignite/internal/cli/ReplManager.java | 5 +
.../internal/cli/call/connect/ConnectCall.java | 19 +-
.../internal/cli/call/connect/DisconnectCall.java | 11 +-
...SessionEventListener.java => ConnectEvent.java} | 26 +-
.../cli/core/repl/ConnectionHeartBeat.java | 134 ++++++++
...EventListener.java => ConnectionLostEvent.java} | 17 +-
...tListener.java => ConnectionRestoredEvent.java} | 17 +-
...sionEventListener.java => DisconnectEvent.java} | 17 +-
.../core/repl/EventListeningActivationPoint.java | 91 ++++++
.../cli/core/repl/PeriodicSessionTaskExecutor.java | 3 +-
.../apache/ignite/internal/cli/core/repl/Repl.java | 11 +-
.../ignite/internal/cli/core/repl/ReplBuilder.java | 16 +-
.../ignite/internal/cli/core/repl/Session.java | 42 +--
.../ignite/internal/cli/core/repl/SessionInfo.java | 47 ++-
.../cli/core/repl/executor/ReplExecutor.java | 2 +
.../cli/core/repl/prompt/ReplPromptProvider.java | 19 +-
.../registry/impl/ClusterConfigRegistryImpl.java | 4 +-
.../repl/registry/impl/MetricRegistryImpl.java | 4 +-
.../repl/registry/impl/NodeConfigRegistryImpl.java | 4 +-
.../core/repl/registry/impl/UnitsRegistryImpl.java | 4 +-
.../cli/event/ConnectionEventListener.java | 65 ++++
.../apache/ignite/internal/cli/event}/Event.java | 5 +-
.../ignite/internal/cli/event/EventFactory.java | 84 +++++
.../ignite/internal/cli/event/EventListener.java} | 12 +-
.../ignite/internal/cli/event/EventPublisher.java} | 15 +-
.../cli/event/EventSubscriptionManager.java} | 14 +-
.../ignite/internal/cli/event/EventType.java} | 10 +-
.../apache/ignite/internal/cli/event/Events.java | 67 ++++
.../ignite/internal/cli/logger/HttpLogging.java | 5 +
.../core/repl/SessionDefaultValueProviderTest.java | 6 +-
.../filter/DynamicCompleterFilterTest.java | 10 +-
.../internal/cli/logger/HttpLoggingTest.java | 35 ++-
.../client/proto/ClientBinaryTupleUtils.java | 6 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 5 +-
modules/client/build.gradle | 4 +-
.../ignite/client/AbstractClientTableTest.java | 36 +--
.../apache/ignite/client/ClientRecordViewTest.java | 4 +-
.../org/apache/ignite/client/ClientTableTest.java | 4 +-
.../ignite/client/PartitionAwarenessTest.java | 2 +-
.../ignite/internal/sql/AbstractSession.java | 10 +-
.../ignite/jdbc/ItJdbcResultSetSelfTest.java | 24 +-
.../ignite/internal/marshaller/FieldAccessor.java | 1 +
.../ignite/internal/marshaller/MarshallerUtil.java | 58 ++++
.../dotnet/Apache.Ignite.Tests/.editorconfig | 3 +
.../Apache.Ignite.Tests/ClientSocketTests.cs | 23 +-
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 20 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 8 +-
.../Transactions/TransactionsTests.cs | 27 ++
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 60 ++--
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 22 +-
.../IClientSocketEventListener.cs} | 16 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 16 +-
.../Internal/Transactions/Transactions.cs | 4 +-
.../service/ItAbstractListenerSnapshotTest.java | 7 +
.../app/client/ItThinClientMarshallingTest.java | 185 ++++++++++-
.../runner/app/client/ItThinClientSqlTest.java | 2 +-
.../ignite/internal/sql/api/ItCommonApiTest.java | 7 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 157 ++++++----
.../internal/sql/api/ItSqlSynchronousApiTest.java | 101 +++---
.../internal/sql/engine/ItAggregatesTest.java | 188 ++++++++---
.../internal/sql/engine/ItDataTypesTest.java | 41 +--
.../ignite/internal/sql/engine/ItDmlTest.java | 9 +-
.../sql/engine/ItDynamicParameterTest.java | 7 +-
.../internal/sql/engine/ItFunctionsTest.java | 29 +-
.../ignite/internal/sql/engine/ItIntervalTest.java | 42 +--
.../internal/sql/engine/ItLimitOffsetTest.java | 41 ++-
.../internal/sql/engine/ItSqlOperatorsTest.java | 1 -
.../sql/engine/datatypes/uuid/ItUuidQueryTest.java | 2 +-
.../datatypes/varbinary/ItVarBinaryQueryTest.java | 2 +-
.../streamer/ItAbstractDataStreamerTest.java | 4 +-
.../sql/cast/test_boolean_cast.test | 73 ++---
.../marshaller/reflection/KvMarshallerImpl.java | 16 +-
.../marshaller/reflection/ObjectStatistics.java | 6 +-
.../reflection/RecordMarshallerImpl.java | 12 +-
.../ignite/internal/schema/row/RowAssembler.java | 16 +-
.../schema/marshaller/KvMarshallerTest.java | 8 +-
.../schema/marshaller/RecordMarshallerTest.java | 8 +-
modules/sql-engine/build.gradle | 2 +
.../ignite/internal/sql/api/SessionImpl.java | 67 ++--
.../internal/sql/engine/AsyncSqlCursorImpl.java | 17 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 42 +--
.../sql/engine/exec/LogicalRelImplementor.java | 4 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 19 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 111 ++++---
.../sql/engine/exec/exp/agg/Accumulator.java | 5 +-
.../engine/exec/exp/agg/AccumulatorWrapper.java | 4 -
.../sql/engine/exec/exp/agg/Accumulators.java | 178 +----------
.../engine/exec/exp/agg/AccumulatorsFactory.java | 21 +-
.../sql/engine/exec/exp/agg/AggregateRow.java | 86 +++++
.../internal/sql/engine/exec/exp/agg/GroupKey.java | 21 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 146 +++------
.../internal/sql/engine/exec/rel/RootNode.java | 14 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 69 +---
.../sql/engine/prepare/IgniteSqlValidator.java | 73 ++++-
.../sql/engine/prepare/PrepareServiceImpl.java | 33 +-
.../sql/engine/rel/agg/IgniteMapHashAggregate.java | 26 +-
.../sql/engine/rel/agg/IgniteMapSortAggregate.java | 20 +-
.../engine/rel/agg/IgniteReduceHashAggregate.java | 5 -
.../sql/engine/rel/agg/MapReduceAggregates.java | 347 +++++++++++++++++++++
.../engine/rule/HashAggregateConverterRule.java | 71 +++--
.../engine/rule/SortAggregateConverterRule.java | 68 ++--
.../ignite/internal/sql/engine/util/Commons.java | 38 +++
.../engine/util/IgniteCustomAssigmentsRules.java | 255 +++++++++++++++
.../ignite/internal/sql/engine/util/PlanUtils.java | 125 ++++++++
.../engine/util/SqlExceptionMapperProvider.java | 63 ++++
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 34 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 20 ++
.../exec/rel/HashAggregateExecutionTest.java | 9 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 129 +++-----
.../exec/rel/SortAggregateExecutionTest.java | 9 +-
.../planner/AbstractAggregatePlannerTest.java | 115 ++++---
.../sql/engine/planner/AbstractPlannerTest.java | 12 +-
.../sql/engine/planner/AggregatePlannerTest.java | 69 +++-
.../sql/engine/planner/CastResolutionTest.java | 217 +++++++++++++
.../planner/ColocatedHashAggregatePlannerTest.java | 33 ++
.../planner/ColocatedSortAggregatePlannerTest.java | 34 ++
.../sql/engine/planner/JoinCommutePlannerTest.java | 6 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 90 +++++-
.../planner/MapReduceSortAggregatePlannerTest.java | 89 ++++--
.../sql/engine/planner/UnionPlannerTest.java | 23 +-
.../sql/engine/prepare/TypeCoercionTest.java | 30 +-
.../internal/sql/engine/util/CommonsTest.java | 54 ++++
.../internal/sql/engine/util/PlanUtilsTest.java | 113 +++++++
.../internal/sql/engine/util/StatementChecker.java | 27 +-
.../internal/sql/engine/util/SqlTestUtils.java | 22 ++
.../ignite/distributed/ItTablePersistenceTest.java | 17 +-
130 files changed, 3991 insertions(+), 1396 deletions(-)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItConnectionHeartbeatTest.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> ConnectEvent.java} (63%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/ConnectionHeartBeat.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> ConnectionLostEvent.java} (74%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> ConnectionRestoredEvent.java} (73%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> DisconnectEvent.java} (74%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/EventListeningActivationPoint.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/ConnectionEventListener.java
copy modules/{core/src/main/java/org/apache/ignite/internal/manager =>
cli/src/main/java/org/apache/ignite/internal/cli/event}/Event.java (89%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/EventFactory.java
copy
modules/{raft/src/main/java/org/apache/ignite/raft/jraft/util/internal/IntegerFieldUpdater.java
=> cli/src/main/java/org/apache/ignite/internal/cli/event/EventListener.java}
(81%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/ArrayFactory.java
=> cli/src/main/java/org/apache/ignite/internal/cli/event/EventPublisher.java}
(79%)
copy
modules/{metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/dsl/OperationType.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/event/EventSubscriptionManager.java}
(75%)
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/commands/DdlCommandParams.java
=> cli/src/main/java/org/apache/ignite/internal/cli/event/EventType.java} (82%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/Events.java
copy modules/platforms/dotnet/Apache.Ignite/{Network/IConnectionInfo.cs =>
Internal/IClientSocketEventListener.cs} (67%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/AggregateRow.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/MapReduceAggregates.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/IgniteCustomAssigmentsRules.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/SqlExceptionMapperProvider.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/CastResolutionTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/CommonsTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/PlanUtilsTest.java
