This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-26156
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard d34cb131003 wip
add 8fea6dcd7ba IGNITE-25669 Fix Netty buffer leak in TcpClientChannel
(#6512)
add 8d94b95b32d IGNITE-26277 Fix DotNetComputeExecutor process start on
undeploy (#6519)
add 9565e696257 IGNITE-26274 Fix on demand deploy race condition (#6470)
add 216dfa0228d IGNITE-26352 Add single checkstyle task (#6517)
add 8c956b3f0d8 IGNITE-26178 Sql. List of SQL keywords (#6520)
add 938e09d0306 IGNITE-25987 Add public CLI API for partition restart with
cleanup functionality (#6513)
add a4695b99f9e IGNITE-25631 C++ Client: Move verification to
configuration methods (#6523)
add 06e115514ce IGNITE-26308 Mute the test until heartbeats are
implemented (#6522)
add 62c47e04531 IGNITE-26336 Fix node name and node url options (#6510)
add 2130f880dd9 IGNITE-26309 .NET: Fix MetricsTests flakiness (#6529)
add 8f6a1f99e71 IGNITE-25872 Sql. Support GROUPING aggregate function
(#6479)
add b809e6218fd IGNITE-26373 Return public API for auto adjust related
entities (#6537)
add 3b9e88e6f0d IGNITE-26359 Reduce excessive warninng messages during
client message handling (#6528)
add 31292e3213d IGNITE-26312 .NET: Fix port issues in compat tests (#6545)
add 0666e26f594 IGNITE-26181 Fix default byte array marshalling (#6521)
add 07bb9b89e48 IGNITE-26235 Separate public ClusterNode from internal
ClusterNode (#6538)
add ef0e9454678 IGNITE-26383 Use TableViewInternal instead of
implementation (#6547)
add fe7855e2927 IGNITE-26366 Move java examples to java folder (#6531)
add 5fac2189cbe wip
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 (d34cb131003)
\
N -- N -- N refs/heads/ignite-26156 (5fac2189cbe)
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.
No new revisions were added by this update.
Summary of changes:
... checkstyleTest checkstyleTestFixtures].run.xml | 9 +-
build.gradle | 8 +
examples/{ => java}/.gitignore | 0
examples/{ => java}/README.md | 0
examples/{ => java}/build.gradle | 0
examples/{ => java}/config/ignite-config.conf | 0
.../{ => java}/config/java.util.logging.properties | 0
.../ignite/example/AbstractExamplesTest.java | 0
.../apache/ignite/example/ExampleTestUtils.java | 0
.../ignite/example/sql/ItSqlExamplesTest.java | 0
.../storage/ItPageMemoryStorageExampleTest.java | 0
.../storage/ItRocksdbStorageExampleTest.java | 0
.../ignite/example/table/ItTableExamplesTest.java | 0
.../example/tx/ItTransactionsExamplesTest.java | 0
.../ignite/example/client/IgniteClientExample.java | 0
.../client/IgniteClientWithConfigExample.java | 0
.../code/deployment/CodeDeploymentExample.java | 0
.../ignite/example/code/deployment/MyJob.java | 0
.../example/code/deployment/resources/script.sh | 0
.../example/compute/ComputeAsyncExample.java | 0
.../example/compute/ComputeBroadcastExample.java | 0
.../compute/ComputeCancellationExample.java | 0
.../example/compute/ComputeColocatedExample.java | 0
.../ignite/example/compute/ComputeExample.java | 0
.../example/compute/ComputeJobPriorityExample.java | 0
.../example/compute/ComputeMapReduceExample.java | 0
.../ComputeWithCustomResultMarshallerExample.java | 0
.../example/compute/ComputeWithResultExample.java | 0
.../example/serialization/AutoSerializableArg.java | 0
.../serialization/AutoSerializableResult.java | 0
.../CustomPojoSerializationExample.java | 0
.../serialization/CustomPojoSerializationJob.java | 0
.../example/serialization/IntegerDecrementJob.java | 0
.../ignite/example/serialization/JsonArg.java | 0
.../example/serialization/JsonArgMarshaller.java | 0
.../ignite/example/serialization/JsonResult.java | 0
.../serialization/JsonResultMarshaller.java | 0
.../NativeTypeSerializationExample.java | 0
.../PojoAutoSerializationExample.java | 0
.../serialization/PojoAutoSerializationJob.java | 0
.../serialization/SerializationExample.java | 0
.../serialization/TupleSerializationExample.java | 0
.../example/serialization/TupleTransformJob.java | 0
.../apache/ignite/example/sql/SqlApiExample.java | 0
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 0
.../PersistentPageMemoryStorageExample.java | 0
.../example/storage/RocksDbStorageExample.java | 0
.../example/storage/StorageEngineExample.java | 0
.../storage/VolatilePageMemoryStorageExample.java | 0
.../apache/ignite/example/streaming/Account.java | 0
.../streaming/DetectFailedEntriesExample.java | 0
.../DistributedComputeWithReceiverExample.java | 0
.../streaming/MultiTableDataStreamerExample.java | 0
.../streaming/SingleTableDataStreamerExample.java | 0
.../ignite/example/streaming/TwoTableReceiver.java | 0
.../ignite/example/table/KeyValueViewExample.java | 0
.../example/table/KeyValueViewPojoExample.java | 0
.../ignite/example/table/RecordViewExample.java | 0
.../example/table/RecordViewPojoExample.java | 0
.../ignite/example/tx/TransactionsExample.java | 0
.../{ => java}/src/main/resources/tradesData.csv | 0
.../apache/ignite/catalog/annotations/Zone.java | 9 +
.../ignite/catalog/definitions/ZoneDefinition.java | 38 ++
.../ignite/marshalling/ByteArrayMarshaller.java | 49 +-
.../JavaSerializationByteArrayMarshalling.java | 70 ---
modules/catalog-compaction/build.gradle | 1 +
.../compaction/ItCatalogCompactionTest.java | 8 +-
.../compaction/CatalogCompactionRunner.java | 20 +-
.../CatalogCompactionRunnerSelfTest.java | 42 +-
modules/cli/build.gradle | 1 +
.../restart/ItRestartPartitionsTest.java | 71 ++-
.../recovery/restart/RestartPartitionsCall.java | 12 +-
.../restart/RestartPartitionsCallInput.java | 22 +-
.../ignite/internal/cli/commands/Options.java | 5 +
.../internal/cli/commands/node/NodeUrlMixin.java | 13 +-
.../partitions/restart/RestartPartitionsMixin.java | 10 +
.../repl/completer/StringDynamicCompleter.java | 1 -
.../ignite/internal/cli/commands/MixinTest.java | 246 +++++++++
.../partitions/restart/RestartPartitionsTest.java | 64 +++
.../filter/ExclusionsCompleterFilterTest.java | 1 -
.../handler/ClientInboundMessageHandler.java | 18 +-
.../compute/ClientComputeExecuteRequest.java | 9 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 2 +
.../ignite/internal/client/TcpClientChannel.java | 86 +--
.../apache/ignite/client/ConfigurationTest.java | 22 +
.../java/org/apache/ignite/client/TestServer.java | 8 +-
.../apache/ignite/client/fakes/FakeCompute.java | 13 +-
.../ignite/client/fakes/FakeInternalTable.java | 24 +-
.../cluster/management/ItClusterManagerTest.java | 6 +-
.../management/raft/ItCmgRaftServiceTest.java | 10 +-
.../cluster/management/ClusterInitializer.java | 33 +-
.../management/ClusterManagementGroupManager.java | 70 +--
.../management/network/CmgMessageCallback.java | 12 +-
.../management/network/CmgMessageHandler.java | 8 +-
.../management/raft/CmgRaftGroupListener.java | 8 +-
.../cluster/management/raft/CmgRaftService.java | 12 +-
.../cluster/management/raft/ValidationManager.java | 10 +-
.../raft/commands/ClusterNodeMessage.java | 10 +-
.../topology/LogicalTopologyServiceImpl.java | 4 +-
.../management/topology/api/LogicalNode.java | 12 +-
.../topology/api/LogicalNodeSerializer.java | 4 +-
.../topology/api/LogicalTopologyService.java | 4 +-
.../cluster/management/ClusterInitializerTest.java | 63 +--
.../management/raft/CmgRaftServiceTest.java | 6 +-
.../topology/LogicalTopologyImplTest.java | 16 +-
.../topology/LogicalTopologyServiceImplTest.java | 4 +-
.../internal/cluster/management/MockNode.java | 6 +-
.../metrics/messaging/MetricMessaging.java | 34 +-
.../deployunit/DeployMessagingService.java | 10 +-
.../ignite/internal/deployunit/NodesToDeploy.java | 6 +-
.../ignite/internal/deployunit/UnitDownloader.java | 21 +-
.../PlatformCompatibilityTestNodeRunner.java | 33 +-
.../internal/compute/ItComputeErrorsBaseTest.java | 11 +-
.../internal/compute/ItExecutionsCleanerTest.java | 7 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 4 +-
.../internal/compute/ItWorkerShutdownTest.java | 14 +-
.../threading/ItComputeApiThreadingTest.java | 3 +-
.../internal/compute/utils/InteractiveJobs.java | 12 +-
.../ignite/internal/compute/ComputeComponent.java | 6 +-
.../internal/compute/ComputeComponentImpl.java | 6 +-
.../internal/compute/ComputeJobFailover.java | 10 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 67 ++-
.../internal/compute/IgniteComputeInternal.java | 4 +-
.../internal/compute/NextWorkerSelector.java | 4 +-
.../compute/PrimaryReplicaNextWorkerSelector.java | 4 +-
.../compute/TaskToJobExecutionWrapper.java | 10 +-
.../compute/executor/JobExecutionInternal.java | 10 +-
.../platform/dotnet/DotNetComputeExecutor.java | 36 +-
.../compute/messaging/ComputeMessaging.java | 62 ++-
.../compute/messaging/RemoteJobExecution.java | 11 +-
.../internal/compute/ComputeComponentImplTest.java | 18 +-
.../internal/compute/IgniteComputeImplTest.java | 38 +-
.../platform/dotnet/DotNetComputeExecutorTest.java | 33 ++
.../internal/network/PublicClusterNodeImpl.java} | 8 +-
...niteDistributionZoneManagerNodeRestartTest.java | 8 +-
.../rebalance/ItRebalanceDistributedTest.java | 8 +-
.../DistributionZoneManagerAlterFilterTest.java | 12 +-
.../DistributionZoneManagerFilterTest.java | 12 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 4 +-
...butionZoneManagerStorageProfilesFilterTest.java | 12 +-
.../DistributionZoneCausalityDataNodesTest.java | 18 +-
.../DistributionZonesTestUtil.java | 8 +-
.../tech-notes/images/cancelRebalance.svg | 2 +-
.../tech-notes/images/primaryReplica.svg | 2 +-
.../ignite/internal/network/file/TestCluster.java | 4 +-
.../network/file/FileTransferServiceImpl.java | 4 +-
.../network/file/FileTransferServiceImplTest.java | 8 +-
.../network/file/TestMessagingService.java | 19 +-
.../internal/network/file/TestTopologyService.java | 26 +-
.../internal/index/IndexBuildController.java | 4 +-
.../ignite/internal/index/IndexBuildTask.java | 6 +-
.../apache/ignite/internal/index/IndexBuilder.java | 6 +-
.../internal/index/IndexManagementUtils.java | 6 +-
.../IndexNodeFinishedRwTransactionsChecker.java | 6 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 8 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 19 +-
.../IndexAvailabilityControllerRestorerTest.java | 4 +-
.../index/IndexAvailabilityControllerTest.java | 4 +-
.../ignite/internal/index/IndexBuilderTest.java | 12 +-
.../internal/index/IndexManagementUtilsTest.java | 14 +-
.../internal/index/TestIndexManagementUtils.java | 8 +-
.../internal/lowwatermark/LowWatermarkImpl.java | 4 +-
.../lowwatermark/LowWatermarkImplTest.java | 6 +-
.../cache/IdempotentCacheVacuumizer.java | 4 +-
.../ItMetaStorageMultipleNodesVsStorageTest.java | 4 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 10 +-
.../metastorage/impl/ElectionListener.java | 4 +-
.../impl/MetaStorageCompactionTrigger.java | 6 +-
.../impl/MetaStorageLeaderElectionListener.java | 4 +-
.../impl/MetaStorageLearnerManager.java | 10 +-
.../MetaStorageDeployWatchesCorrectnessTest.java | 4 +-
.../MetaStorageLeaderElectionListenerTest.java | 8 +-
.../impl/MetaStorageManagerRecoveryTest.java | 4 +-
.../impl/StandaloneMetaStorageManager.java | 10 +-
.../internal/network/ClusterNodeResolver.java | 7 +-
.../internal/network/ClusterNodeSerializer.java | 11 +-
.../ignite/internal/network/IgniteClusterImpl.java | 14 +-
.../internal/network/InternalClusterNode.java} | 12 +-
...rNodeImpl.java => InternalClusterNodeImpl.java} | 17 +-
.../ignite/internal/network/JoinedNodes.java | 6 +-
.../ignite/internal/network/MessagingService.java | 55 +-
.../internal/network/NetworkMessageHandler.java | 3 +-
.../internal/network/TopologyEventHandler.java | 6 +-
.../ignite/internal/network/TopologyService.java | 9 +-
.../network/TrackableNetworkMessageHandler.java | 3 +-
.../network/UnresolvableConsistentIdException.java | 3 +-
.../JumpToExecutorByConsistentIdAfterSend.java | 15 +-
...java => InternalClusterNodeSerializerTest.java} | 9 +-
.../JumpToExecutorByConsistentIdAfterSendTest.java | 24 +-
.../network/SingleClusterNodeResolver.java | 11 +-
.../network/netty/ItConnectionManagerTest.java | 4 +-
.../node/ItNodeStalenessAndRestartTest.java | 4 +-
.../network/scalecube/ItClusterServiceTest.java | 14 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 26 +-
.../internal/network/DefaultMessagingService.java | 35 +-
.../handshake/HandshakeEventLoopSwitcher.java | 4 +-
.../network/message/ClusterNodeMessage.java | 12 +-
.../internal/network/netty/ConnectionManager.java | 8 +-
.../internal/network/netty/HandshakeHandler.java | 4 +-
.../internal/network/netty/InNetworkObject.java | 10 +-
.../internal/network/netty/MessageHandler.java | 6 +-
.../network/recovery/HandshakeManagerUtils.java | 4 +-
.../recovery/RecoveryAcceptorHandshakeManager.java | 10 +-
.../RecoveryInitiatorHandshakeManager.java | 12 +-
.../RecoveryInitiatorHandshakeManagerFactory.java | 4 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 10 +-
.../scalecube/ScaleCubeTopologyService.java | 74 +--
.../network/DefaultMessagingServiceTest.java | 61 ++-
.../handshake/NoOpHandshakeEventLoopSwitcher.java | 4 +-
.../network/netty/RecoveryHandshakeTest.java | 6 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 4 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 8 +-
.../scalecube/ScaleCubeTopologyServiceTest.java | 14 +-
.../replicator/ItZoneDataReplicationTest.java | 4 +-
.../replicator/fixtures/TestPlacementDriver.java | 6 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 4 +-
.../PartitionReplicaLifecycleManager.java | 4 +-
.../partition/replicator/ReplicaPrimacyEngine.java | 6 +-
.../partition/replicator/TxRecoveryEngine.java | 6 +-
.../replicator/ZonePartitionReplicaListener.java | 6 +-
...xStateCommitPartitionReplicaRequestHandler.java | 6 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 14 +-
.../outgoing/OutgoingSnapshotsManager.java | 6 +-
.../PartitionReplicaLifecycleManagerTest.java | 5 +-
.../incoming/IncomingSnapshotCopierTest.java | 12 +-
.../placementdriver/TestPlacementDriver.java | 15 +-
.../placementdriver/TestReplicaMetaImpl.java | 12 +-
.../ItPrimaryReplicaChoiceTest.java | 11 +-
.../PlacementDriverManagerTest.java | 4 +-
.../internal/placementdriver/LeaseUpdater.java | 20 +-
.../placementdriver/PlacementDriverManager.java | 4 +-
.../internal/placementdriver/TopologyTracker.java | 4 +-
.../placementdriver/PlacementDriverTest.java | 18 +-
modules/platforms/cpp/ignite/client/CMakeLists.txt | 1 +
.../platforms/cpp/ignite/client/ignite_client.cpp | 7 -
.../ignite_client_configuration.cpp} | 17 +-
.../ignite/client/ignite_client_configuration.h | 38 +-
modules/platforms/cpp/ignite/client/ssl_mode.h | 2 +-
.../cpp/ignite/network/detail/win/sockets.cpp | 1 -
.../cpp/tests/client-test/ignite_client_test.cpp | 60 +++
.../cpp/tests/client-test/ignite_runner_suite.h | 4 +-
.../CurrentClientWithOldServerCompatibilityTest.cs | 7 +-
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 106 ++--
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 3 -
.../Apache.Ignite/ApiCompatibilitySuppressions.xml | 2 +-
modules/platforms/python/tests/test_fetch_table.py | 3 +-
.../internal/raft/LeaderElectionListener.java | 4 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 8 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 8 +-
.../server/impl/RaftServiceEventInterceptor.java | 10 +-
.../apache/ignite/raft/jraft/rpc/RpcContext.java | 4 +-
.../raft/jraft/rpc/impl/AbstractClientService.java | 6 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 5 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 14 +-
.../rpc/impl/RaftGroupEventsClientListener.java | 4 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 48 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 6 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 8 +-
.../ItPlacementDriverReplicaSideTest.java | 4 +-
.../raft/client/TopologyAwareRaftGroupService.java | 27 +-
.../PlacementDriverMessageProcessor.java | 14 +-
.../ignite/internal/replicator/ReplicaImpl.java | 6 +-
.../ignite/internal/replicator/ReplicaManager.java | 14 +-
.../ignite/internal/replicator/ReplicaService.java | 8 +-
.../exception/ReplicaStoppingException.java | 4 +-
.../exception/ReplicaUnavailableException.java | 4 +-
.../replicator/PlacementDriverReplicaSideTest.java | 18 +-
.../internal/replicator/ReplicaManagerTest.java | 4 +-
.../AbstractTopologyAwareGroupServiceTest.java | 24 +-
.../internal/replicator/ReplicaTestUtils.java | 6 +-
.../topology/TestLogicalTopologyService.java | 4 +-
modules/rest/build.gradle | 1 +
.../internal/rest/cluster/TopologyController.java | 5 +-
.../apache/ignite/internal/ItIgniteStartTest.java | 6 +-
.../ItTruncateRaftLogAndRestartNodesTest.java | 4 +-
.../management/ItDuplicateNodeNamesTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 8 +-
.../app/client/ItThinClientTransactionsTest.java | 9 +-
.../app/compute/ItEmbeddedMarshallingTest.java | 24 +-
.../streamer/ItAbstractDataStreamerTest.java | 4 +-
.../internal/table/ItReadOnlyTransactionTest.java | 22 +-
.../ignite/internal/table/ItReplicasTest.java | 10 +-
.../ignite/internal/table/ItTableScanTest.java | 21 +-
.../partition/ItAbstractPartitionManagerTest.java | 6 +-
.../main/java/org/apache/ignite/IgniteServer.java | 3 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 4 +-
.../internal/ClusterPerClassIntegrationTest.java | 3 +-
.../internal/ClusterPerTestIntegrationTest.java | 13 +-
.../internal/sql/engine/ItAggregatesTest.java | 72 ++-
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 1 -
.../systemviews/ItTransactionsSystemViewTest.java | 4 +-
.../engine/systemviews/ItZonesSystemViewTest.java | 1 -
.../group1/aggregate/group/test_grouping_sets.test | 149 ++++++
.../group/test_multicolumn_grouping_sets.test | 106 ++++
.../internal/sql/engine/SqlQueryProcessor.java | 4 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 6 +-
.../internal/sql/engine/exec/ExecutionContext.java | 8 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 24 +-
.../sql/engine/exec/MailboxRegistryImpl.java | 6 +-
.../engine/exec/exp/agg/AccumulatorWrapper.java | 3 +
.../sql/engine/exec/exp/agg/Accumulators.java | 65 +++
.../engine/exec/exp/agg/AccumulatorsFactory.java | 19 +-
.../sql/engine/exec/exp/agg/AggregateRow.java | 21 +-
.../sql/engine/exec/kill/KillCommandHandler.java | 4 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 4 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 4 +-
.../internal/sql/engine/exec/rel/Outbox.java | 4 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 2 +-
.../sql/engine/message/MessageListener.java | 4 +-
.../sql/engine/message/MessageServiceImpl.java | 12 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 8 +-
.../sql/engine/rel/agg/MapReduceAggregates.java | 27 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 1 +
.../internal/sql/engine/util/IgniteResource.java | 5 +
.../ignite/internal/sql/docs/OperatorListTest.java | 1 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 24 +-
.../sql/engine/exec/PartitionProvidersTest.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 4 +-
.../exec/exp/agg/GroupingAccumulatorTest.java | 189 +++++++
.../engine/exec/kill/KillCommandHandlerTest.java | 24 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 28 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 18 +-
.../exec/rel/TableScanNodeExecutionTest.java | 10 +-
.../engine/framework/ClusterServiceFactory.java | 52 +-
.../sql/engine/framework/NoOpTransaction.java | 10 +-
.../sql/engine/framework/TestBuilders.java | 8 +-
.../planner/AbstractAggregatePlannerTest.java | 35 +-
.../sql/engine/planner/AggregatePlannerTest.java | 12 +
.../planner/ColocatedHashAggregatePlannerTest.java | 12 +
.../planner/ColocatedSortAggregatePlannerTest.java | 12 +
.../planner/MapReduceHashAggregatePlannerTest.java | 12 +
.../planner/MapReduceSortAggregatePlannerTest.java | 12 +
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 4 +-
.../DistributionZoneSqlToCommandConverterTest.java | 4 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 4 +-
.../sql/engine/sql/SqlReservedWordsTest.java | 581 +++++++++++++++++++++
.../engine/util/IgniteSqlDateTimeUtilsTest.java | 4 +-
.../src/test/resources/docs/operator_list.txt | 3 +
.../src/test/resources/tpcds/plan/q27.plan | 68 +++
.../test/resources/tpcds/plan/q27_colocated.plan | 68 +++
.../disaster/system/MetastorageRepairImpl.java | 4 +-
.../system/SystemDisasterRecoveryManagerImpl.java | 34 +-
.../disaster/system/MetastorageRepairImplTest.java | 14 +-
.../SystemDisasterRecoveryManagerImplTest.java | 44 +-
.../internal/systemview/SystemViewManagerTest.java | 6 +-
.../ItAbstractInternalTableScanTest.java | 12 +-
.../ItInternalTableReadOnlyOperationsTest.java | 18 +-
.../ItInternalTableReadOnlyScanTest.java | 4 +-
.../ItInternalTableReadWriteScanTest.java | 4 +-
.../apache/ignite/distributed/ItLockTableTest.java | 4 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 6 +-
.../ItTxObservableTimePropagationTest.java | 4 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 4 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 10 +-
.../ignite/internal/table/ItColocationTest.java | 8 +-
.../ignite/internal/table/InternalTable.java | 20 +-
.../internal/table/StreamerReceiverRunner.java | 6 +-
.../apache/ignite/internal/table/TableImpl.java | 8 +-
.../ignite/internal/table/TableViewInternal.java | 10 +
.../PartitionReplicatorNodeRecovery.java | 12 +-
.../internal/table/distributed/TableManager.java | 82 +--
.../disaster/DisasterRecoveryManager.java | 21 +-
.../replicator/PartitionReplicaListener.java | 6 +-
.../replicator/TransactionStateResolver.java | 4 +-
.../distributed/storage/InternalTableImpl.java | 22 +-
.../table/partition/HashPartitionManagerImpl.java | 9 +-
.../ignite/internal/utils/PrimaryReplica.java | 8 +-
.../distributed/TableManagerRecoveryTest.java | 12 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../PartitionReplicaListenerIndexLockingTest.java | 8 +-
...itionReplicaListenerSortedIndexLockingTest.java | 8 +-
.../replication/PartitionReplicaListenerTest.java | 14 +-
.../ZonePartitionReplicaListenerTest.java | 14 +-
.../storage/InternalTableEstimatedSizeTest.java | 6 +-
.../distributed/storage/InternalTableImplTest.java | 6 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 24 +-
.../ignite/internal/table/TxAbstractTest.java | 6 +-
.../internal/table/TxInfrastructureTest.java | 8 +-
.../table/impl/DummyInternalTableImpl.java | 28 +-
.../tx/distributed/ItTransactionRecoveryTest.java | 7 +-
.../impl/FinishedReadOnlyTransactionTracker.java | 4 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 4 +-
.../tx/impl/PersistentTxStateVacuumizer.java | 6 +-
.../tx/impl/RemoteReadWriteTransaction.java | 4 +-
.../internal/tx/impl/TxCleanupRequestHandler.java | 12 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 4 +-
.../apache/ignite/internal/tx/TxCleanupTest.java | 12 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 14 +-
...FinishedTransactionBatchRequestHandlerTest.java | 4 +-
.../internal/tx/impl/OrphanDetectorTest.java | 16 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 6 +-
.../internal/worker/ThreadAssertingCursor.java | 1 -
settings.gradle | 2 +-
396 files changed, 4029 insertions(+), 1726 deletions(-)
rename examples/{ => java}/.gitignore (100%)
rename examples/{ => java}/README.md (100%)
rename examples/{ => java}/build.gradle (100%)
rename examples/{ => java}/config/ignite-config.conf (100%)
rename examples/{ => java}/config/java.util.logging.properties (100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/AbstractExamplesTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/ExampleTestUtils.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/sql/ItSqlExamplesTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/storage/ItPageMemoryStorageExampleTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/storage/ItRocksdbStorageExampleTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/table/ItTableExamplesTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/tx/ItTransactionsExamplesTest.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/client/IgniteClientExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/client/IgniteClientWithConfigExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/code/deployment/CodeDeploymentExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/code/deployment/MyJob.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/code/deployment/resources/script.sh
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeAsyncExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeBroadcastExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeCancellationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeColocatedExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeExample.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeJobPriorityExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeMapReduceExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeWithCustomResultMarshallerExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeWithResultExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/AutoSerializableArg.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/AutoSerializableResult.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/CustomPojoSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/CustomPojoSerializationJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/IntegerDecrementJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonArg.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonArgMarshaller.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonResult.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonResultMarshaller.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/NativeTypeSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/PojoAutoSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/PojoAutoSerializationJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/SerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/TupleSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/TupleTransformJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/sql/SqlApiExample.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/sql/jdbc/SqlJdbcExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/PersistentPageMemoryStorageExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/RocksDbStorageExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/StorageEngineExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/VolatilePageMemoryStorageExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/Account.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/DistributedComputeWithReceiverExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/MultiTableDataStreamerExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/RecordViewExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java (100%)
rename examples/{ => java}/src/main/resources/tradesData.csv (100%)
delete mode 100644
modules/api/src/main/java/org/apache/ignite/marshalling/JavaSerializationByteArrayMarshalling.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/MixinTest.java
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/ClusterNodeImpl.java
=>
core/src/main/java/org/apache/ignite/internal/network/PublicClusterNodeImpl.java}
(90%)
copy modules/{api/src/main/java/org/apache/ignite/network/ClusterNode.java =>
network-api/src/main/java/org/apache/ignite/internal/network/InternalClusterNode.java}
(82%)
rename
modules/network-api/src/main/java/org/apache/ignite/internal/network/{ClusterNodeImpl.java
=> InternalClusterNodeImpl.java} (81%)
rename
modules/network-api/src/test/java/org/apache/ignite/internal/network/{ClusterNodeSerializerTest.java
=> InternalClusterNodeSerializerTest.java} (88%)
copy modules/platforms/cpp/ignite/{common/uuid.cpp =>
client/ignite_client_configuration.cpp} (72%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/group1/aggregate/group/test_grouping_sets.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/group1/aggregate/group/test_multicolumn_grouping_sets.test
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/GroupingAccumulatorTest.java
create mode 100644 modules/sql-engine/src/test/resources/tpcds/plan/q27.plan
create mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q27_colocated.plan
