You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ko...@apache.org on 2022/02/25 07:56:09 UTC
[ignite-3] branch ignite-16266 updated (c08a2e7 -> 4a4e4e7)
This is an automated email from the ASF dual-hosted git repository.
korlov pushed a change to branch ignite-16266
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard c08a2e7 WIP.
discard 5b64293 WIP.
discard 9f9202d Merge branch 'main' into ignite-14925-sorted-indexes
omit 99fe791 IGNITE-14830 Introduce sorted index prototype (#518)
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 870fa15 IGNITE-14830 Introduce sorted index prototype (#518)
add 923e598 WIP.
add 4a4e4e7 WIP.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (c08a2e7)
\
N -- N -- N refs/heads/ignite-16266 (4a4e4e7)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../client/proto/query/JdbcQueryEventHandler.java | 9 +
.../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 -
.../ignite/internal/client/proto/ClientOp.java | 3 +
.../handler/ClientInboundMessageHandler.java | 4 +
.../client/handler/JdbcQueryEventHandlerImpl.java | 59 +-
...ava => ClientSqlPreparedStmntBatchRequest.java} | 12 +-
.../client/query/JdbcClientQueryEventHandler.java | 11 +
.../internal/jdbc/JdbcPreparedStatement.java | 76 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 37 +-
.../ignite/client/fakes/FakeSchemaRegistry.java | 5 +
.../apache/ignite/internal/util/ArrayUtils.java | 35 +
.../ignite/internal/util/IgniteStripedLock.java | 143 +
.../internal/util/io/IgniteUnsafeDataInput.java | 2 +-
.../internal/util/io/IgniteUnsafeDataOutput.java | 2 +-
.../java/org/apache/ignite/lang/IgniteTuple3.java | 234 +
.../internal/testframework/IgniteTestUtils.java | 62 +-
.../ignite/internal/util/ArrayUtilsSelfTest.java | 87 +
.../apache/ignite/internal/util/IgniteRandom.java} | 39 +-
.../ignite/internal/util/IgniteRandomSelfTest.java | 53 +
.../internal/util/IgniteStripedLockSelfTest.java | 197 +
.../metastorage/server/KeyValueStorage.java | 2 +-
.../server/persistence/RocksDbKeyValueStorage.java | 2 +-
.../server/persistence/RocksStorageUtils.java | 16 +-
.../server/persistence/WatchCursor.java | 226 +-
.../server/AbstractKeyValueStorageTest.java | 105 +-
.../server/SimpleInMemoryKeyValueStorage.java | 4 +-
modules/network/pom.xml | 6 +
.../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 +-
...rializationException.java => DeclaredType.java} | 25 +-
.../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} | 6 +-
.../marshal/DefaultUserObjectMarshaller.java | 131 +-
...ntiationException.java => DescribedObject.java} | 18 +-
.../serialization/marshal/DescriptorResolver.java | 59 -
.../marshal/ExternalizableMarshaller.java | 4 +-
.../serialization/marshal/LocalDescriptors.java | 41 +-
.../marshal/MarshallingValidations.java | 2 +-
...eReader.java => SchemaMismatchEventSource.java} | 21 +-
...Exception.java => SchemaMismatchException.java} | 9 +-
.../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} | 16 +-
.../serialization/ClassDescriptorFactoryTest.java | 23 +-
.../serialization/ClassDescriptorMergerTest.java | 146 +
.../marshal/DefaultSchemaMismatchHandlerTest.java} | 29 +-
...efaultUserObjectMarshallerWithBuiltinsTest.java | 6 +-
...ltUserObjectMarshallerWithSchemaChangeTest.java | 283 +
...shallerWithSerializableOverrideStreamsTest.java | 2 +-
.../tree/ItBplusTreeFakeReuseSelfTest.java | 79 +
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 467 ++
.../pagememory/tree/ItBplusTreeReuseSelfTest.java | 158 +
.../pagememory/tree/ItBplusTreeSelfTest.java | 3047 ++++++++++
.../internal/pagememory/PageMemoryIoModule.java | 4 +-
.../pagememory/freelist/AbstractFreeList.java | 2 +-
.../internal/pagememory/freelist/PagesList.java | 4 +-
.../internal/pagememory/reuse/ReuseListImpl.java | 156 +
.../ignite/internal/pagememory/tree/BplusTree.java | 6426 ++++++++++++++++++++
.../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 | 186 +
.../runner/app/jdbc/ItJdbcBatchSelfTest.java | 767 +++
.../app/jdbc/ItJdbcStatementBatchingSelfTest.java | 80 -
.../internal/sql/engine/ItCreateTableDdlTest.java | 57 +
.../ignite/internal/sql/engine/ItDmlTest.java | 261 +
.../internal/sql/engine/ItSecondaryIndexTest.java | 4 +-
.../internal/sql/engine/util/QueryChecker.java | 3 +-
.../apache/ignite/internal/schema/BinaryRow.java | 37 +-
.../ignite/internal/schema/ByteBufferRow.java | 13 +-
.../org/apache/ignite/internal/schema/Columns.java | 2 +-
.../builder/TableDefinitionBuilderImpl.java | 16 +
.../schema/registry/SchemaRegistryImpl.java | 5 +
.../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 | 60 +-
.../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 +-
.../src/main/codegen/includes/parserImpls.ftl | 28 +-
.../internal/sql/engine/SqlQueryProcessor.java | 19 +-
.../sql/engine/exec/LogicalRelImplementor.java | 5 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 4 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 107 +-
.../sql/engine/exec/rel/TableScanNode.java | 10 +-
.../internal/sql/engine/prepare/IgnitePlanner.java | 8 +-
.../engine/prepare/IgniteSqlToRelConvertor.java | 167 +
.../sql/engine/prepare/IgniteSqlValidator.java | 8 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 13 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 65 +-
.../internal/sql/engine/rel/IgniteTableModify.java | 2 +-
.../sql/engine/schema/IgniteTableImpl.java | 55 +-
.../sql/engine/schema/InternalIgniteTable.java | 6 +-
.../{ColumnDescriptor.java => ModifyRow.java} | 37 +-
.../internal/sql/engine/trait/TraitUtils.java | 4 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 6 +-
.../sql/engine/planner/AbstractPlannerTest.java | 3 +-
.../index/RocksDbSortedIndexStorageTest.java | 57 +-
.../internal/table/MutableRowTupleAdapterTest.java | 4 +-
.../table/impl/DummySchemaManagerImpl.java | 2 +-
parent/pom.xml | 7 +
137 files changed, 17019 insertions(+), 1869 deletions(-)
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
copy modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/{ClientSqlExecuteBatchRequest.java => ClientSqlPreparedStmntBatchRequest.java} (79%)
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
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/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/network/src/main/java/org/apache/ignite/internal/network/serialization/{UserObjectSerializationException.java => DeclaredType.java} (55%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/MergedField.java
copy modules/network/src/{test/java/org/apache/ignite/internal/network/serialization/marshal/SimpleEnum.java => main/java/org/apache/ignite/internal/network/serialization/marshal/DefaultSchemaMismatchHandler.java} (84%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{InstantiationException.java => DescribedObject.java} (71%)
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/{ValueReader.java => SchemaMismatchEventSource.java} (58%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/{UncheckedMarshalException.java => SchemaMismatchException.java} (74%)
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/network/src/{main/java/org/apache/ignite/internal/network/serialization/ReflectionException.java => test/java/org/apache/ignite/internal/network/serialization/BuiltInTypeTest.java} (73%)
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/UosIgniteOutputStream.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/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/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/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/ItCreateTableDdlTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItDmlTest.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/IgniteSqlToRelConvertor.java
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/{ColumnDescriptor.java => ModifyRow.java} (61%)