This is an automated email from the ASF dual-hosted git repository.
ppa pushed a change to branch ignite-26029
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from c980e8d4021 IGNITE-26029 Test improvement.
add ad38bf0af57 IGNITE-26078 Update transactions Java example (#6346)
add 8a93cd8318c IGNITE-26082 Update Streaming API examples (#6348)
add 5b328d66dd9 IGNITE-26132 Improve retry writing of dirty pages (#6382)
add 55bec6e74cc IGNITE-26021 Support prefixes in JitComparator (#6377)
add fffbc662d7e IGNITE-21553 fixed test: compute broadcast when using
incorrect node. (#6381)
add 1ecc1b64643 IGNITE-26162 make compatibility tests more extensible &
fix hardcode (#6386)
add 1bd6475444f IGNITE-25811 Sql. Forbid use of an expression as interval
string (#6364)
add aad0f8a9677 IGNITE-26165 Fix event log configuration usage (#6388)
add e6792e23313 IGNITE-26167 Fix testExecuteMapReduceExceptionPropagation
(#6390)
add ab8b8bb3f2a IGNITE-26112 Disable multiline separators (#6367)
add 7c26060d20c IGNITE-26171 Fix NullPointerException on write retry pages
at checkpoint (#6394)
add 1e6487e7f02 IGNITE-26075 Fix refreshAndGetLeaderWithTerm in order not
to return stale leader (#6344)
add 4c92cf4262c IGNITE-26002 Network thread even distribution (#6370)
add 7179bc254b5 Bump spring-boot from 3.5.3 to 3.5.4 (#6319)
add f9b0045378a Bump org.junit.platform:junit-platform-console from 1.13.3
to 1.13.4 (#6292)
add 127e0dbecf4 IGNITE-25191 Fix Vacuum silently fails in ItSqlLogicTest
(#6373)
add e7ff1c9390e Bump io.swagger.core.v3:swagger-annotations from 2.2.34 to
2.2.35 (#6351)
add eb34d9c9d0f Merge remote-tracking branch 'origin/main' into
ignite-26029
No new revisions were added by this update.
Summary of changes:
check-rules/checkstyle-rules.xml | 2 +
.../{pojo/AccountValue.java => Account.java} | 79 ++-
.../streaming/DetectFailedEntriesExample.java | 96 +++
.../DistributedComputeWithReceiverExample.java | 144 ++++
.../streaming/KeyValueViewDataStreamerExample.java | 219 ------
.../KeyValueViewPojoDataStreamerExample.java | 219 ------
.../streaming/MultiTableDataStreamerExample.java | 97 +++
.../streaming/RecordViewDataStreamerExample.java | 217 ------
.../RecordViewPojoDataStreamerExample.java | 213 ------
.../streaming/SingleTableDataStreamerExample.java | 132 ++++
.../ignite/example/streaming/TwoTableReceiver.java | 44 ++
.../ignite/example/streaming/pojo/Account.java | 98 ---
.../ignite/example/streaming/pojo/AccountKey.java | 50 --
.../ignite/example/streaming/pojo/Trade.java | 118 ----
.../receiver/ReceiverStreamProcessingExample.java | 276 --------
...treamProcessingWithResultSubscriberExample.java | 342 ----------
...iverStreamProcessingWithTableUpdateExample.java | 379 -----------
.../ignite/example/tx/TransactionsExample.java | 133 ++--
gradle/libs.versions.toml | 6 +-
.../tests/containers/Ignite3ClusterContainer.java | 1 -
.../converters/ClientConnectorConverter.java | 1 -
.../persistence/MigrationCacheProcessor.java | 1 -
.../catalog/definitions/TableDefinition.java | 1 -
.../apache/ignite/deployment/version/Version.java | 1 -
.../org/apache/ignite/marshalling/Marshaller.java | 1 -
.../UnsupportedObjectTypeMarshallingException.java | 1 -
.../exception/InvalidCredentialsException.java | 1 -
.../UnsupportedAuthenticationTypeException.java | 1 -
.../org/apache/ignite/tx/TransactionException.java | 1 -
.../marshalling/ByteArrayMarshallerTest.java | 2 -
.../internal/binarytuple/BinaryTupleParser.java | 2 +-
.../inlineschema/TupleWithSchemaMarshalling.java | 2 -
.../ignite/internal/catalog/ItCatalogDslTest.java | 1 -
.../catalog/sql/CreateFromDefinitionTest.java | 1 -
.../internal/catalog/CatalogApplyResult.java | 1 -
.../internal/catalog/commands/CatalogUtils.java | 1 -
.../catalog/commands/CreateSystemViewCommand.java | 1 -
.../descriptors/CatalogSortedIndexDescriptor.java | 1 -
.../catalog/descriptors/ConsistencyMode.java | 1 -
.../ignite/internal/catalog/CatalogIndexTest.java | 1 -
.../ignite/internal/catalog/CatalogSchemaTest.java | 1 -
.../internal/catalog/CatalogSystemViewTest.java | 1 -
.../ignite/internal/catalog/CatalogZoneTest.java | 1 -
.../configuration/ItConfigCommandTest.java | 2 -
...tConnectWithBasicAuthenticationCommandTest.java | 1 -
.../repl/executor/ItIgnitePicocliCommandsTest.java | 1 -
.../java/org/apache/ignite/internal/cli/Main.java | 1 -
.../cli/call/cliconfig/profile/ProfileList.java | 1 -
.../internal/cli/commands/CommandConstants.java | 1 -
.../cluster/init/ClusterInitReplCommand.java | 1 -
.../cluster/init/ConfigFileParseException.java | 1 -
.../cluster/unit/ClusterUnitDeployCommand.java | 1 -
.../cluster/unit/ClusterUnitDeployReplCommand.java | 1 -
.../cluster/unit/ClusterUnitListCommand.java | 1 -
.../cluster/unit/ClusterUnitListReplCommand.java | 1 -
.../cluster/unit/ClusterUnitUndeployCommand.java | 1 -
.../unit/ClusterUnitUndeployReplCommand.java | 1 -
.../commands/node/unit/NodeUnitListCommand.java | 1 -
.../node/unit/NodeUnitListReplCommand.java | 1 -
.../questions/ConnectToClusterQuestion.java | 1 -
.../cli/commands/treesitter/parser/Parser.java | 1 -
.../ignite/internal/cli/config/ini/IniParser.java | 1 -
.../cli/core/call/SingleCallExecutionPipeline.java | 1 -
.../cli/core/exception/ExceptionWriter.java | 1 -
.../core/exception/UnitAlreadyExistsException.java | 1 -
.../completer/DynamicCompleterActivationPoint.java | 1 -
.../completer/hocon/HoconDynamicCompleter.java | 1 -
.../repl/executor/RegistryCommandExecutor.java | 1 -
.../apache/ignite/internal/cli/sql/SqlSchema.java | 1 -
.../ignite/internal/cli/sql/SqlSchemaLoader.java | 1 -
.../cli/commands/cluster/ClusterInitTest.java | 1 -
.../partitions/restart/RestartPartitionsTest.java | 1 -
.../repl/completer/HoconDynamicCompleterTest.java | 1 -
.../repl/completer/StringDynamicCompleterTest.java | 1 -
.../filter/DeployUnitsOptionsFilterTest.java | 1 -
.../style/component/MessageUiComponentTest.java | 1 -
.../ignite/internal/cli/util/ArrayUtilsTest.java | 1 -
.../client/proto/StreamerReceiverSerializer.java | 1 -
.../internal/compute/SharedComputeUtils.java | 1 -
.../jdbc/proto/event/JdbcQuerySingleResult.java | 1 -
.../proto/ClientMessagePackerUnpackerTest.java | 1 -
.../ignite/client/handler/ItClientHandlerTest.java | 1 -
.../ignite/client/handler/ClientHandlerModule.java | 16 +-
.../handler/ClientInboundMessageHandler.java | 17 +-
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 1 -
.../client/compute/ClientJobExecution.java | 1 -
.../ignite/internal/client/sql/ClientSql.java | 1 -
.../ignite/internal/client/table/ClientTuple.java | 1 -
.../apache/ignite/client/ClientMetricsTest.java | 1 -
.../ignite/client/TestClientHandlerModule.java | 3 +-
.../apache/ignite/client/fakes/FakeCompute.java | 1 -
.../ignite/client/fakes/FakeIgniteTables.java | 1 -
.../cluster/management/ItClusterManagerTest.java | 1 -
.../cluster/management/ClusterInitializer.java | 1 -
.../cluster/management/ClusterInitializerTest.java | 1 -
.../internal/cluster/management/MockNode.java | 1 -
.../internal/deployment/ItDeploymentUnitTest.java | 1 -
.../internal/deployunit/FileDeployerService.java | 1 -
.../exception/DeploymentUnitNotFoundException.java | 1 -
.../deployunit/message/DeployUnitMessageTypes.java | 1 -
.../metastore/DeploymentUnitStoreImpl.java | 1 -
modules/compatibility-tests/build.gradle | 12 +-
...ldClientWithCurrentServerCompatibilityTest.java | 2 +-
.../ignite/internal/CompatibilityTestBase.java | 24 +-
.../org/apache/ignite/internal/IgniteCluster.java | 24 +-
.../PlatformCompatibilityTestNodeRunner.java | 3 +-
.../compute/ClassLoaderExceptionsMapper.java | 1 -
.../queue/BoundedPriorityBlockingQueue.java | 1 -
.../compute/loader/JobContextManagerTest.java | 1 -
.../notifications/ConfigurationListener.java | 5 +
.../configuration/ConfigurationChanger.java | 1 -
.../ConfigurationDynamicDefaultsPatcherImpl.java | 1 -
.../configuration/ConfigurationTreeGenerator.java | 1 -
.../configuration/asm/InnerNodeAsmGenerator.java | 1 -
.../asm/ConfigurationTreeGeneratorTest.java | 1 -
.../tree/ConstructableTreeNodeTest.java | 1 -
.../tree/ConverterToMapVisitorTest.java | 1 -
.../configuration/tree/InternalIdTest.java | 1 -
.../ignite/internal/lang/IgniteStringBuilder.java | 1 -
.../apache/ignite/internal/util/GridUnsafe.java | 1 -
.../org/apache/ignite/internal/util/HashUtils.java | 1 -
.../apache/ignite/internal/util/IgniteUtils.java | 1 -
.../ignite/internal/util/PointerWrapping.java | 1 -
.../util/subscription/AccumulatorSubscriber.java | 1 -
.../util/subscription/ConcatenatedPublisher.java | 1 -
.../internal/future/InFlightFuturesTest.java | 1 -
.../ignite/internal/future/OrderingFutureTest.java | 2 -
.../testframework/matchers/TaskStateMatcher.java | 1 -
.../rebalance/ItRebalanceDistributedTest.java | 1 -
.../distributionzones/rebalance/RebalanceUtil.java | 1 -
.../utils/CatalogAlterZoneEventListenerTest.java | 1 -
.../DistributionZonesTestUtil.java | 1 -
.../eventlog/impl/ItEventLogConfigurationTest.java | 12 +-
.../internal/eventlog/impl/ChannelRegistry.java | 10 +
.../impl/ConfigurationBasedChannelRegistry.java | 56 +-
.../impl/ConfigurationBasedSinkRegistry.java | 50 +-
.../internal/eventlog/impl/EventLogImpl.java | 19 +-
.../internal/eventlog/impl/SinkRegistry.java | 10 +
.../internal/eventlog/event/IgniteEventsTest.java | 1 -
.../ConfigurationBasedChannelRegistryTest.java | 7 +
.../impl/ConfigurationBasedSinkRegistryTest.java | 7 +
.../internal/eventlog/impl/EventLogTest.java | 16 +
.../network/file/FileChunkMessagesStream.java | 1 -
.../network/file/FileTransferServiceImpl.java | 1 -
.../internal/network/file/FileSenderTest.java | 1 -
.../network/file/FileTransferServiceImplTest.java | 1 -
.../ignite/jdbc/ItJdbcMultiStatementSelfTest.java | 1 -
.../ignite/jdbc/ItJdbcResultSetSelfTest.java | 32 +-
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 1 -
.../ignite/internal/marshaller/Marshaller.java | 1 -
.../metastorage/dsl/CompoundConditionType.java | 1 -
.../internal/metastorage/dsl/ConditionType.java | 1 -
.../internal/metastorage/server/Statement.java | 1 -
.../metrics/exporters/ItJvmMetricSourceTest.java | 1 -
.../exporters/ItMetricExportersLoadingTest.java | 2 -
.../ignite/internal/metrics/MetricManagerImpl.java | 1 -
.../internal/network/NettyBootstrapFactory.java | 19 +-
.../handshake/HandshakeEventLoopSwitcher.java | 205 ++++++
.../network/netty/ChannelEventLoopsSource.java | 33 -
.../ignite/internal/network/netty/ChannelKey.java | 2 +-
.../internal/network/netty/ConnectionManager.java | 13 +-
.../network/recovery/HandshakeManagerUtils.java | 57 --
.../recovery/RecoveryAcceptorHandshakeManager.java | 12 +-
.../RecoveryInitiatorHandshakeManager.java | 11 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 3 +-
.../PerSessionSerializationService.java | 1 -
.../marshal/BuiltInNonContainerMarshallers.java | 1 -
.../serialization/marshal/ProtocolMarshalling.java | 1 -
.../network/DefaultMessagingServiceTest.java | 2 +-
.../handshake/NoOpHandshakeEventLoopSwitcher.java | 56 ++
.../network/netty/RecoveryHandshakeTest.java | 6 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 4 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 4 +-
.../internal/network/messages/NetworkMessage1.java | 1 -
.../internal/network/messages/NetworkMessage2.java | 1 -
.../internal/pagememory/freelist/FreeListImpl.java | 1 -
.../pagememory/persistence/PageStoreWriter.java | 2 +-
.../persistence/PersistentPageMemory.java | 73 +-
.../persistence/checkpoint/CheckpointManager.java | 2 +-
.../checkpoint/CheckpointPagesWriter.java | 37 +-
.../internal/pagememory/freelist/TestDataRow.java | 1 -
.../checkpoint/CheckpointPagesWriterTest.java | 10 +-
.../throttling/ProgressSpeedCalculationTest.java | 1 -
.../AssignmentsChainSerializer.java | 1 -
.../handlers/TxFinishReplicaRequestHandler.java | 1 -
.../network/disaster/LocalPartitionStateEnum.java | 1 -
.../network/replication/RequestTypeTest.java | 1 -
.../raft/ZonePartitionRaftListenerTest.java | 2 -
.../MultiActorPlacementDriverTest.java | 1 -
.../cpp/tests/client-test/compute_test.cpp | 21 +-
.../server/snasphot/UpdateCountRaftListener.java | 1 -
.../storage/impl/StorageDestructionIntent.java | 1 -
.../apache/ignite/raft/jraft/core/NodeImpl.java | 154 ++++-
.../ignite/raft/jraft/rpc/RaftClientService.java | 12 +
.../ignite/raft/jraft/rpc/RaftServerService.java | 10 +
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 2 +-
.../rpc/impl/cli/GetLeaderRequestProcessor.java | 68 +-
.../rpc/impl/core/DefaultRaftClientService.java | 12 +-
.../internal/raft/storage/TermCacheTest.java | 1 -
.../ignite/internal/replicator/ReplicaService.java | 3 +-
...tion.java => AwaitReplicaTimeoutException.java} | 20 +-
.../replicator/exception/ReplicationException.java | 2 +-
.../exception/ReplicationTimeoutException.java | 2 +-
.../rest/api/deployment/UnitVersionStatus.java | 1 -
.../internal/rest/matcher/RestJobStateMatcher.java | 2 -
.../ignite/internal/rest/ItRestPortsTest.java | 1 -
.../recovery/ItDisasterRecoveryControllerTest.java | 1 -
...onfigurationValidationExceptionHandlerTest.java | 1 -
.../internal/benchmark/FutureTimeoutBenchmark.java | 1 -
.../app/client/ItThinClientAuthenticationTest.java | 1 -
.../client/ItThinClientComputeMarshallingTest.java | 1 -
.../runner/app/client/ItThinClientComputeTest.java | 25 +-
.../runner/app/client/ItThinClientSqlTest.java | 1 -
.../ignite/internal/table/ItInternalTableTest.java | 1 -
.../partition/ItAbstractPartitionManagerTest.java | 1 -
.../org/apache/ignite/internal/app/IgniteImpl.java | 6 +-
.../ignite/internal/configuration/IgnitePaths.java | 1 -
.../threading/PublicApiThreadingIgniteCatalog.java | 1 -
.../framework/ConfigAnnotationValue.java | 1 -
.../framework/ConfigurationTreeComparator.java | 1 -
.../ConfigurationTreeComparatorSelfTest.java | 1 -
.../ignite/internal/ClusterConfiguration.java | 1 -
.../internal/ClusterPerClassIntegrationTest.java | 1 -
.../ignite/internal/schema/SchemaManagerTest.java | 1 -
.../internal/schema/marshaller/MapperTest.java | 1 -
.../schema/BinaryTupleComparatorBaseTest.java | 6 +-
.../AuthenticationProviderConfigurationSchema.java | 1 -
.../authentication/AuthenticationManagerImpl.java | 1 -
.../ignite/IgniteClientAutoConfiguration.java | 1 -
.../ignite/IgniteClientAutoConfigurationTest.java | 1 -
.../org/apache/ignite/data/SpringDataJdbcTest.java | 1 -
.../sql/engine/ItAlterTableAlterColumnTest.java | 1 -
.../internal/sql/engine/ItAlterTableDdlTest.java | 1 -
.../internal/sql/engine/ItDataTypesTest.java | 5 -
.../sql/engine/ItDynamicParameterTest.java | 52 +-
.../ignite/internal/sql/engine/ItIntervalTest.java | 203 +++---
.../internal/sql/engine/ItSqlOperatorsTest.java | 6 +-
.../engine/datatypes/ItDivisionDecimalTest.java | 2 -
.../engine/datatypes/tests/TestTypeArguments.java | 3 -
.../datatypes/varbinary/ItVarBinaryIndexTest.java | 1 -
.../datatypes/varbinary/ItVarBinaryJoinTest.java | 1 -
.../datatypes/varbinary/ItVarBinaryQueryTest.java | 1 -
.../datatypes/varbinary/ItVarBinarySetOpTest.java | 1 -
.../engine/systemviews/ItLocksSystemViewTest.java | 1 -
.../apache/ignite/internal/sql/sqllogic/For.java | 1 -
.../internal/sql/sqllogic/ItSqlLogicTest.java | 3 -
.../apache/ignite/internal/sql/sqllogic/Loop.java | 1 -
.../internal/sql/sqllogic/ScriptException.java | 1 -
.../sql/group1/cast/test_cast_bigint.test | 2 +-
.../sql/group1/cast/test_cast_decimal.test | 6 +-
.../sql/group1/cast/test_cast_float.test | 2 +-
.../sql/group1/cast/test_cast_int.test | 2 +-
.../sql/group1/cast/test_cast_interval_day.test | 2 +-
.../sql/group1/cast/test_cast_interval_year.test | 2 +-
.../sql/group1/cast/test_cast_smallint.test | 2 +-
.../sql/group1/cast/test_cast_tinyint.test | 2 +-
.../group1/function/date/test_extract_month.test | 750 +--------------------
.../group1/function/date/test_extract_year.test | 644 +-----------------
.../generic/test_in_list_of_single_element.test | 2 +-
.../group1/types/date/test_incorrect_dates.test | 8 +-
.../group1/types/interval/interval_constants.test | 54 +-
.../types/timestamp/test_incorrect_timestamp.test | 18 +-
.../timestamp/test_incorrect_timestamp_ltz.test | 18 +-
.../engine/exec/ExecutionDependencyResolver.java | 1 -
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 1 -
.../engine/exec/exp/SearchBoundsImplementor.java | 2 -
.../exec/mapping/smallcluster/AbstractTarget.java | 1 -
.../sql/engine/exec/rel/MergeJoinNode.java | 1 -
.../sql/engine/prepare/IgniteSqlValidator.java | 9 +
.../prepare/IgniteSqlValidatorErrorMessages.java | 1 -
.../ddl/ClusterWideStorageProfileValidator.java | 1 -
.../prepare/ddl/DdlSqlToCommandConverter.java | 1 -
.../pruning/PartitionPruningMetadataExtractor.java | 1 -
.../internal/sql/engine/rel/IgniteMergeJoin.java | 1 -
.../sql/engine/rel/agg/MapReduceAggregates.java | 1 -
.../rel/logical/IgniteLogicalSystemViewScan.java | 1 -
.../internal/sql/engine/rex/IgniteRexBuilder.java | 34 +
.../sql/engine/rule/LogicalScanConverterRule.java | 1 -
.../IgniteProjectCorrelateTransposeRule.java | 1 -
.../engine/rule/logical/ProjectScanMergeRule.java | 1 -
.../engine/schema/AbstractIgniteDataSource.java | 1 -
.../sql/engine/schema/IgniteDataSource.java | 1 -
.../sql/engine/schema/SqlSchemaManagerImpl.java | 1 -
.../sql/engine/sql/IgniteAbstractSqlAlterZone.java | 1 -
.../sql/engine/sql/IgniteSqlCreateIndex.java | 1 -
.../internal/sql/engine/sql/IgniteSqlExplain.java | 1 -
.../internal/sql/engine/sql/IgniteSqlParser.java | 1 -
.../engine/statistic/SqlStatisticManagerImpl.java | 1 -
.../sql/engine/type/IgniteTypeFactory.java | 1 -
.../ignite/internal/sql/engine/util/Commons.java | 1 -
.../sql/engine/util/ExtendedProjectedTuple.java | 1 -
.../sql/engine/exec/QueryRecoveryTest.java | 1 -
.../internal/sql/engine/exec/QueryTimeoutTest.java | 1 -
.../exec/rel/DataSourceScanNodeExecutionTest.java | 1 -
.../sql/engine/exec/rel/ScanNodeExecutionTest.java | 1 -
.../sql/engine/framework/TestBuilders.java | 1 -
.../internal/sql/engine/framework/TestNode.java | 1 -
.../sql/engine/planner/AbstractPlannerTest.java | 1 -
.../sql/engine/planner/AggregatePlannerTest.java | 2 -
.../sql/engine/planner/CastResolutionTest.java | 2 +-
.../sql/engine/planner/DynamicParametersTest.java | 2 -
.../sql/engine/planner/ImplicitCastsTest.java | 1 -
.../planner/MapReduceHashAggregatePlannerTest.java | 1 -
.../internal/sql/engine/planner/PlannerTest.java | 2 -
.../sql/engine/planner/SetOpPlannerTest.java | 2 -
.../planner/datatypes/BaseTypeCoercionTest.java | 2 -
.../DateTimeComparisonTypeCoercionTest.java | 2 -
.../DateTimeFunctionsTypeCoercionTest.java | 1 -
.../DateTimeInsertSourcesTypeCoercionTest.java | 2 -
.../DateTimeMergeSourcesCoercionTest.java | 2 -
.../datatypes/DateTimeQualifyCoercionTest.java | 2 -
.../datatypes/DateTimeSetOperatorCoercionTest.java | 2 -
.../DateTimeUpdateSourcesCoercionTest.java | 3 -
.../NumericBinaryOperationsTypeCoercionTest.java | 13 -
.../datatypes/NumericCaseTypeCoercionTest.java | 41 --
.../NumericComparisonTypeCoercionTest.java | 13 -
.../datatypes/NumericMergeSourcesCoercionTest.java | 1 -
.../NumericQuantifyOperatorTypeCoercionTest.java | 13 -
.../datatypes/NumericSetOperatorCoercionTest.java | 1 -
.../NumericUpdateSourcesCoercionTest.java | 1 -
.../datatypes/utils/CharacterStringPair.java | 1 -
.../datatypes/utils/DifferentFamiliesPair.java | 1 -
.../datatypes/utils/DifferentFamiliesPairTest.java | 1 -
.../planner/datatypes/utils/NumericPair.java | 1 -
.../PartitionAwarenessMetadataTest.java | 1 -
.../pruning/PruningMetadataSerializationTest.java | 2 -
.../engine/schema/SqlSchemaManagerImplTest.java | 1 -
.../internal/sql/engine/sql/SqlDdlParserTest.java | 1 -
.../sql/engine/type/IgniteTypeSystemTest.java | 1 -
.../internal/sql/engine/util/TypeUtilsTest.java | 1 -
.../util/format/SqlDateTimeParserSelfTest.java | 1 -
.../src/testFixtures/resources/tpcds/query12.sql | 2 +-
.../src/testFixtures/resources/tpcds/query16.sql | 2 +-
.../src/testFixtures/resources/tpcds/query20.sql | 2 +-
.../src/testFixtures/resources/tpcds/query21.sql | 4 +-
.../src/testFixtures/resources/tpcds/query32.sql | 4 +-
.../src/testFixtures/resources/tpcds/query37.sql | 2 +-
.../src/testFixtures/resources/tpcds/query40.sql | 4 +-
.../src/testFixtures/resources/tpcds/query5.sql | 6 +-
.../src/testFixtures/resources/tpcds/query72.sql | 2 +-
.../src/testFixtures/resources/tpcds/query77.sql | 12 +-
.../src/testFixtures/resources/tpcds/query80.sql | 6 +-
.../src/testFixtures/resources/tpcds/query82.sql | 2 +-
.../src/testFixtures/resources/tpcds/query92.sql | 4 +-
.../src/testFixtures/resources/tpcds/query94.sql | 2 +-
.../src/testFixtures/resources/tpcds/query95.sql | 2 +-
.../src/testFixtures/resources/tpcds/query98.sql | 2 +-
.../storage/AbstractMvTableStorageTest.java | 1 -
.../AbstractPageMemoryStorageEngine.java | 1 -
.../storage/pagememory/StoragePartitionMetaIo.java | 1 -
.../sorted/comparator/JitComparatorGenerator.java | 151 +++--
.../sorted/comparator/JitComparatorOptions.java | 133 ++++
.../index/sorted/comparator/JitComparatorTest.java | 21 +-
.../ItInternalTableReadOnlyOperationsTest.java | 1 -
.../internal/table/distributed/TableManager.java | 2 -
.../disaster/DisasterRecoveryManager.java | 1 -
.../table/distributed/StorageCleanupTest.java | 2 -
.../ZonePartitionReplicaListenerTest.java | 2 -
.../disaster/ItDisasterRecoveryManagerTest.java | 1 -
.../ItDisasterRecoveryReconfigurationTest.java | 2 -
.../tx/distributed/ItTxResourcesVacuumTest.java | 1 -
.../ignite/internal/tx/PartitionEnlistment.java | 1 -
.../internal/tx/TransactionInternalException.java | 1 -
.../org/apache/ignite/internal/tx/TxState.java | 1 -
.../tx/impl/PersistentTxStateVacuumizer.java | 14 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 1 -
.../tx/impl/WaitDieDeadlockPreventionPolicy.java | 1 -
.../internal/tx/AbstractLockManagerTest.java | 2 -
.../internal/tx/CoarseGrainedLockManagerTest.java | 1 -
.../org/apache/ignite/internal/tx/TxStateTest.java | 2 -
370 files changed, 2005 insertions(+), 4646 deletions(-)
rename
examples/src/main/java/org/apache/ignite/example/streaming/{pojo/AccountValue.java
=> Account.java} (52%)
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/DistributedComputeWithReceiverExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewPojoDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/MultiTableDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/RecordViewDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/RecordViewPojoDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/Account.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/AccountKey.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/Trade.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithResultSubscriberExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithTableUpdateExample.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/handshake/HandshakeEventLoopSwitcher.java
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/netty/ChannelEventLoopsSource.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/internal/network/handshake/NoOpHandshakeEventLoopSwitcher.java
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/{ReplicationTimeoutException.java
=> AwaitReplicaTimeoutException.java} (60%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/comparator/JitComparatorOptions.java
