This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a change to branch IGNITE-22662__snapshot_refactoring
in repository https://gitbox.apache.org/repos/asf/ignite.git
from 8806f144676 Fix flaky IgniteClusterSnapshotCheckTest
add 6863dfaccce IGNITE-25357 SQL Calcite: Fixed assertion on planning for
filter with double correlate - Fixes #12183.
add 381e9be96fe IGNITE-25875 SQL Calcite: Refactor PlannerTest - Fixes
#12180.
add c01524f07f2 [MINOR] Make ignite-codegen2 provided (#12187)
add e5b795162ef IGNITE-25359 BinaryStreams moved to ignite-binary-impl
(#12188)
add bc8683b9f17 IGNITE-25882 Remove Serializable interface from Message
(#12185)
add 0afbe4904c0 [MINOR] Make BinaryLazyValue package private (#12195)
add 9941d6d961c IGNITE-25913 Use MessageSerializer for GridIntList (#12192)
add c84a4f5131c IGNITE-23120 Add warn if index inline size is too big
(#12155)
add 72972d710f8 IGNITE-25944 Use MessageSerializer for
SessionChannelMessage (#12196)
add 728b1de4ab2 IGNITE-25871 Fix CdcCommandLineStartup interruption
(#12179)
add 2597ba43704 IGNITE-25950 Use MessageSerializer for GridCacheEntryInfo
(#12198)
add 35736e63fa9 IGNITE-25946 Use MessageSerializer for
UserAuthenticateRequestMessage (#12197)
add 9f5c30e5fdc IGNITE-25960 Use MessageSerializer for
UserAuthenticateResponseMessage (#12199)
add 6454d932bdb [MINOR] Use ${groupId} instead of explicit group name
(#12208)
add 8c283c99cf9 IGNITE-25928 Remove IgniteConfiguration from BinaryContext
(#12194)
add 24f55e85bf6 [MINOR] Minify BinaryUtils methods visibility (#12210)
add 1ba0780e216 IGNITE-25969 Use MessageSerializer for WalStateAckMessage
(#12205)
add 4826f7cff13 IGNITE-25970 Use MessageSerializer for
MissingMappingRequestMessage and MissingMappingResponseMessage (#12206)
add 39c58b0bf53 [MINOR] Minify visibility of BinaryUtils doReadXXXArray
methods (#12213)
add d2e4b417259 IGNITE-25958 Fix exclusions in
IgniteCompatibilityAbstractTest (#12214)
add 4ec0626cba1 IGNITE-25695 SQL Calcite: Fix flaky
TimeCalculationExecutionTest (#12146)
add 5626dc9e0d4 IGNITE-24754 SQL Calcite: Fix MergeJoin/NestedLoopJoin
buffers overflow - Fixes #11977.
add e0248cc9a74 IGNITE-25909 SQL Calcite: Optimize memory consumption for
hash-table based operators - Fixes #12189.
add 40506167234 IGNITE-25971 Use MessageSerializer for
GridQueryKillRequest and GridQueryKillResponse (#12207)
add e1ed0953bdf IGNITE-26015 Use MessageSerializer for
UserManagementOperationFinishedMessage (#12218)
add 0944fc9eb3c IGNITE-25992 Use MessageSerializer for GridCacheVersion
and GridCacheVersionEx (#12215)
add 090454dff01 IGNITE-25834 Fixed flaky
GridCommandHandlerTest#testClusterCreateSnapshotWarning (#12174)
add b43dba33469 IGNITE-25993 Use MessageSerializer for
GridDhtPartitionExchangeId (#12217)
add eea94bf674d IGNITE-26044 Simplify BinaryContext creation (#12225)
add 58157a882ac IGNITE-26049 Remove BinaryConfiguration dependency from
BinaryContext (#12229)
add 5784b72b451 IGNITE-26045 Use MessageSerializer for
TcpInverseConnectionResponseMessage (#12226)
add aa1f3b6f0bf IGNITE-26041 Use MessageSerializer for CacheEvictionEntry
(#12222)
add d3fc842a5fb IGNITE-26077 Remove QueryUtils usage from BinaryContext
(#12232)
add 06a557b2e4d IGNITE-26061 Register predefined types in corresponding
processors (#12230)
add 51aa3a59c98 IGNITE-25996 Use MessageSerializer for CacheVersionedValue
(#12219)
add 76a2e620d9b IGNITE-26026 [ducktests] Migrate to eclipse-temurin JDK
docker image (#12220)
add edc625f76a3 Merge branch 'master' of github.com:apache/ignite into
IGNITE-22662__snapshot_refactoring
No new revisions were added by this update.
Summary of changes:
assembly/dependencies-apache-ignite-lgpl.xml | 1 +
assembly/dependencies-apache-ignite-slim.xml | 1 +
assembly/dependencies-apache-ignite.xml | 1 +
.../benchmarks/jmh/sql/JmhSqlBenchmark.java | 51 ++
modules/binary/api/README.txt | 9 +
.../internal/binary/BinaryPositionReadable.java | 0
.../internal/binary/streams/BinaryInputStream.java | 0
.../binary/streams/BinaryMemoryAllocatorChunk.java | 0
.../binary/streams/BinaryOutputStream.java | 0
.../internal/binary/streams/BinaryStream.java | 0
.../internal/binary/streams/BinaryStreams.java | 35 +-
.../binary/streams/BinaryStreamsFactory.java} | 46 +-
modules/binary/impl/README.txt | 8 +
modules/binary/{api => impl}/pom.xml | 14 +-
.../binary/streams/BinaryAbstractInputStream.java | 0
.../binary/streams/BinaryAbstractOutputStream.java | 0
.../binary/streams/BinaryAbstractStream.java | 0
.../streams/BinaryByteBufferInputStream.java | 0
.../binary/streams/BinaryHeapInputStream.java | 0
.../binary/streams/BinaryHeapOutputStream.java | 0
.../binary/streams/BinaryMemoryAllocator.java | 16 +-
.../binary/streams/BinaryOffheapInputStream.java | 0
.../binary/streams/BinaryOffheapOutputStream.java | 0
.../binary/streams/BinaryStreamsFactoryImpl.java | 72 ++
...te.internal.binary.streams.BinaryStreamsFactory | 1 +
modules/bom/pom.xml | 10 +
.../query/calcite/CalciteQueryProcessor.java | 3 +
...OpMemoryTracker.java => MappingRowHandler.java} | 40 +-
.../query/calcite/exec/RuntimeHashIndex.java | 48 +-
.../query/calcite/exec/exp/agg/GroupKey.java | 110 +--
.../query/calcite/exec/rel/AbstractSetOpNode.java | 29 +-
.../query/calcite/exec/rel/HashAggregateNode.java | 74 +-
.../query/calcite/exec/rel/IntersectNode.java | 2 +-
.../query/calcite/exec/rel/MergeJoinNode.java | 269 ++-----
.../query/calcite/exec/rel/MinusNode.java | 2 +-
.../query/calcite/exec/rel/NestedLoopJoinNode.java | 174 ++---
.../calcite/exec/tracker/ObjectSizeCalculator.java | 2 +-
.../query/calcite/metadata/ColocationGroup.java | 2 +-
.../query/calcite/rel/set/IgniteMapSetOp.java | 3 +-
.../calcite/exec/rel/AbstractExecutionTest.java | 10 +-
.../query/calcite/exec/rel/BaseAggregateTest.java | 3 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 3 +-
.../calcite/exec/rel/JoinBuffersExecutionTest.java | 238 ++++++
.../exec/rel/TimeCalculationExecutionTest.java | 2 +-
.../integration/CorrelatesIntegrationTest.java | 44 +-
.../calcite/integration/JoinIntegrationTest.java | 5 +-
.../tpch/{TpchTest.java => AbstractTpchTest.java} | 14 +-
.../integration/tpch/TpchScale001Test.java} | 13 +-
.../integration/tpch/TpchScale010Test.java} | 20 +-
.../integration/tpch/TpchScale100Test.java} | 25 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 35 +
.../planner/CorrelatedSubqueryPlannerTest.java | 34 +
.../calcite/planner/MergeJoinPlannerTest.java | 22 +
.../query/calcite/planner/PlanExecutionTest.java | 361 +++++++++
.../query/calcite/planner/PlanSplitterTest.java | 281 +++++++
.../query/calcite/planner/PlannerTest.java | 855 ---------------------
.../planner/ProjectFilterScanMergePlannerTest.java | 12 +
.../query/calcite/planner/TestTable.java | 18 +
.../ignite/testsuites/ExecutionTestSuite.java | 2 +
.../ignite/testsuites/IntegrationTestSuite.java | 8 +-
.../apache/ignite/testsuites/PlannerTestSuite.java | 6 +-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 4 +-
.../apache/ignite/internal/MessageProcessor.java | 5 +-
.../internal/MessageSerializerGenerator.java | 11 +-
.../java/org/apache/ignite/internal/Order.java | 9 +-
.../ignite/IgniteCommonsSystemProperties.java | 17 +
.../apache/ignite/internal/util/CommonUtils.java | 90 +++
.../junits/IgniteCompatibilityAbstractTest.java | 6 +-
.../apache/ignite/util/GridCommandHandlerTest.java | 33 +-
modules/core/pom.xml | 16 +-
.../org/apache/ignite/IgniteSystemProperties.java | 17 -
.../ignite/internal/GridDirectTransient.java | 2 +
.../ignite/internal/GridJobCancelRequest.java | 7 +-
.../ignite/internal/GridJobExecuteRequest.java | 6 +-
.../ignite/internal/GridJobExecuteResponse.java | 7 +-
.../ignite/internal/GridJobSiblingsRequest.java | 6 +-
.../ignite/internal/GridJobSiblingsResponse.java | 6 +-
.../ignite/internal/GridTaskCancelRequest.java | 7 +-
.../ignite/internal/GridTaskSessionRequest.java | 6 +-
.../ignite/internal/IgniteDiagnosticMessage.java | 3 -
.../apache/ignite/internal/binary/BinaryArray.java | 2 +-
.../ignite/internal/binary/BinaryContext.java | 279 +++----
.../internal/binary/BinaryEnumObjectImpl.java | 2 +-
.../ignite/internal/binary/BinaryMarshaller.java | 5 +-
.../ignite/internal/binary/BinaryObjectImpl.java | 4 +-
.../internal/binary/BinaryObjectOffheapImpl.java | 2 +-
.../ignite/internal/binary/BinaryReaderExImpl.java | 2 +-
.../apache/ignite/internal/binary/BinaryUtils.java | 371 ++++-----
.../ignite/internal/binary/BinaryWriterExImpl.java | 2 +-
.../internal/binary/builder/BinaryBuilderEnum.java | 2 +-
.../binary/builder/BinaryBuilderReader.java | 8 +-
.../binary/builder/BinaryEnumArrayLazyValue.java | 2 +-
.../binary/builder/BinaryLazyArrayList.java | 7 +-
.../binary/builder/BinaryLazyLinkedList.java | 13 +-
.../internal/binary/builder/BinaryLazyMap.java | 9 +-
.../internal/binary/builder/BinaryLazySet.java | 3 +-
.../internal/binary/builder/BinaryLazyValue.java | 2 +-
.../binary/builder/BinaryObjectArrayLazyValue.java | 2 +-
.../binary/builder/BinaryObjectBuilderImpl.java | 4 +-
.../binary/builder/BinaryObjectBuilders.java | 33 +
.../query/index/sorted/inline/InlineIndexTree.java | 2 +-
.../index/sorted/inline/InlineRecommender.java | 60 +-
.../client/thin/ClientBinaryMarshaller.java | 14 +-
.../internal/client/thin/TcpClientChannel.java | 6 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 13 +-
.../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 8 +-
.../internal/managers/GridManagerAdapter.java | 3 +-
.../managers/checkpoint/GridCheckpointRequest.java | 6 +-
.../managers/communication/GridIoManager.java | 12 +-
.../managers/communication/GridIoMessage.java | 7 +-
.../communication/GridIoMessageFactory.java | 51 +-
.../communication/GridIoSecurityAwareMessage.java | 7 +-
.../managers/communication/GridIoUserMessage.java | 6 +-
.../communication/IgniteIoTestMessage.java | 3 -
.../communication/SessionChannelMessage.java | 59 +-
.../managers/deployment/GridDeploymentRequest.java | 7 +-
.../deployment/GridDeploymentResponse.java | 7 +-
.../encryption/GenerateEncryptionKeyRequest.java | 3 -
.../encryption/GenerateEncryptionKeyResponse.java | 3 -
.../eventstorage/GridEventStorageMessage.java | 3 -
.../UserAuthenticateRequestMessage.java | 98 +--
.../UserAuthenticateResponseMessage.java | 74 +-
.../UserManagementOperationFinishedMessage.java | 76 +-
.../processors/cache/CacheEntryInfoCollection.java | 3 -
.../processors/cache/CacheEvictionEntry.java | 102 +--
.../processors/cache/CacheInvokeDirectResult.java | 5 +-
.../processors/cache/CacheObjectUtils.java | 2 +-
.../processors/cache/GridCacheEntryInfo.java | 127 +--
.../processors/cache/GridCacheMessage.java | 3 -
.../internal/processors/cache/GridCacheUtils.java | 16 +
.../GridChangeGlobalStateMessageResponse.java | 3 -
.../processors/cache/WalStateAckMessage.java | 122 +--
.../processors/cache/binary/BinaryMetadataKey.java | 82 --
.../binary/CacheObjectBinaryProcessorImpl.java | 100 +--
.../cache/binary/MetadataRequestMessage.java | 3 -
.../cache/binary/MetadataResponseMessage.java | 3 -
.../distributed/GridCacheTtlUpdateRequest.java | 3 -
.../distributed/GridCacheTxRecoveryRequest.java | 6 +-
.../distributed/GridCacheTxRecoveryResponse.java | 6 +-
.../distributed/GridDistributedBaseMessage.java | 6 +-
.../distributed/GridDistributedLockRequest.java | 3 -
.../distributed/GridDistributedLockResponse.java | 6 +-
.../GridDistributedTxFinishRequest.java | 6 +-
.../GridDistributedTxFinishResponse.java | 3 -
.../GridDistributedTxPrepareRequest.java | 6 +-
.../GridDistributedTxPrepareResponse.java | 6 +-
.../distributed/GridDistributedUnlockRequest.java | 6 +-
.../dht/GridDhtAffinityAssignmentRequest.java | 3 -
.../dht/GridDhtAffinityAssignmentResponse.java | 3 -
.../cache/distributed/dht/GridDhtLockRequest.java | 6 +-
.../cache/distributed/dht/GridDhtLockResponse.java | 6 +-
.../distributed/dht/GridDhtTxFinishRequest.java | 6 +-
.../distributed/dht/GridDhtTxFinishResponse.java | 6 +-
.../dht/GridDhtTxOnePhaseCommitAckRequest.java | 3 -
.../distributed/dht/GridDhtTxPrepareRequest.java | 6 +-
.../distributed/dht/GridDhtTxPrepareResponse.java | 6 +-
.../distributed/dht/GridDhtUnlockRequest.java | 6 +-
.../dht/PartitionUpdateCountersMessage.java | 3 -
.../dht/TransactionAttributesAwareRequest.java | 3 -
.../AtomicApplicationAttributesAwareRequest.java | 3 -
.../atomic/GridDhtAtomicAbstractUpdateRequest.java | 5 +-
.../GridDhtAtomicDeferredUpdateResponse.java | 6 +-
.../dht/atomic/GridDhtAtomicNearResponse.java | 3 -
.../atomic/GridDhtAtomicSingleUpdateRequest.java | 6 +-
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 6 +-
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 6 +-
.../GridNearAtomicAbstractSingleUpdateRequest.java | 6 +-
.../atomic/GridNearAtomicCheckUpdateRequest.java | 3 -
.../atomic/GridNearAtomicFullUpdateRequest.java | 6 +-
.../GridNearAtomicSingleUpdateFilterRequest.java | 6 +-
.../GridNearAtomicSingleUpdateInvokeRequest.java | 6 +-
.../atomic/GridNearAtomicSingleUpdateRequest.java | 6 +-
.../dht/atomic/GridNearAtomicUpdateResponse.java | 6 +-
.../distributed/dht/atomic/NearCacheUpdates.java | 3 -
.../cache/distributed/dht/atomic/UpdateErrors.java | 3 -
.../dht/preloader/CacheGroupAffinityMessage.java | 3 -
.../dht/preloader/GridDhtForceKeysRequest.java | 6 +-
.../dht/preloader/GridDhtForceKeysResponse.java | 6 +-
.../preloader/GridDhtPartitionDemandMessage.java | 6 +-
.../dht/preloader/GridDhtPartitionExchangeId.java | 99 +--
.../GridDhtPartitionSupplyErrorMessage.java | 3 -
.../preloader/GridDhtPartitionSupplyMessage.java | 6 +-
.../GridDhtPartitionsAbstractMessage.java | 6 +-
.../preloader/GridDhtPartitionsFullMessage.java | 6 +-
.../preloader/GridDhtPartitionsSingleMessage.java | 6 +-
.../preloader/GridDhtPartitionsSingleRequest.java | 6 +-
.../dht/preloader/latch/LatchAckMessage.java | 3 -
.../distributed/near/CacheVersionedValue.java | 78 +-
.../cache/distributed/near/GridNearGetRequest.java | 6 +-
.../distributed/near/GridNearGetResponse.java | 6 +-
.../distributed/near/GridNearLockRequest.java | 6 +-
.../distributed/near/GridNearLockResponse.java | 6 +-
.../distributed/near/GridNearSingleGetRequest.java | 6 +-
.../near/GridNearSingleGetResponse.java | 5 +-
.../distributed/near/GridNearTxFinishRequest.java | 6 +-
.../distributed/near/GridNearTxFinishResponse.java | 6 +-
.../distributed/near/GridNearTxPrepareRequest.java | 6 +-
.../near/GridNearTxPrepareResponse.java | 6 +-
.../distributed/near/GridNearUnlockRequest.java | 6 +-
.../snapshot/AbstractSnapshotMessage.java | 3 +-
.../snapshot/IncrementalSnapshotAwareMessage.java | 3 -
.../snapshot/SnapshotFilesFailureMessage.java | 6 +-
.../snapshot/SnapshotFilesRequestMessage.java | 6 +-
.../wal/reader/StandaloneNoopCommunicationSpi.java | 3 +-
.../wal/reader/StandaloneSpiContext.java | 3 +-
.../cache/query/GridCacheQueryRequest.java | 6 +-
.../cache/query/GridCacheQueryResponse.java | 6 +-
.../processors/cache/query/GridCacheSqlQuery.java | 5 +-
.../continuous/CacheContinuousQueryBatchAck.java | 3 -
.../continuous/CacheContinuousQueryEntry.java | 5 +-
.../cache/transactions/IgniteTxEntry.java | 3 +-
.../processors/cache/transactions/IgniteTxKey.java | 6 +-
.../cache/transactions/TxEntryValueHolder.java | 3 -
.../processors/cache/transactions/TxLock.java | 3 -
.../processors/cache/transactions/TxLockList.java | 3 -
.../cache/transactions/TxLocksRequest.java | 3 -
.../cache/transactions/TxLocksResponse.java | 3 -
.../processors/cache/version/GridCacheVersion.java | 97 +--
.../cache/version/GridCacheVersionEx.java | 59 +-
.../processors/closure/GridClosureProcessor.java | 11 +
.../cluster/ClusterMetricsUpdateMessage.java | 3 -
.../ContinuousRoutineStartResultMessage.java | 3 -
.../continuous/GridContinuousMessage.java | 6 +-
.../processors/datastreamer/DataStreamerEntry.java | 3 -
.../datastreamer/DataStreamerRequest.java | 5 +-
.../datastreamer/DataStreamerResponse.java | 5 +-
.../marshaller/MissingMappingRequestMessage.java | 74 +-
.../marshaller/MissingMappingResponseMessage.java | 94 +--
.../processors/odbc/ClientListenerNioListener.java | 8 +-
.../internal/processors/odbc/SqlListenerUtils.java | 119 +--
.../processors/platform/PlatformProcessorImpl.java | 10 +
.../processors/platform/utils/PlatformUtils.java | 10 +-
.../internal/processors/query/QueryUtils.java | 4 +-
.../twostep/messages/GridQueryCancelRequest.java | 3 -
.../h2/twostep/messages/GridQueryFailResponse.java | 3 -
.../twostep/messages/GridQueryNextPageRequest.java | 3 -
.../messages/GridQueryNextPageResponse.java | 6 +-
.../query/messages/GridQueryKillRequest.java | 100 +--
.../query/messages/GridQueryKillResponse.java | 77 +-
.../message/SchemaOperationStatusMessage.java | 3 -
.../query/stat/messages/StatisticsColumnData.java | 3 +-
.../stat/messages/StatisticsDecimalMessage.java | 3 +-
.../query/stat/messages/StatisticsKeyMessage.java | 6 +-
.../query/stat/messages/StatisticsObjectData.java | 3 +-
.../query/stat/messages/StatisticsRequest.java | 3 -
.../query/stat/messages/StatisticsResponse.java | 3 -
.../rest/handlers/task/GridTaskResultRequest.java | 6 +-
.../rest/handlers/task/GridTaskResultResponse.java | 3 -
.../service/ServiceDeploymentProcessId.java | 3 +-
.../service/ServiceSingleNodeDeploymentResult.java | 3 +-
.../ServiceSingleNodeDeploymentResultBatch.java | 3 -
.../apache/ignite/internal/util/GridIntList.java | 91 +--
.../internal/util/GridMessageCollection.java | 3 -
.../apache/ignite/internal/util/IgniteUtils.java | 251 +++---
.../internal/util/UUIDCollectionMessage.java | 3 -
.../util/distributed/SingleNodeMessage.java | 3 -
.../internal/util/io/GridUnsafeDataInput.java | 2 +-
.../internal/util/io/GridUnsafeDataOutput.java | 2 +-
.../plugin/extensions/communication/Message.java | 3 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 3 +-
.../org/apache/ignite/spi/IgniteSpiContext.java | 5 +-
.../collision/jobstealing/JobStealingRequest.java | 6 +-
.../spi/communication/CommunicationListener.java | 3 +-
.../ignite/spi/communication/CommunicationSpi.java | 3 +-
.../tcp/internal/CommunicationListenerEx.java | 3 +-
.../TcpInverseConnectionResponseMessage.java | 52 +-
.../tcp/messages/HandshakeMessage.java | 5 +-
.../tcp/messages/HandshakeWaitMessage.java | 5 +-
.../communication/tcp/messages/NodeIdMessage.java | 3 -
.../tcp/messages/RecoveryLastReceivedMessage.java | 5 +-
.../startup/cmdline/CdcCommandLineStartup.java | 16 +-
.../binary/BinaryContextPredefinedTypesTest.java | 6 +-
.../binary/BinaryFieldExtractionSelfTest.java | 12 +-
.../binary/BinaryFieldsAbstractSelfTest.java | 12 +-
.../BinaryFooterOffsetsAbstractSelfTest.java | 13 +-
.../internal/binary/BinaryMarshallerSelfTest.java | 12 +-
.../GridBinaryMarshallerCtxDisabledSelfTest.java | 9 +-
.../binary/GridBinaryWildcardsSelfTest.java | 6 +-
.../binary/RawBinaryObjectExtractorTest.java | 7 +-
.../cache/IgniteIncompleteCacheObjectSelfTest.java | 3 -
.../GridBinaryCacheEntryMemorySizeSelfTest.java | 8 +-
.../platform/PlatformGetInternalCachesTask.java | 8 +-
.../session/GridSessionCheckpointSelfTest.java | 9 +-
...dJobStealingCollisionSpiAttributesSelfTest.java | 14 +-
...StealingCollisionSpiCustomTopologySelfTest.java | 7 +-
.../GridJobStealingCollisionSpiSelfTest.java | 17 +-
.../ignite/testframework/GridSpiTestContext.java | 9 +-
.../testframework/junits/GridAbstractTest.java | 7 +-
.../junits/GridTestBinaryMarshaller.java | 7 +-
.../ignite/testframework/junits/IgniteMock.java | 22 +-
.../testframework/junits/IgniteTestResources.java | 8 +-
.../src/test/resources/codegen/TestMessage.java | 11 +
.../resources/codegen/TestMessageSerializer.java | 16 +-
modules/ducktests/tests/docker/Dockerfile | 15 +-
modules/ducktests/tests/docker/requirements.txt | 3 +-
modules/ducktests/tests/docker/run_tests.sh | 4 +-
.../internal/processors/query/h2/QueryTable.java | 5 +-
.../query/h2/twostep/msg/GridH2DmlRequest.java | 6 +-
.../query/h2/twostep/msg/GridH2DmlResponse.java | 3 -
.../query/h2/twostep/msg/GridH2QueryRequest.java | 6 +-
...aryMetadataConcurrentUpdateWithIndexesTest.java | 12 +-
...dc-config.xml => cdc-command-line-consumer.xml} | 21 +-
.../ignite/cdc/CdcCommandLineStartupTest.java | 157 ++++
.../ignite/testsuites/IgniteSpringTestSuite.java | 2 +
parent/pom.xml | 2 +-
pom.xml | 1 +
306 files changed, 3213 insertions(+), 4170 deletions(-)
create mode 100644 modules/binary/api/README.txt
rename modules/{core =>
binary/api}/src/main/java/org/apache/ignite/internal/binary/BinaryPositionReadable.java
(100%)
rename modules/{core =>
binary/api}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryInputStream.java
(100%)
rename modules/{core =>
binary/api}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryMemoryAllocatorChunk.java
(100%)
rename modules/{core =>
binary/api}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryOutputStream.java
(100%)
rename modules/{core =>
binary/api}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryStream.java
(100%)
copy modules/{core =>
binary/api}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryStreams.java
(75%)
rename
modules/{core/src/main/java/org/apache/ignite/internal/binary/streams/BinaryStreams.java
=>
binary/api/src/main/java/org/apache/ignite/internal/binary/streams/BinaryStreamsFactory.java}
(60%)
create mode 100644 modules/binary/impl/README.txt
copy modules/binary/{api => impl}/pom.xml (83%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryAbstractInputStream.java
(100%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryAbstractOutputStream.java
(100%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryAbstractStream.java
(100%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryByteBufferInputStream.java
(100%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryHeapInputStream.java
(100%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryHeapOutputStream.java
(100%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryMemoryAllocator.java
(92%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryOffheapInputStream.java
(100%)
rename modules/{core =>
binary/impl}/src/main/java/org/apache/ignite/internal/binary/streams/BinaryOffheapOutputStream.java
(100%)
create mode 100644
modules/binary/impl/src/main/java/org/apache/ignite/internal/binary/streams/BinaryStreamsFactoryImpl.java
create mode 100644
modules/binary/impl/src/main/resources/META-INF/services/org.apache.ignite.internal.binary.streams.BinaryStreamsFactory
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/{tracker/NoOpMemoryTracker.java
=> MappingRowHandler.java} (50%)
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/JoinBuffersExecutionTest.java
rename
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/tpch/{TpchTest.java
=> AbstractTpchTest.java} (83%)
copy
modules/{core/src/test/java/org/apache/ignite/internal/processors/cache/consistency/inmem/AtomicReadRepairTest.java
=>
calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/tpch/TpchScale001Test.java}
(74%)
copy
modules/{jcl/src/test/java/org/apache/ignite/testsuites/IgniteJclTestSuite.java
=>
calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/tpch/TpchScale010Test.java}
(74%)
copy
modules/{core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotSingleBackupWALBlockingTest.java
=>
calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/tpch/TpchScale100Test.java}
(63%)
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/PlanExecutionTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/PlanSplitterTest.java
delete mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/PlannerTest.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataKey.java
copy modules/spring/src/test/config/cdc/{correct-cdc-config.xml =>
cdc-command-line-consumer.xml} (73%)
create mode 100644
modules/spring/src/test/java/org/apache/ignite/cdc/CdcCommandLineStartupTest.java
