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/02/04 15:13:19 UTC
[ignite-3] branch ignite-15212 updated (a570113 -> b297650)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15212
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from a570113 Fix compilation.
add de98821 IGNITE-16364 Sql. Adopt IGNITE-14991, IGNITE-15235, IGNITE-15526 - Fixes #581.
add a71adbd IGNITE-16311 Removed redundant mentions of closed tasks in code. (#561)
add bd86528 IGNITE-15945 Class inheritance and effectively final fields
add 74649e9 IGNITE-16408 Tests fail when building under specific locales (#595)
add 789df33 IGNITE-16404 Enable Unsafe for netty
add da9251d IGNITE-16357 Add documentation for DB names format used by API calls (#596)
add c99f7a8 IGNITE-16419 Split startup parameters (#598)
add 3b7af82 IGNITE-16392 PageMemory data regions configuration; porting of PageMemoryNoStoreImpl and all other necessary components. (#591)
add da1ce16 IGNITE-16235 Races between query execution and table creation - Fixes #542.
add d9f30cf IGNITE-16361 Implemented predictable "nested" listener behavior in configuration notifications (#589)
add 34d7af9 IGNITE-16341 .NET: Emit efficient user object serialization code (#599)
add 59eed92 IGNITE-16425 Improved check of table existence. (#603)
add 4bca20b IGNITE-16411 Fix NPE on JdbcDatabaseMetadata.getColumns - Fixes #604.
add 1eec6f7 IGNITE-16420 Fix testDefaultAsyncContinuationExecutorIsForkJoinPool flakiness (#614)
add 58ac13b IGNITE-16389 Fix unstable test testStopQueryOnNodeStop - Fixes #601.
add 40905cf IGNITE-14698 Improved configuration values serialization. (#605)
add 9aed461 IGNITE-16433 Disabled some tests regard to local state recovery. Fixes #610
add 1b3fdab IGNITE-16269 Added max rows support to JDBC cursor. (#592)
add 3ad271c IGNITE-16328 Sql Adopt IGNITE-15992, IGNITE-16138 - Fixes #565.
add 0cef02c IGNITE-16349 Sql. Check for potential NPE after IGNITE-15462 - Fixes #585.
add f854f55 IGNITE-16347 Sql. Support for function TYPEOF. Incorrect plan provided for queries with correlated subquery in project list. - Fixes #579.
add d450e19 IGNITE-16340 Sql. Request with ORDER BY plans infinitely
add 58b7b08 IGNITE-16345 Fix unstable KeyValueViewOperationsSimpleSchemaTest.putGetAllTypes (#609)
add c44f97b IGNITE-16434 @InternalId integration for table id, optimized direct proxy usage for tables (#611)
add f5025d1 IGNITE-15814 FreeList and corresponding classes ported from Ignite 2.x (#602)
add 8931db5 "IGNITE-15473 Moved rest into internal package. Fixes #621
add c4d3d82 IGNITE-16469: Fix mentions for SQL resolved tickets (#627)
add e179bdc IGNITE-16427 Added indentations and fixes to codeblocks in aplha-4 docs. Fixes #615
add 634cf1a IGNITE-16456 Fixed the markup on a WARNING in docs. Fixes #622
add 4660f13 IGNITE-16467 Muted testInstallLargeSnapshotWithThrottle
add fa1d644 IGNITE-16457 Fixed JDBC driver name in docs. Fixes #623
add 5c96ffd IGNITE-16461 Thin client: Remove TODOs for completed tickets, enable/add tests (#628)
add 6391959 IGNITE-16458 Updated the IP address in the example. Fixes #624
add 14a2fee IGNITE-16473 Removed TODOs for completed tickets. Fixes #629
add 971b1d6 IGNITE-16476 Deal with all "TODO" on resolved tickets (IGNITE-14645, IGNITE-15409) (#630)
add 6f171d6 IGNITE-16260 User object serialization performance optimization
add 916a007 IGNITE-16450 Fix the build on Java 17
add a669236 Merge branch 'main' into ignite-15212
add b297650 Typos.
No new revisions were added by this update.
Summary of changes:
docs/_docs/quick-start/getting-started-guide.adoc | 5 +-
docs/_docs/sql/jdbc-driver.adoc | 4 +-
docs/_docs/table-views.adoc | 46 +-
.../transactions/performing-transactions.adoc | 23 +-
.../CoreDistributedConfigurationModule.java | 8 +-
.../store/DataRegionConfigurationSchema.java | 46 +-
.../store/DataStorageConfigurationSchema.java | 2 +
.../store/MemoryAllocatorConfigurationSchema.java} | 16 +-
.../PageMemoryDataRegionConfigurationSchema.java | 95 +
...a => RocksDbDataRegionConfigurationSchema.java} | 19 +-
.../UnsafeMemoryAllocatorConfigurationSchema.java} | 14 +-
.../ignite/schema/definition/ColumnDefinition.java | 2 +-
.../org/apache/ignite/sql/async/AsyncSession.java | 12 +-
.../ignite/sql/reactive/ReactiveSession.java | 8 +-
.../ignite/cli/builtins/node/NodeManager.java | 15 +
.../proto/query/event/BatchExecuteRequest.java | 8 +-
.../proto/query/event/JdbcMetaColumnsRequest.java | 12 +-
.../ignite/client/proto/query/event/Query.java | 16 +-
.../internal/client/proto/ClientMessagePacker.java | 27 -
.../client/proto/ClientMessageUnpacker.java | 21 -
.../internal/client/proto/ClientMsgPackType.java | 3 -
.../client/proto/ClientMessageUnpackerTest.java | 13 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 9 +-
.../handler/requests/sql/JdbcQueryCursor.java | 108 +
.../handler/requests/table/ClientTableCommon.java | 3 +-
.../requests/table/ClientTableGetRequest.java | 2 +-
.../requests/table/ClientTablesGetRequest.java | 2 +-
.../client/table/ClientKeyValueBinaryView.java | 2 -
.../internal/client/table/ClientKeyValueView.java | 2 +-
.../client/table/ClientRecordBinaryView.java | 3 +-
.../client/table/ClientRecordSerializer.java | 12 +-
.../ignite/internal/client/table/ClientSchema.java | 1 -
.../ignite/internal/client/table/ClientTable.java | 10 +-
.../ignite/internal/client/table/ClientTables.java | 4 +-
.../client/table/ClientTupleSerializer.java | 14 +-
.../ignite/internal/jdbc/JdbcConnection.java | 22 +-
.../marshaller/ClientMarshallerWriter.java | 3 +-
.../ignite/client/AbstractClientTableTest.java | 7 +
.../ignite/client/ClientKeyValueViewTest.java | 57 +-
.../apache/ignite/client/ClientRecordViewTest.java | 59 +-
.../org/apache/ignite/client/ClientTableTest.java | 17 +-
.../apache/ignite/client/ConfigurationTest.java | 4 +-
.../org/apache/ignite/client/ConnectionTest.java | 9 +-
.../ignite/client/fakes/FakeIgniteTables.java | 11 +-
.../ignite/client/fakes/FakeInternalTable.java | 8 +-
.../configuration/ConfigurationProperty.java | 9 +-
.../configuration/NamedConfigurationTree.java | 12 +-
.../configuration/ConfigurationChanger.java | 29 +-
.../configuration/ConfigurationListenerHolder.java | 129 ++
.../internal/configuration/ConfigurationNode.java | 21 +-
.../configuration/ConfigurationRegistry.java | 49 +-
.../configuration/DynamicConfiguration.java | 7 +-
.../configuration/DynamicConfigurationChanger.java | 9 +-
.../configuration/NamedListConfiguration.java | 29 +-
.../ConfigurationNotificationContext.java | 9 +-
.../ConfigurationNotificationUtils.java | 46 +-
.../notifications/ConfigurationNotifier.java | 186 +-
.../internal/configuration/tree/InnerNode.java | 9 -
.../internal/configuration/tree/NamedListNode.java | 19 +-
.../util/ConfigurationSerializationUtil.java | 426 ++++
.../ConfigurationListenerHolderTest.java | 122 ++
.../configuration/ConfigurationTestUtils.java} | 16 +-
.../configuration/TestConfigurationChanger.java | 2 +-
.../notifications/ConfigurationListenerTest.java | 82 +-
.../testframework/ConfigurationExtension.java | 15 +-
.../util/ConfigurationSerializationUtilTest.java | 87 +
.../apache/ignite/internal/util/ArrayUtils.java | 258 +--
.../ignite/internal/util/CollectionUtils.java | 113 +-
.../ignite/internal/util/FastTimestamps.java | 65 +
.../apache/ignite/internal/util/GridUnsafe.java | 26 +-
.../apache/ignite/internal/util/IgniteCursor.java | 67 +
.../ignite/internal/util/IgniteLongList.java | 568 +++++
.../apache/ignite/internal/util/IgniteUtils.java | 30 +
.../ignite/internal/util/OffheapReadWriteLock.java | 697 +++++++
.../ignite/internal/util/StringIntrospection.java | 139 ++
.../ignite/internal/util/io/IgniteDataInput.java | 309 +++
.../ignite/internal/util/io/IgniteDataOutput.java | 138 ++
.../internal/util/io/IgniteUnsafeDataInput.java | 800 ++++++++
.../internal/util/io/IgniteUnsafeDataOutput.java | 702 +++++++
.../apache/ignite/internal/util/io}/VarInts.java | 12 +-
.../internal/testframework/IgniteTestUtils.java | 99 +-
.../ignite/internal/util/ArrayUtilsSelfTest.java | 50 +
.../ignite/internal/util/CollectionUtilsTest.java | 68 +-
.../internal/util/IgniteLongListSelfTest.java | 174 ++
.../util/IgniteOffheapReadWriteLockSelfTest.java | 463 +++++
.../ignite/internal/util/IgniteUtilsTest.java | 24 +
.../internal/util/StringIntrospectionTest.java | 63 +
.../ignite/internal/util/io/IgniteTestIoUtils.java | 148 ++
.../IgniteUnsafeDataInputOutputByteOrderTest.java | 240 +++
.../util/io/IgniteUnsafeDataInputTest.java} | 33 +-
.../io/IgniteUnsafeDataOutputArraySizingTest.java | 123 ++
.../ignite/internal/util/io}/VarIntsTest.java | 2 +-
.../internal/metastorage/MetaStorageManager.java | 12 +-
modules/network/pom.xml | 29 +
.../stream/DirectByteBufferStreamImplV1.java | 2 +-
.../network/serialization/BuiltInType.java | 38 +-
.../network/serialization/BuiltInTypeIds.java | 9 +
.../network/serialization/ClassDescriptor.java | 137 +-
.../serialization/ClassDescriptorRegistry.java | 34 +-
.../serialization/ClassIndexedDescriptors.java | 10 +
.../internal/network/serialization/Classes.java | 50 +
...ptors.java => CompositeDescriptorRegistry.java} | 33 +-
.../network/serialization/DescriptorRegistry.java} | 8 +-
.../network/serialization/FieldDescriptor.java | 11 +
.../serialization/IdIndexedDescriptors.java | 18 +
....java => MapBackedClassIndexedDescriptors.java} | 14 +-
.../MapBackedIdIndexedDescriptors.java | 10 +-
.../PerSessionSerializationService.java | 38 +-
.../serialization/SerializationService.java | 6 +-
.../marshal/BuiltInContainerMarshallers.java | 90 +-
.../serialization/marshal/BuiltInMarshalling.java | 269 ++-
.../marshal/BuiltInNonContainerMarshallers.java | 62 +-
.../marshal/DefaultFieldsReaderWriter.java | 18 +-
.../marshal/DefaultUserObjectMarshaller.java | 338 +--
.../serialization/marshal/DescriptorResolver.java | 59 +
.../marshal/ExternalizableMarshaller.java | 18 +-
.../marshal/{Bits.java => LittleEndianBits.java} | 67 +-
.../serialization/marshal/LocalDescriptors.java | 64 +
.../serialization/marshal/MarshalledObject.java | 28 +-
.../serialization/marshal/MarshallingContext.java | 44 +-
.../marshal/MarshallingValidations.java | 104 +
.../serialization/marshal/ProtocolMarshalling.java | 48 +
.../serialization/marshal/ProxyMarshaller.java | 14 +-
.../marshal/SerializableInstantiation.java | 3 +-
.../marshal/StructuredObjectMarshaller.java | 153 +-
.../{ValueReader.java => TypedValueReader.java} | 15 +-
.../serialization/marshal/TypedValueWriter.java | 13 +-
.../marshal/UnmarshallingContext.java | 55 +-
...ValueWriter.java => UosIgniteOutputStream.java} | 34 +-
.../marshal/UosObjectInputStream.java | 100 +-
.../marshal/UosObjectOutputStream.java | 83 +-
.../marshal/UserObjectMarshaller.java | 16 +-
.../network/serialization/marshal/ValueReader.java | 8 +-
.../network/serialization/marshal/ValueWriter.java | 8 +-
.../ignite/internal/network/AllTypesMessage.java | 3 +-
.../internal/network/AllTypesMessageGenerator.java | 22 +-
.../network/SerializationMicroBenchmark.java | 307 +++
.../ignite/internal/network/UosProfilerTarget.java | 97 +
.../serialization/BuiltInDescriptorsTest.java | 38 +-
.../network/serialization/ClassesTest.java | 124 ++
...a => MapBackedClassIndexedDescriptorsTest.java} | 28 +-
.../MapBackedIdIndexedDescriptorsTest.java | 27 +-
.../network/serialization/MarshallableTest.java | 15 +-
.../DefaultUserObjectMarshallerCommonTest.java | 78 +-
...rConcreteTypesKnownUpfrontOptimizationTest.java | 416 ++++
...erObjectMarshallerWithArbitraryObjectsTest.java | 57 +-
...efaultUserObjectMarshallerWithBuiltinsTest.java | 422 +++-
...UserObjectMarshallerWithExternalizableTest.java | 19 +-
...shallerWithSerializableOverrideStreamsTest.java | 51 +-
...ltUserObjectMarshallerWithSerializableTest.java | 14 +-
.../marshal/ProtocolMarshallingTest.java | 121 ++
.../serialization/marshal/TestDescriptors.java} | 11 +-
modules/page-memory/pom.xml | 31 +
.../CorruptedDataStructureException.java | 63 +
.../internal/pagememory/PageIdAllocator.java | 16 +-
.../ignite/internal/pagememory/PageMemory.java | 15 +-
.../internal/pagememory/PageMemoryIoModule.java} | 28 +-
.../ignite/internal/pagememory/Storable.java | 63 +
.../pagememory/datastructure/DataStructure.java | 470 +++++
.../pagememory/evict/PageEvictionTracker.java | 58 +
.../pagememory/evict/PageEvictionTrackerNoOp.java} | 42 +-
.../pagememory/freelist/AbstractFreeList.java | 924 +++++++++
.../freelist/CorruptedFreeListException.java} | 29 +-
.../internal/pagememory/freelist/FreeList.java | 94 +
.../internal/pagememory/freelist/PagesList.java | 2165 ++++++++++++++++++++
.../pagememory/freelist/io/PagesListMetaIo.java | 234 +++
.../pagememory/freelist/io/PagesListNodeIo.java | 281 +++
.../pagememory/impl/PageMemoryNoStoreImpl.java | 890 ++++++++
.../internal/pagememory/io/AbstractDataPageIo.java | 1514 ++++++++++++++
.../internal/pagememory/io/DataPagePayload.java | 85 +
.../ignite/internal/pagememory/io/IoVersions.java | 20 +-
.../ignite/internal/pagememory/io/PageIo.java | 147 +-
.../internal/pagememory/io/PageIoRegistry.java | 11 +-
.../DirectMemoryProvider.java} | 30 +-
.../pagememory/mem/DirectMemoryRegion.java} | 23 +-
.../mem/IgniteOutOfMemoryException.java} | 44 +-
.../internal/pagememory/mem/MemoryAllocator.java} | 21 +-
.../pagememory/mem/unsafe/UnsafeChunk.java | 73 +
.../mem/unsafe/UnsafeMemoryAllocator.java} | 25 +-
.../mem/unsafe/UnsafeMemoryProvider.java | 140 ++
.../pagememory/metric/IoStatisticsHolder.java | 10 +-
...ticsHolder.java => IoStatisticsHolderNoOp.java} | 49 +-
.../pagememory/reuse/LongListReuseBag.java} | 32 +-
.../internal/pagememory/reuse/ReuseList.java | 3 +-
.../internal/pagememory/util/PageHandler.java | 157 +-
.../internal/pagememory/util/PageIdUtils.java | 1 +
.../internal/pagememory/util/PageLockListener.java | 44 +-
.../pagememory/util/PageLockListenerNoOp.java | 75 +
...ache.ignite.internal.pagememory.io.PageIoModule | 17 +
.../internal/pagememory/TestPageIoModule.java | 12 +-
.../internal/pagememory/TestPageIoRegistry.java | 57 +
.../pagememory/freelist/AbstractFreeListTest.java | 305 +++
.../pagememory/freelist/TestDataPageIo.java | 75 +
.../internal/pagememory/freelist/TestDataRow.java | 78 +
.../pagememory/impl/PageMemoryNoLoadSelfTest.java | 391 ++++
.../dotnet/Apache.Ignite.Benchmarks/Program.cs | 4 +-
.../Serialization/ObjectSerializerHandlerOld.cs} | 27 +-
.../SerializerHandlerBenchmarksBase.cs | 92 +
.../SerializerHandlerReadBenchmarks.cs | 82 +
.../SerializerHandlerWriteBenchmarks.cs | 90 +
.../Table/RecordViewDefaultMappingTest.cs | 100 +
.../Serialization/ObjectSerializerHandlerTests.cs | 154 ++
.../Table/Serialization/ReflectionUtilsTests.cs | 111 +
.../Apache.Ignite.Tests/Table/TablesTests.cs | 12 +
.../Internal/Proto/ClientDataTypeExtensions.cs | 52 +
.../Internal/Proto/ClientMessagePackType.cs | 5 -
.../Apache.Ignite/Internal/Proto/IgniteUuid.cs | 46 -
.../Internal/Proto/MessagePackReaderExtensions.cs | 21 +-
.../Internal/Proto/MessagePackWriterExtensions.cs | 13 -
.../dotnet/Apache.Ignite/Internal/Table/Schema.cs | 4 +-
.../Serialization/IRecordSerializerHandler.cs | 5 +-
.../Table/Serialization/MessagePackMethods.cs | 131 ++
.../Table/Serialization/ObjectSerializerHandler.cs | 238 ++-
.../Table/Serialization/RecordSerializer.cs | 6 +-
.../Table/Serialization/ReflectionUtils.cs | 125 ++
.../Table/Serialization/TupleSerializerHandler.cs | 11 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 20 +-
.../dotnet/Apache.Ignite/Internal/Table/Tables.cs | 13 +-
.../platforms/dotnet/Apache.Ignite/Table/ITable.cs | 3 +
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 1 +
.../ignite/{ => internal}/rest/ErrorResult.java | 2 +-
.../ignite/{ => internal}/rest/RestModule.java | 14 +-
.../{ => internal}/rest/netty/RestApiHandler.java | 4 +-
.../rest/netty/RestApiHttpRequest.java | 2 +-
.../rest/netty/RestApiHttpResponse.java | 2 +-
.../rest/netty/RestApiInitializer.java | 4 +-
.../{ => internal}/rest/netty/package-info.java | 2 +-
.../ignite/{ => internal}/rest/package-info.java | 2 +-
.../presentation/ConfigurationPresentation.java | 2 +-
.../rest/presentation/hocon/HoconPresentation.java | 4 +-
.../rest/presentation/hocon/package-info.java | 2 +-
.../rest/presentation/package-info.java | 2 +-
.../ignite/{ => internal}/rest/routes/Route.java | 6 +-
.../ignite/{ => internal}/rest/routes/Router.java | 6 +-
.../{ => internal}/rest/routes/package-info.java | 2 +-
.../rest/netty/RestApiHttpResponseTest.java | 4 +-
.../ConfigurationPresentationTest.java | 4 +-
.../{ => internal}/rest/routes/RouteTest.java | 2 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 12 +-
.../runner/app/ItIgniteNodeRestartTest.java | 2 +-
.../ignite/internal/runner/app/ItIgnitionTest.java | 2 +-
.../runner/app/ItTableApiContractTest.java | 8 +-
.../internal/runner/app/ItTablesApiTest.java | 4 +-
.../runner/app/jdbc/ItJdbcConnectionSelfTest.java | 4 +-
.../runner/app/jdbc/ItJdbcMetadataSelfTest.java | 84 +-
.../app/jdbc/ItJdbcStatementBatchingSelfTest.java | 80 +
.../runner/app/jdbc/ItJdbcStatementSelfTest.java | 2 -
.../internal/sql/engine/ItDataTypesTest.java | 4 +-
.../internal/sql/engine/ItFunctionsTest.java | 79 +-
.../internal/sql/engine/ItMixedQueriesTest.java | 24 +-
.../internal/sql/engine/ItOrToUnionRuleTest.java | 15 +-
.../internal/sql/engine/ItSortAggregateTest.java | 34 +
.../sql/engine/extension/TestTableImpl.java | 6 +-
.../internal/sql/engine/util/QueryChecker.java | 18 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 2 +-
.../storage/DistributedConfigurationStorage.java | 15 +-
.../storage/LocalConfigurationStorage.java | 8 +-
.../apache/ignite/internal/schema/BinaryRow.java | 3 -
.../internal/schema/row/ExpandableByteBuf.java | 8 +-
.../internal/schema/ExpandableByteBufTest.java | 6 +-
.../org/apache/ignite/internal/schema/RowTest.java | 85 +
.../SchemaConfigurationConverterTest.java | 6 +-
.../configuration/TableValidatorImplTest.java | 29 +-
modules/sql-engine/src/main/codegen/config.fmpp | 2 +-
.../src/main/codegen/includes/parserImpls.ftl | 6 +
.../sql/engine/exec/ExchangeServiceImpl.java | 3 +-
.../internal/sql/engine/exec/ExecutionContext.java | 3 +-
.../sql/engine/exec/QueryTaskExecutorImpl.java | 2 +-
.../internal/sql/engine/exec/exp/RexImpTable.java | 50 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 12 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 56 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 6 +-
.../sql/engine/externalize/RelJsonReader.java | 4 +-
.../sql/engine/metadata/FragmentDescription.java | 8 +-
.../sql/engine/metadata/IgniteMdCollation.java | 10 +-
.../internal/sql/engine/prepare/IgnitePlanner.java | 5 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 2 +
.../sql/engine/prepare/ddl/CreateIndexCommand.java | 2 +-
.../internal/sql/engine/rel/IgniteIndexScan.java | 10 +-
.../internal/sql/engine/rel/IgniteLimit.java | 8 +-
.../internal/sql/engine/rel/IgniteTableScan.java | 12 +-
.../engine/rel/agg/IgniteSortAggregateBase.java | 16 +-
.../engine/rel/logical/IgniteLogicalTableScan.java | 6 +-
.../engine/rule/logical/LogicalOrToUnionRule.java | 157 +-
.../internal/sql/engine/schema/IgniteTable.java | 4 +-
.../sql/engine/schema/IgniteTableImpl.java | 4 +-
.../sql/engine/schema/SqlSchemaManager.java | 5 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 8 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 9 +
.../internal/sql/engine/trait/TraitUtils.java | 10 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 7 +-
...ManagersTest.java => MockedStructuresTest.java} | 62 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 106 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 12 +-
.../sql/engine/exec/rel/ExecutionTest.java | 18 +-
.../exec/rel/HashAggregateExecutionTest.java | 101 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 2 +
.../exec/rel/HashIndexSpoolExecutionTest.java | 2 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 2 +-
.../exec/rel/NestedLoopJoinExecutionTest.java | 2 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 21 +-
.../sql/engine/externalize/RelJsonReaderTest.java | 5 +-
.../sql/engine/planner/AbstractPlannerTest.java | 44 +-
.../planner/CorrelatedSubqueryPlannerTest.java | 80 +
.../internal/sql/engine/planner/PlannerTest.java | 35 +-
.../engine/planner/SortAggregatePlannerTest.java | 41 +
.../sql/engine/planner/TableSpoolPlannerTest.java | 60 -
.../storage/rocksdb/RocksDbDataRegion.java | 16 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 5 +-
.../rocksdb/RocksDbPartitionStorageTest.java | 11 +-
.../storage/rocksdb/RocksDbTableStorageTest.java | 11 +-
.../index/RocksDbSortedIndexStorageTest.java | 12 +-
.../distributed/ItInternalTableScanTest.java | 7 +-
.../ignite/distributed/ItTablePersistenceTest.java | 16 +-
.../distributed/ItTxDistributedTestSingleNode.java | 18 +-
.../schema/ExtendedTableConfigurationSchema.java | 10 +-
.../internal/table/IgniteTablesInternal.java | 6 +-
.../ignite/internal/table/InternalTable.java | 4 +-
.../apache/ignite/internal/table/TableImpl.java | 4 +-
.../internal/table/distributed/TableManager.java | 128 +-
.../table/distributed/raft/PartitionListener.java | 7 +-
.../distributed/storage/InternalTableImpl.java | 29 +-
.../internal/table/event/TableEventParameters.java | 10 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 31 +-
.../internal/table/MutableRowTupleAdapterTest.java | 69 +-
.../table/RecordBinaryViewOperationsTest.java | 4 +-
.../ignite/internal/table/TableManagerTest.java | 9 +-
.../raft/PartitionCommandListenerTest.java | 3 +-
.../table/impl/DummyInternalTableImpl.java | 12 +-
parent/pom.xml | 38 +-
330 files changed, 21167 insertions(+), 2655 deletions(-)
copy modules/{rest/src/main/java/org/apache/ignite/rest/package-info.java => api/src/main/java/org/apache/ignite/configuration/schemas/store/MemoryAllocatorConfigurationSchema.java} (59%)
mode change 100755 => 100644
create mode 100644 modules/api/src/main/java/org/apache/ignite/configuration/schemas/store/PageMemoryDataRegionConfigurationSchema.java
copy modules/api/src/main/java/org/apache/ignite/configuration/schemas/store/{DataRegionConfigurationSchema.java => RocksDbDataRegionConfigurationSchema.java} (79%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/package-info.java => api/src/main/java/org/apache/ignite/configuration/schemas/store/UnsafeMemoryAllocatorConfigurationSchema.java} (58%)
mode change 100755 => 100644
create mode 100644 modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/JdbcQueryCursor.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/ConfigurationListenerHolder.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/util/ConfigurationSerializationUtil.java
create mode 100644 modules/configuration/src/test/java/org/apache/ignite/internal/configuration/ConfigurationListenerHolderTest.java
copy modules/{rest/src/main/java/org/apache/ignite/rest/presentation/hocon/package-info.java => configuration/src/test/java/org/apache/ignite/internal/configuration/ConfigurationTestUtils.java} (62%)
mode change 100755 => 100644
create mode 100644 modules/configuration/src/test/java/org/apache/ignite/internal/configuration/util/ConfigurationSerializationUtilTest.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/FastTimestamps.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteCursor.java
create 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/OffheapReadWriteLock.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/StringIntrospection.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/io/IgniteDataInput.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/io/IgniteDataOutput.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/io/IgniteUnsafeDataInput.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/io/IgniteUnsafeDataOutput.java
rename modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal => core/src/main/java/org/apache/ignite/internal/util/io}/VarInts.java (86%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/ArrayUtilsSelfTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteLongListSelfTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteOffheapReadWriteLockSelfTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/StringIntrospectionTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/io/IgniteTestIoUtils.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/io/IgniteUnsafeDataInputOutputByteOrderTest.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/MapBackedIdIndexedDescriptors.java => core/src/test/java/org/apache/ignite/internal/util/io/IgniteUnsafeDataInputTest.java} (54%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/io/IgniteUnsafeDataOutputArraySizingTest.java
rename modules/{network/src/test/java/org/apache/ignite/internal/network/serialization/marshal => core/src/test/java/org/apache/ignite/internal/util/io}/VarIntsTest.java (98%)
rename modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{CompositeIdIndexedDescriptors.java => CompositeDescriptorRegistry.java} (56%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/presentation/hocon/package-info.java => network/src/main/java/org/apache/ignite/internal/network/serialization/DescriptorRegistry.java} (81%)
mode change 100755 => 100644
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{MapBackedIdIndexedDescriptors.java => MapBackedClassIndexedDescriptors.java} (67%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/DescriptorResolver.java
rename modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{Bits.java => LittleEndianBits.java} (60%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/LocalDescriptors.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/MarshallingValidations.java
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{ValueReader.java => TypedValueReader.java} (64%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{ValueWriter.java => UosIgniteOutputStream.java} (60%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/SerializationMicroBenchmark.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/UosProfilerTarget.java
copy modules/network/src/test/java/org/apache/ignite/internal/network/serialization/{MapBackedIdIndexedDescriptorsTest.java => MapBackedClassIndexedDescriptorsTest.java} (55%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerConcreteTypesKnownUpfrontOptimizationTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/ProtocolMarshallingTest.java
copy modules/{rest/src/main/java/org/apache/ignite/rest/netty/package-info.java => network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/TestDescriptors.java} (81%)
mode change 100755 => 100644
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/CorruptedDataStructureException.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/MapBackedIdIndexedDescriptors.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/PageMemoryIoModule.java} (56%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/Storable.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/datastructure/DataStructure.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/evict/PageEvictionTracker.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/MapBackedIdIndexedDescriptors.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/evict/PageEvictionTrackerNoOp.java} (52%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/freelist/AbstractFreeList.java
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/SqlSchemaManager.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/freelist/CorruptedFreeListException.java} (56%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/freelist/FreeList.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/freelist/PagesList.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/freelist/io/PagesListMetaIo.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/freelist/io/PagesListNodeIo.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/impl/PageMemoryNoStoreImpl.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/io/AbstractDataPageIo.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/io/DataPagePayload.java
copy modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/{metric/IoStatisticsHolder.java => mem/DirectMemoryProvider.java} (57%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/netty/package-info.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/mem/DirectMemoryRegion.java} (60%)
mode change 100755 => 100644
copy modules/{rest/src/main/java/org/apache/ignite/rest/ErrorResult.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/mem/IgniteOutOfMemoryException.java} (50%)
copy modules/{rest/src/main/java/org/apache/ignite/rest/netty/package-info.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/mem/MemoryAllocator.java} (63%)
mode change 100755 => 100644
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/mem/unsafe/UnsafeChunk.java
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/MapBackedIdIndexedDescriptors.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/mem/unsafe/UnsafeMemoryAllocator.java} (59%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/mem/unsafe/UnsafeMemoryProvider.java
copy modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/metric/{IoStatisticsHolder.java => IoStatisticsHolderNoOp.java} (54%)
copy modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/MapBackedIdIndexedDescriptors.java => page-memory/src/main/java/org/apache/ignite/internal/pagememory/reuse/LongListReuseBag.java} (56%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/util/PageLockListenerNoOp.java
create mode 100644 modules/page-memory/src/main/resources/META-INF/services/org.apache.ignite.internal.pagememory.io.PageIoModule
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/TestPageIoRegistry.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/freelist/AbstractFreeListTest.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/freelist/TestDataPageIo.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/freelist/TestDataRow.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/impl/PageMemoryNoLoadSelfTest.java
copy modules/platforms/dotnet/{Apache.Ignite/Internal/Table/Serialization/ObjectSerializerHandler.cs => Apache.Ignite.Benchmarks/Table/Serialization/ObjectSerializerHandlerOld.cs} (83%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Benchmarks/Table/Serialization/SerializerHandlerBenchmarksBase.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Benchmarks/Table/Serialization/SerializerHandlerReadBenchmarks.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Benchmarks/Table/Serialization/SerializerHandlerWriteBenchmarks.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/RecordViewDefaultMappingTest.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/Serialization/ObjectSerializerHandlerTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/Serialization/ReflectionUtilsTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Proto/ClientDataTypeExtensions.cs
delete mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Proto/IgniteUuid.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/MessagePackMethods.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/ReflectionUtils.cs
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/ErrorResult.java (97%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/RestModule.java (95%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/netty/RestApiHandler.java (97%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/netty/RestApiHttpRequest.java (97%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/netty/RestApiHttpResponse.java (98%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/netty/RestApiInitializer.java (94%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/netty/package-info.java (95%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/package-info.java (95%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/presentation/ConfigurationPresentation.java (97%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/presentation/hocon/HoconPresentation.java (96%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/presentation/hocon/package-info.java (93%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/presentation/package-info.java (94%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/routes/Route.java (96%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/routes/Router.java (94%)
rename modules/rest/src/main/java/org/apache/ignite/{ => internal}/rest/routes/package-info.java (94%)
rename modules/rest/src/test/java/org/apache/ignite/{ => internal}/rest/netty/RestApiHttpResponseTest.java (95%)
rename modules/rest/src/test/java/org/apache/ignite/{ => internal}/rest/presentation/ConfigurationPresentationTest.java (98%)
rename modules/rest/src/test/java/org/apache/ignite/{ => internal}/rest/routes/RouteTest.java (98%)
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/ItJdbcStatementBatchingSelfTest.java
rename modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/{DdlWithMockedManagersTest.java => MockedStructuresTest.java} (87%)
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/CorrelatedSubqueryPlannerTest.java