You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2022/03/03 13:57:34 UTC
[ignite-3] branch ignite-16115 updated (639f879 -> d719fed)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-16115
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 639f879 Minor.
add c4d80d0 IGNITE-16479: Fix mentions for SQL resolved tickets - Fixes #634.
add 66a6f39 IGNITE-15156 ITJRaftCounterServerTest.testFollowerCatchUpFromSnapshot2 is flaky (#632)
add c06f4c4 IGNITE-16442 Upgrade to Apache Calcite 1.29.0
add 33b449a IGNITE-16487 Use PATCH HTTP verb instead of PUT for modifying cluster/node configuration (#638)
add ca09fba IGNITE-16445 Always specify charset explicitly (#617)
add 9aaaf48 IGNITE-16148 Enrich IgniteTransactions javadoc with tx examples. Fixes #641
add 2cf7b4b IGNITE-16495 Make RestModule handlers asynchronous
add d0eab12 IGNITE-16422 Fix ArrayOutOfBoundException on row update via SQL (#606)
add 86ed4f7 IGNITE-16506 Modernizer plugin does not find any violations during the build even if they exist (#646)
add 63e53cc IGNITE-16515 Fix flaky RocksDbSortedIndexStorageTest (#650)
add c4c2636 IGNITE-16207 ExpressionFactoryImpl#SCALAR_CACHE usage fix (#649)
add bd0333d IGNITE-16406 Added additional check for scans. Fixes #597
add f35d063 IGNITE-14871 Add cluster initialization commands to the Ignite CLI (#647)
add 0cf58f5 IGNITE-16522 Fix usage of the JDK Marshaller in raft group listeners (#653)
add a6aa54b IGNITE-16502 fixed deadlock caused by query plan cache (#652)
add 25e46c8 IGNITE-15913 Merge SQL calcite running query registry to 3.0 (#648)
add 6dfbbfe IGNITE-16527 Reduced byte arrays allocation in usages of SearchRow interface. (#654)
add 18d663d IGNITE-14916 RuntimeHashIndex scan must filter result by predicate (#661)
add 8128656 IGNITE-16546 Introduce root.dir property for better maven plugins behaviour (#665)
add e545eee IGNITE-16552 Get rid of outdated hamcrest-core dependency (#663)
add 817995d IGNITE-16566 Use Mockito BOM in pom.xml (#668)
add 66108f5 IGNITE-16567 Remove GSON dependency (#669)
add fc01ecc IGNITE-14269 Added multi-invoke feature for meta storage. Fixes #619
add 86c8675 IGNITE-16577 MultiInvokeCommand extends WriteCommand. Fixes #673
add f8d3118 IGNITE-16275 B+Tree ported from Ignite 2.x master (#657)
add 2cc992d IGNITE-15948 Basic class structure change handling (#670)
add 12e1c38 IGNITE-16584 Fix metastorage cursor wrong order (#675)
add 3eb87bf IGNITE-16201 JDBC: Batch execution (#639)
add 0a7aa64 IGNITE-16474 Forbid nullable key columns (#676)
add 3592f0e IGNITE-16547 MERGE operation support. (#662)
add 6e0aff3 IGNITE-15157 ITCliServiceTest.testAddPeerRemovePeer is flaky (#612)
add f1a932f IGNITE-16482 Adoption of a bunch of tickets from Ignite-2 (#635)
add 3288848 IGNITE-16268 JDBC. Validation of statement type should be done before its execution (#613)
add 87665a2 IGNITE-16451 Optimized ArrayUtils#remove (#681)
add 151c9b6 IGNITE-16554 Add table name to serialized form (#687)
add 0d40c99 IGNITE-16091 ItCliServiceTest.testChangePeers is flaky (#686)
add 2c3fcb2 IGNITE-16486 Adoption of a bunch of tickets from Ignite-2 - Fixes #637.
add 676adb3 IGNITE-16555 remove SqlExtension (#688)
add 1881726 IGNITE-16558 Sql schema synchronization (#692)
add be5fb0e IGNITE-16534 Make BplusMetaIo abstract (#685)
add e57c629 IGNITE-16453 Use LongArrayList instead of IgniteLongList (#684)
add 293d8a9 IGNITE-16545 Subscription to revision update in the test configuration framework (#694)
add c6731c3 IGNITE-15244 testLearnerServices is still flaky (#696)
add f83ae45 IGNITE-16560 [Native Persistence 3.0] PageMemoryImpl porting (#667)
add bac4a46 IGNITE-16368 Implement a futures for causality tokens
add 6808248 IGNITE-16366 Add causality tokens for notifications
add 91a531f IGNITE-16377 Notification listeners of TableManager should rely on causality tokens when referring to dependee components
add 4ce4ef3 IGNITE-16390 Improvements of event listeners for SqlQueryProcessor
add d719fed Merge branch 'main' into ignite-16115
No new revisions were added by this update.
Summary of changes:
DEVNOTES.md | 20 +
.../CheckPropertiesNotInParent.sh | 13 +-
.../CheckUnusedDependenciesAndPluginsInParent.sh | 1 +
check-rules/modernizer-rules.xml | 49 +
examples/pom.xml | 4 +
.../apache/ignite/example/ExampleTestUtils.java | 3 +-
.../affinity/RendezvousAffinityFunctionTest.java | 2 +-
.../org/apache/ignite/tx/IgniteTransactions.java | 35 +-
.../java/org/apache/ignite/tx/Transaction.java | 2 +-
.../expression/TestArrayBytecodeExpressions.java | 27 +-
modules/cli/pom.xml | 12 +
.../org/apache/ignite/cli/ItConfigCommandTest.java | 50 +-
.../cli/builtins/cluster/ClusterApiClient.java | 111 +
.../cli/builtins/cluster/InitClusterRequest.java} | 30 +-
.../cli/builtins/config/ConfigurationClient.java | 10 +-
.../cli/builtins/init/InitIgniteCommand.java | 4 +-
.../ignite/cli/builtins/node/NodeManager.java | 4 +-
.../apache/ignite/cli/spec/ClusterCommandSpec.java | 87 +
.../apache/ignite/cli/spec/ConfigCommandSpec.java | 63 +-
.../org/apache/ignite/cli/spec/IgniteCliSpec.java | 1 +
.../ignite/cli/spec/NodeEndpointOptions.java | 80 +
.../apache/ignite/cli/IgniteCliInterfaceTest.java | 434 +-
.../org/apache/ignite/cli/ui/ProgressBarTest.java | 7 +-
.../java/org/apache/ignite/cli/ui/SpinnerTest.java | 11 +-
.../client/proto/query/JdbcQueryEventHandler.java | 9 +
.../client/proto/query/JdbcStatementType.java | 45 +-
.../proto/query/event/BatchExecuteRequest.java | 32 +-
.../proto/query/event/BatchExecuteResult.java | 41 +-
...Request.java => BatchPreparedStmntRequest.java} | 61 +-
.../ignite/client/proto/query/event/Query.java | 98 -
.../proto/query/event/QueryExecuteRequest.java | 32 +-
.../ignite/internal/client/proto/ClientOp.java | 3 +
modules/client-handler/pom.xml | 5 -
.../handler/ClientInboundMessageHandler.java | 4 +
.../client/handler/JdbcQueryEventHandlerImpl.java | 94 +-
.../sql/ClientSqlPreparedStmntBatchRequest.java | 49 +
.../client/query/JdbcClientQueryEventHandler.java | 11 +
.../internal/jdbc/JdbcPreparedStatement.java | 86 +-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 4 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 48 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 6 +
.../ignite/client/fakes/FakeSchemaRegistry.java | 5 +
.../configuration/ConfigurationListenerHolder.java | 8 +-
.../configuration/ConfigurationRegistry.java | 22 +-
...onfigurationStorageRevisionListenerHolder.java} | 35 +-
.../testframework/ConfigurationExtension.java | 170 +-
.../testframework/ConfigurationExtensionTest.java | 67 +-
.../InjectRevisionListenerHolder.java} | 16 +-
.../internal/causality/OutdatedTokenException.java | 43 +
.../ignite/internal/causality/VersionedValue.java | 369 ++
.../ignite/internal/manager/EventParameters.java | 24 +-
.../apache/ignite/internal/util/ArrayUtils.java | 72 +-
.../ignite/internal/util/CollectionUtils.java | 15 +
.../ignite/internal/util/IgniteLongList.java | 568 --
.../ignite/internal/util/IgniteStripedLock.java | 143 +
.../apache/ignite/internal/util/IgniteUtils.java | 17 +
.../internal/util/io/IgniteUnsafeDataInput.java | 2 +-
.../internal/util/io/IgniteUnsafeDataOutput.java | 2 +-
.../java/org/apache/ignite/lang/IgniteTuple3.java | 234 +
.../internal/causality/VersionedValueTest.java | 245 +
.../internal/testframework/IgniteTestUtils.java | 73 +-
.../ignite/internal/util/ArrayUtilsSelfTest.java | 87 +
.../internal/util/IgniteLongListSelfTest.java | 174 -
.../apache/ignite/internal/util/IgniteRandom.java} | 39 +-
.../ignite/internal/util/IgniteRandomSelfTest.java | 53 +
.../internal/util/IgniteStripedLockSelfTest.java | 197 +
.../org/apache/ignite/lang/LoggerHelperTest.java | 8 +-
modules/metastorage-client/pom.xml | 6 +
.../client/ItMetaStorageServiceTest.java | 193 +-
.../metastorage/client/CompoundCondition.java | 99 +
.../internal/metastorage/client/Condition.java | 361 +-
.../internal/metastorage/client/Conditions.java | 26 +-
.../ignite/internal/metastorage/client/If.java | 154 +
.../metastorage/client/MetaStorageService.java | 14 +-
.../metastorage/client/MetaStorageServiceImpl.java | 67 +-
.../internal/metastorage/client/Operations.java | 65 +-
.../{Condition.java => SimpleCondition.java} | 50 +-
.../internal/metastorage/client/Statement.java | 83 +
.../metastorage/client/StatementResult.java | 109 +
.../internal/metastorage/client/Update.java} | 51 +-
.../internal/metastorage/common/StatementInfo.java | 86 +
.../metastorage/common/StatementResultInfo.java} | 36 +-
.../internal/metastorage/common/UpdateInfo.java | 63 +
.../common/command/CompoundConditionInfo.java | 73 +
.../common/command/CompoundConditionType.java} | 12 +-
.../metastorage/common/command/ConditionInfo.java | 70 +-
.../metastorage/common/command/IfInfo.java | 76 +
.../common/command/MultiInvokeCommand.java} | 37 +-
...ConditionInfo.java => SimpleConditionInfo.java} | 7 +-
modules/metastorage-server/pom.xml | 6 +
.../server/AbstractCompoundCondition.java | 97 +
...Condition.java => AbstractSimpleCondition.java} | 31 +-
.../internal/metastorage/server/AndCondition.java} | 34 +-
.../internal/metastorage/server/Condition.java | 16 +-
.../metastorage/server/ExistenceCondition.java | 2 +-
.../ignite/internal/metastorage/server/If.java | 74 +
.../metastorage/server/KeyValueStorage.java | 13 +-
.../internal/metastorage/server/OrCondition.java} | 34 +-
.../metastorage/server/RevisionCondition.java | 2 +-
.../internal/metastorage/server/Statement.java | 84 +
.../metastorage/server/StatementResult.java | 65 +
.../metastorage/server/TombstoneCondition.java | 2 +-
.../server/{Condition.java => Update.java} | 43 +-
.../ignite/internal/metastorage/server/Value.java | 2 +-
.../metastorage/server/ValueCondition.java | 2 +-
.../server/persistence/RocksDbKeyValueStorage.java | 74 +-
.../server/persistence/RocksStorageUtils.java | 16 +-
.../server/persistence/WatchCursor.java | 226 +-
.../server/raft/MetaStorageListener.java | 186 +-
.../server/AbstractKeyValueStorageTest.java | 346 +-
.../metastorage/server/AndConditionTest.java | 109 +
.../metastorage/server/OrConditionTest.java | 109 +
.../server/SimpleInMemoryKeyValueStorage.java | 56 +-
.../internal/metastorage/MetaStorageManager.java | 31 +-
modules/network/pom.xml | 6 +
.../stream/DirectByteBufferStreamImplV1.java | 5 +-
.../network/message/ClassDescriptorMessage.java | 63 +-
.../network/message/FieldDescriptorMessage.java | 8 +-
.../network/serialization/BrokenFieldAccessor.java | 145 +
.../network/serialization/BuiltInType.java | 49 +-
.../network/serialization/ClassDescriptor.java | 258 +-
.../serialization/ClassDescriptorFactory.java | 42 +-
.../serialization/ClassDescriptorMerger.java | 72 +
.../serialization/ClassDescriptorRegistry.java | 6 +-
.../network/serialization/DeclaredType.java} | 26 +-
.../network/serialization/FieldAccessor.java | 40 +
.../network/serialization/FieldDescriptor.java | 149 +-
.../network/serialization/MergedField.java | 139 +
.../PerSessionSerializationService.java | 207 +-
.../serialization/SerializationService.java | 27 +-
.../SpecialSerializationMethodsImpl.java | 16 +-
.../network/serialization/UnsafeFieldAccessor.java | 18 +-
.../marshal/BuiltInContainerMarshallers.java | 65 +-
.../marshal/BuiltInNonContainerMarshallers.java | 159 +-
.../marshal/DefaultSchemaMismatchHandler.java} | 8 +-
.../marshal/DefaultUserObjectMarshaller.java | 131 +-
...nmarshalException.java => DescribedObject.java} | 19 +-
.../serialization/marshal/DescriptorResolver.java | 59 -
.../marshal/ExternalizableMarshaller.java | 4 +-
.../serialization/marshal/LocalDescriptors.java | 41 +-
.../marshal/MarshallingValidations.java | 2 +-
...ception.java => SchemaMismatchEventSource.java} | 23 +-
...Exception.java => SchemaMismatchException.java} | 15 +-
.../marshal/SchemaMismatchHandler.java | 70 +
.../marshal/SchemaMismatchHandlers.java | 55 +
.../marshal/StructuredObjectMarshaller.java | 177 +-
.../serialization/marshal/TypedValueReader.java | 6 +-
.../serialization/marshal/TypedValueWriter.java | 6 +-
.../serialization/marshal/UnmarshalException.java | 4 +-
.../marshal/UnmarshallingContext.java | 14 -
.../marshal/UosObjectInputStream.java | 24 +-
.../marshal/UosObjectOutputStream.java | 12 +-
.../network/serialization/BuiltInTypeTest.java} | 18 +-
.../serialization/ClassDescriptorFactoryTest.java | 23 +-
.../serialization/ClassDescriptorMergerTest.java | 146 +
.../marshal/DefaultSchemaMismatchHandlerTest.java} | 27 +-
...efaultUserObjectMarshallerWithBuiltinsTest.java | 6 +-
...ltUserObjectMarshallerWithSchemaChangeTest.java | 283 +
...shallerWithSerializableOverrideStreamsTest.java | 5 +-
.../persistence/ItBplusTreePageMemoryImplTest.java | 71 +
.../ItBplusTreeReuseListPageMemoryImplTest.java | 70 +
.../tree/ItBplusTreeFakeReuseSelfTest.java | 79 +
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 481 ++
.../pagememory/tree/ItBplusTreeReuseSelfTest.java | 158 +
.../pagememory/tree/ItBplusTreeSelfTest.java | 3070 ++++++++++
.../internal/pagememory/PageIdAllocator.java | 5 +
.../pagememory/freelist/AbstractFreeList.java | 2 +-
.../internal/pagememory/freelist/PagesList.java | 46 +-
.../pagememory/freelist/io/PagesListMetaIo.java | 12 +-
.../persistence/ClockPageReplacementFlags.java | 158 +
.../persistence/ClockPageReplacementPolicy.java | 102 +
.../ClockPageReplacementPolicyFactory.java} | 27 +-
.../pagememory/persistence/GroupPartitionId.java | 114 +
.../pagememory/persistence/LoadedPagesMap.java | 137 +
.../pagememory/persistence/PageHeader.java | 298 +
.../pagememory/persistence/PageMemoryEx.java | 119 +
.../pagememory/persistence/PageMemoryImpl.java | 1601 +++++
.../internal/pagememory/persistence/PagePool.java | 277 +
.../persistence/PageReadWriteManager.java | 59 +
.../persistence/PageReplacementPolicy.java | 78 +
.../persistence/PageReplacementPolicyFactory.java} | 23 +-
.../RandomLruPageReplacementPolicy.java | 242 +
.../RandomLruPageReplacementPolicyFactory.java} | 27 +-
.../pagememory/persistence/ReplaceCandidate.java | 79 +
.../persistence/RobinHoodBackwardShiftHashMap.java | 700 +++
.../persistence/SegmentedLruPageList.java | 365 ++
.../SegmentedLruPageReplacementPolicy.java | 111 +
.../SegmentedLruPageReplacementPolicyFactory.java} | 27 +-
.../pagememory/reuse/LongListReuseBag.java | 31 +-
.../internal/pagememory/reuse/ReuseListImpl.java | 156 +
.../ignite/internal/pagememory/tree/BplusTree.java | 6433 ++++++++++++++++++++
.../pagememory/tree/BplusTreeRuntimeException.java | 65 +
.../pagememory/tree/CorruptedTreeException.java | 120 +
.../internal/pagememory/tree/IgniteTree.java | 145 +
.../pagememory/tree/IgniteTreePrinter.java | 96 +
.../internal/pagememory/tree/io/BplusInnerIo.java | 216 +
.../internal/pagememory/tree/io/BplusIo.java | 538 ++
.../internal/pagememory/tree/io/BplusLeafIo.java | 66 +
.../internal/pagememory/tree/io/BplusMetaIo.java | 185 +
.../pagememory/impl/PageMemoryNoLoadSelfTest.java | 7 +-
.../persistence/PageMemoryImplNoLoadTest.java | 68 +
.../persistence/TestPageReadWriteManager.java | 57 +
.../ignite/raft/jraft/core/ItCliServiceTest.java | 14 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 66 +-
.../raft/server/ItJraftCounterServerTest.java | 2 -
.../internal/raft/server/impl/JraftServerImpl.java | 3 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 2 +-
.../raft/jraft/storage/impl/RocksDBLogStorage.java | 4 +-
.../ignite/raft/jraft/entity/LogEntryTest.java | 7 +-
.../entity/codec/BaseLogEntryCodecFactoryTest.java | 3 +-
.../ignite/raft/jraft/storage/FileServiceTest.java | 13 +-
.../raft/jraft/storage/io/LocalFileReaderTest.java | 5 +-
.../snapshot/local/LocalSnapshotCopierTest.java | 2 +
.../snapshot/local/SnapshotFileReaderTest.java | 3 +-
.../apache/ignite/raft/jraft/test/TestUtils.java | 3 +-
.../raft/jraft/util/AsciiCodecBenchmark.java | 8 +-
.../raft/jraft/util/AsciiStringUtilTest.java | 9 +-
.../ignite/raft/jraft/util/BytesUtilTest.java | 5 +-
.../apache/ignite/raft/jraft/util/CrcUtilTest.java | 3 +-
.../apache/ignite/raft/jraft/util/UtilsTest.java | 3 +-
modules/rest/pom.xml | 17 +-
.../apache/ignite/internal/rest/RestModule.java | 76 +-
.../ignite/internal/rest/netty/RestApiHandler.java | 98 +-
.../internal/rest/netty/RestApiHttpResponse.java | 18 +-
.../internal/rest/netty/RestApiInitializer.java | 2 -
.../presentation/ConfigurationPresentation.java | 4 +-
.../rest/presentation/hocon/HoconPresentation.java | 46 +-
.../internal/rest/routes/RequestHandler.java | 37 +
.../apache/ignite/internal/rest/routes/Route.java | 14 +-
.../apache/ignite/internal/rest/routes/Router.java | 30 +-
.../rest/netty/RestApiHttpResponseTest.java | 3 +-
.../ConfigurationPresentationTest.java | 34 +-
.../ignite/internal/rest/routes/RouteTest.java | 30 +-
.../ignite/internal/runner/app/ItIgnitionTest.java | 2 +-
.../app/jdbc/ItJdbcAbstractStatementSelfTest.java | 8 +
.../runner/app/jdbc/ItJdbcBatchSelfTest.java | 793 +++
.../app/jdbc/ItJdbcComplexDmlDdlSelfTest.java | 10 +-
.../runner/app/jdbc/ItJdbcErrorsSelfTest.java | 11 +-
.../runner/app/jdbc/ItJdbcResultSetSelfTest.java | 10 -
.../app/jdbc/ItJdbcStatementBatchingSelfTest.java | 80 -
.../runner/app/jdbc/ItJdbcStatementSelfTest.java | 28 +-
.../app/jdbc/ItJdbcUpdateStatementSelfTest.java | 109 +-
.../internal/sql/engine/ItCorrelatesTest.java | 61 +
.../internal/sql/engine/ItCreateTableDdlTest.java | 57 +
.../internal/sql/engine/ItDataTypesTest.java | 2 +
.../ignite/internal/sql/engine/ItDmlTest.java | 261 +
.../internal/sql/engine/ItHashSpoolTest.java | 67 +
.../internal/sql/engine/ItMixedQueriesTest.java | 4 +-
.../internal/sql/engine/ItRunningQueriesTest.java | 180 +
.../internal/sql/engine/ItSqlExtensionTest.java | 69 -
.../sql/engine/extension/TestExtension.java | 165 -
.../engine/extension/TestFilterConverterRule.java | 59 -
.../sql/engine/extension/TestPhysFilter.java | 143 -
.../sql/engine/extension/TestPhysTableScan.java | 95 -
.../sql/engine/extension/TestTableImpl.java | 110 -
.../internal/sql/engine/util/QueryChecker.java | 9 +-
...nite.internal.sql.engine.extension.SqlExtension | 1 -
.../org/apache/ignite/internal/app/IgniteImpl.java | 16 +-
.../storage/DistributedConfigurationStorage.java | 8 +-
.../DistributedConfigurationStorageTest.java | 10 +-
.../apache/ignite/internal/schema/BinaryRow.java | 37 +-
.../ignite/internal/schema/ByteBufferRow.java | 4 +-
.../org/apache/ignite/internal/schema/Columns.java | 2 +-
.../ignite/internal/schema/SchemaDescriptor.java | 2 +
.../ignite/internal/schema/SchemaRegistry.java | 1 +
.../builder/TableDefinitionBuilderImpl.java | 16 +
.../marshaller/schema/SchemaSerializerImpl.java | 12 +-
.../schema/registry/SchemaRegistryImpl.java | 5 +
.../schema/registry/UpgradingRowAdapter.java | 4 +-
.../internal/schema/row/ExpandableByteBuf.java | 4 +-
.../org/apache/ignite/internal/schema/row/Row.java | 31 +-
.../ignite/internal/schema/row/RowAssembler.java | 28 +-
.../ignite/internal/schema/row/VarTableFormat.java | 43 +-
.../internal/schema/ExpandableByteBufTest.java | 63 +-
.../schema/RowAssemblerAdvancedSchemaTest.java | 150 +-
.../schema/RowAssemblerSimpleSchemaTest.java | 378 +-
.../org/apache/ignite/internal/schema/RowTest.java | 94 +-
.../SchemaDescriptorConverterTest.java | 4 +-
.../schema/marshaller/KvMarshallerTest.java | 62 +-
.../schema/marshaller/RecordMarshallerTest.java | 4 +-
.../schema/registry/SchemaRegistryImplTest.java | 58 +-
.../schema/registry/UpgradingRowAdapterTest.java | 4 +-
.../schema/testobjects/TestObjectWithAllTypes.java | 16 +-
modules/sql-engine/pom.xml | 15 +
.../src/main/codegen/includes/parserImpls.ftl | 28 +-
.../apache/ignite/internal/sql/engine/Query.java | 170 +
.../ignite/internal/sql/engine/QueryContext.java | 83 +
.../ignite/internal/sql/engine/QueryProcessor.java | 13 +
.../ignite/internal/sql/engine/QueryRegistry.java} | 36 +-
.../internal/sql/engine/QueryRegistryImpl.java | 65 +
.../{QueryProcessor.java => QueryState.java} | 36 +-
.../internal/sql/engine/QueryValidator.java} | 24 +-
.../internal/sql/engine/RemoteFragmentKey.java | 75 +
.../ignite/internal/sql/engine/RootQuery.java | 334 +
.../internal/sql/engine/RunningFragment.java | 76 +
.../ignite/internal/sql/engine/RunningQuery.java} | 18 +-
.../internal/sql/engine/SqlQueryProcessor.java | 267 +-
.../internal/sql/engine/exec/ExchangeService.java | 4 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 47 +-
.../internal/sql/engine/exec/ExecutionContext.java | 36 +-
.../internal/sql/engine/exec/ExecutionService.java | 22 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 571 +-
.../sql/engine/exec/LogicalRelImplementor.java | 22 +-
.../sql/engine/exec/QueryValidationException.java} | 21 +-
.../internal/sql/engine/exec/RuntimeHashIndex.java | 18 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 15 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 10 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 4 +-
.../sql/engine/exec/rel/IndexSpoolNode.java | 4 +-
.../internal/sql/engine/exec/rel/LimitNode.java | 8 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 107 +-
.../internal/sql/engine/exec/rel/Outbox.java | 7 +-
.../sql/engine/exec/rel/TableScanNode.java | 10 +-
.../sql/engine/extension/ExternalConvention.java | 59 -
.../sql/engine/extension/SqlExtension.java | 154 -
.../sql/engine/externalize/RelInputEx.java | 3 +-
.../sql/engine/externalize/RelJsonReader.java | 12 +-
...boxCloseMessage.java => QueryCloseMessage.java} | 16 +-
.../sql/engine/message/SqlQueryMessageGroup.java | 2 +-
.../sql/engine/metadata/IgniteMdCollation.java | 5 +-
.../engine/metadata/IgniteMdCumulativeCost.java | 5 +-
.../engine/metadata/IgniteMdFragmentMapping.java | 16 -
.../sql/engine/metadata/IgniteMdRowCount.java | 14 +-
.../internal/sql/engine/prepare/DdlPlan.java | 5 +
.../internal/sql/engine/prepare/IgnitePlanner.java | 8 +-
.../sql/engine/prepare/IgniteRelShuttle.java | 6 -
.../engine/prepare/IgniteSqlToRelConvertor.java | 167 +
.../sql/engine/prepare/IgniteSqlValidator.java | 8 +-
.../sql/engine/prepare/MappingQueryContext.java | 18 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 13 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 20 +-
.../sql/engine/prepare/PlanningContext.java | 19 +-
.../sql/engine/prepare/PrepareService.java} | 20 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 182 +
.../sql/engine/prepare/QueryPlanCacheImpl.java | 71 +-
.../internal/sql/engine/prepare/Splitter.java | 7 -
.../prepare/ddl/DdlSqlToCommandConverter.java | 65 +-
.../sql/engine/rel/IgniteHashIndexSpool.java | 6 +-
.../internal/sql/engine/rel/IgniteRelVisitor.java | 5 -
.../internal/sql/engine/rel/IgniteTableModify.java | 6 +-
.../engine/rel/ProjectableFilterableTableScan.java | 10 +-
.../engine/rel/logical/IgniteLogicalIndexScan.java | 6 -
.../sql/engine/rule/FilterConverterRule.java | 18 +-
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 28 +-
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 9 +-
.../sql/engine/rule/LogicalScanConverterRule.java | 31 +-
.../sql/engine/rule/ProjectConverterRule.java | 20 +-
.../sql/engine/rule/SortConverterRule.java | 11 +-
.../sql/engine/rule/UnionConverterRule.java | 8 +-
.../sql/engine/rule/logical/ExposeIndexRule.java | 16 +-
.../engine/rule/logical/FilterScanMergeRule.java | 180 +-
.../engine/rule/logical/LogicalOrToUnionRule.java | 18 +-
.../engine/rule/logical/ProjectScanMergeRule.java | 130 +-
.../logical/RuleFactoryConfig.java} | 26 +-
.../internal/sql/engine/rule/package-info.java} | 13 +-
.../internal/sql/engine/schema/IgniteSchema.java | 14 +-
.../internal/sql/engine/schema/IgniteTable.java | 7 +
.../sql/engine/schema/IgniteTableImpl.java | 124 +-
.../sql/engine/schema/InternalIgniteTable.java | 6 +-
.../{SqlSchemaManager.java => ModifyRow.java} | 44 +-
.../sql/engine/schema/SqlSchemaManager.java | 4 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 287 +-
.../sql/engine/trait/RewindabilityTraitDef.java | 2 +-
.../internal/sql/engine/trait/TraitUtils.java | 17 +-
.../internal/sql/engine/util/BaseQueryContext.java | 50 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 26 -
.../internal/sql/engine/StopCalciteModuleTest.java | 34 +-
.../sql/engine/exec/MockedStructuresTest.java | 74 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 77 +
.../sql/engine/exec/rel/BaseAggregateTest.java | 2 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 6 +
.../sql/engine/exec/rel/LimitExecutionTest.java | 115 +
.../engine/exec/schema/SqlSchemaManagerTest.java | 264 +
.../sql/engine/externalize/RelJsonReaderTest.java | 7 +-
.../sql/engine/planner/AbstractPlannerTest.java | 22 +-
.../internal/sql/engine/planner/PlannerTest.java | 2 +-
.../planner/ProjectFilterScanMergePlannerTest.java | 240 +
.../engine/planner/SortAggregatePlannerTest.java | 14 +-
.../sql/engine/prepare/QueryPlanCacheSelfTest.java | 77 +
.../apache/ignite/internal/storage/SearchRow.java | 8 +-
.../internal/storage/basic/BinarySearchRow.java | 21 +-
.../{SimpleDataRow.java => DelegatingDataRow.java} | 28 +-
.../internal/storage/basic/SimpleDataRow.java | 11 +-
.../storage/AbstractPartitionStorageTest.java | 4 +-
.../storage/rocksdb/RocksDbPartitionStorage.java | 48 +-
.../storage/rocksdb/index/ByteArraySearchRow.java | 5 +-
.../index/RocksDbSortedIndexStorageTest.java | 8 +-
.../internal/table/distributed/TableManager.java | 409 +-
.../command/scan/ScanRetrieveBatchCommand.java | 12 +-
.../table/distributed/raft/PartitionListener.java | 246 +-
.../distributed/storage/InternalTableImpl.java | 6 +-
.../distributed/storage/VersionedRowStore.java | 4 +-
.../internal/table/event/TableEventParameters.java | 16 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 3 +-
.../internal/table/MutableRowTupleAdapterTest.java | 4 +-
.../ignite/internal/table/TableManagerTest.java | 33 +-
.../table/impl/DummySchemaManagerImpl.java | 2 +-
parent/pom.xml | 125 +-
pom.xml | 6 +-
399 files changed, 30539 insertions(+), 6684 deletions(-)
create mode 100644 check-rules/modernizer-rules.xml
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/builtins/cluster/ClusterApiClient.java
copy modules/{client/src/test/java/org/apache/ignite/client/fakes/FakeIgniteQueryProcessor.java => cli/src/main/java/org/apache/ignite/cli/builtins/cluster/InitClusterRequest.java} (59%)
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/spec/ClusterCommandSpec.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/spec/NodeEndpointOptions.java
copy modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/{BatchExecuteRequest.java => BatchPreparedStmntRequest.java} (64%)
delete mode 100644 modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/Query.java
create mode 100644 modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlPreparedStmntBatchRequest.java
copy modules/{api/src/main/java/org/apache/ignite/tx/Transaction.java => configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationStorageRevisionListenerHolder.java} (52%)
copy modules/{core/src/main/java/org/apache/ignite/internal/manager/EventParameters.java => configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/InjectRevisionListenerHolder.java} (55%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/causality/OutdatedTokenException.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/causality/VersionedValue.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteLongList.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteStripedLock.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/lang/IgniteTuple3.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/causality/VersionedValueTest.java
delete mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteLongListSelfTest.java
copy modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/reuse/LongListReuseBag.java => core/src/test/java/org/apache/ignite/internal/util/IgniteRandom.java} (56%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteRandomSelfTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteStripedLockSelfTest.java
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/CompoundCondition.java
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/If.java
copy modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/{Condition.java => SimpleCondition.java} (90%)
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/Statement.java
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/StatementResult.java
copy modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/basic/BinarySearchRow.java => metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/Update.java} (51%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/StatementInfo.java
copy modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/ByteArraySearchRow.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/StatementResultInfo.java} (57%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/UpdateInfo.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/CompoundConditionInfo.java
copy modules/{core/src/main/java/org/apache/ignite/internal/manager/EventParameters.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/CompoundConditionType.java} (72%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/IfInfo.java
copy modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/ByteArraySearchRow.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/MultiInvokeCommand.java} (57%)
copy modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/{ConditionInfo.java => SimpleConditionInfo.java} (89%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCompoundCondition.java
rename modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/{AbstractCondition.java => AbstractSimpleCondition.java} (62%)
copy modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/ByteArraySearchRow.java => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AndCondition.java} (58%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/If.java
copy modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/ByteArraySearchRow.java => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/OrCondition.java} (58%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Statement.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/StatementResult.java
copy modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/{Condition.java => Update.java} (51%)
create mode 100644 modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/AndConditionTest.java
create mode 100644 modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/OrConditionTest.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/BrokenFieldAccessor.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/ClassDescriptorMerger.java
copy modules/{metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Condition.java => network/src/main/java/org/apache/ignite/internal/network/serialization/DeclaredType.java} (53%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/MergedField.java
copy modules/{core/src/main/java/org/apache/ignite/internal/manager/EventParameters.java => network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/DefaultSchemaMismatchHandler.java} (78%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{UnmarshalException.java => DescribedObject.java} (70%)
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/DescriptorResolver.java
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{UnmarshalException.java => SchemaMismatchEventSource.java} (57%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{UnmarshalException.java => SchemaMismatchException.java} (72%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/SchemaMismatchHandler.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/SchemaMismatchHandlers.java
copy modules/{core/src/main/java/org/apache/ignite/internal/manager/EventParameters.java => network/src/test/java/org/apache/ignite/internal/network/serialization/BuiltInTypeTest.java} (67%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/ClassDescriptorMergerTest.java
copy modules/network/src/{main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java => test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultSchemaMismatchHandlerTest.java} (54%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerWithSchemaChangeTest.java
create mode 100644 modules/page-memory/src/integrationTest/java/org/apache/ignite/internal/pagememory/persistence/ItBplusTreePageMemoryImplTest.java
create mode 100644 modules/page-memory/src/integrationTest/java/org/apache/ignite/internal/pagememory/persistence/ItBplusTreeReuseListPageMemoryImplTest.java
create mode 100644 modules/page-memory/src/integrationTest/java/org/apache/ignite/internal/pagememory/tree/ItBplusTreeFakeReuseSelfTest.java
create mode 100644 modules/page-memory/src/integrationTest/java/org/apache/ignite/internal/pagememory/tree/ItBplusTreeReplaceRemoveRaceTest.java
create mode 100644 modules/page-memory/src/integrationTest/java/org/apache/ignite/internal/pagememory/tree/ItBplusTreeReuseSelfTest.java
create mode 100644 modules/page-memory/src/integrationTest/java/org/apache/ignite/internal/pagememory/tree/ItBplusTreeSelfTest.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/ClockPageReplacementFlags.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/ClockPageReplacementPolicy.java
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/DdlPlan.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/ClockPageReplacementPolicyFactory.java} (63%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/GroupPartitionId.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/LoadedPagesMap.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageHeader.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageMemoryEx.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageMemoryImpl.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PagePool.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageReadWriteManager.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageReplacementPolicy.java
copy modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/SearchRow.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageReplacementPolicyFactory.java} (58%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/RandomLruPageReplacementPolicy.java
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/DdlPlan.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/RandomLruPageReplacementPolicyFactory.java} (63%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/ReplaceCandidate.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/RobinHoodBackwardShiftHashMap.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/SegmentedLruPageList.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/SegmentedLruPageReplacementPolicy.java
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/DdlPlan.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/SegmentedLruPageReplacementPolicyFactory.java} (63%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/reuse/ReuseListImpl.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/BplusTree.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/BplusTreeRuntimeException.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/CorruptedTreeException.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/IgniteTree.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/IgniteTreePrinter.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/io/BplusInnerIo.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/io/BplusIo.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/io/BplusLeafIo.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/io/BplusMetaIo.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/PageMemoryImplNoLoadTest.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/TestPageReadWriteManager.java
create mode 100644 modules/rest/src/main/java/org/apache/ignite/internal/rest/routes/RequestHandler.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcBatchSelfTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcStatementBatchingSelfTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItCorrelatesTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItCreateTableDdlTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItDmlTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItHashSpoolTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItRunningQueriesTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlExtensionTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestExtension.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestFilterConverterRule.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestPhysFilter.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestPhysTableScan.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestTableImpl.java
delete mode 100644 modules/runner/src/integrationTest/resources/META-INF/services/org.apache.ignite.internal.sql.engine.extension.SqlExtension
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/Query.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryContext.java
copy modules/{api/src/main/java/org/apache/ignite/tx/Transaction.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryRegistry.java} (50%)
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryRegistryImpl.java
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{QueryProcessor.java => QueryState.java} (57%)
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryValidator.java} (61%)
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RemoteFragmentKey.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RootQuery.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RunningFragment.java
copy modules/{core/src/main/java/org/apache/ignite/internal/manager/EventParameters.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/RunningQuery.java} (70%)
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/QueryValidationException.java} (60%)
delete mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/extension/ExternalConvention.java
delete mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/extension/SqlExtension.java
rename modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/{OutboxCloseMessage.java => QueryCloseMessage.java} (79%)
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/IgniteSqlToRelConvertor.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PrepareService.java} (66%)
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PrepareServiceImpl.java
rename modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{extension/CatalogUpdateListener.java => rule/logical/RuleFactoryConfig.java} (58%)
copy modules/{core/src/main/java/org/apache/ignite/internal/manager/EventParameters.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/package-info.java} (79%)
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/{SqlSchemaManager.java => ModifyRow.java} (60%)
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/ExpressionFactoryImplTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/LimitExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/schema/SqlSchemaManagerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/ProjectFilterScanMergePlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/prepare/QueryPlanCacheSelfTest.java
copy modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/{SimpleDataRow.java => DelegatingDataRow.java} (74%)