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 2021/07/19 14:16:28 UTC
[ignite-3] branch ignite-14591 updated (33f0545 -> cdff008)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14591
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 33f0545 Minor.
add b874180 IGNITE-14408 Implement the Vault Service on top of RocksDB (#174)
add 41ee54f IGNITE-15021 Apache Rat plugin does not check full text license (#189)
add 49b259f IGNITE-14599 Added generic way to bootstrap configuration from Hocon files. Fixes #181
add 5708dd2 IGNITE-14571 - Added release finalization procedure to RELEASE.md
add 7610b69 IGNITE-15013 The design for transactional protocol. - Fixes #190.
add f73dd33 IGNITE-15022 - Updating docs for Ignite 3 alpha 2 release (#192)
add 2a8a3f5 IGNITE-15018 Add support for message inheritance for @Transferable (#193)
add e858e11 IGNITE-15038 Fixed a race in argument capturing. - Fixes #195.
add 7f82358 IGNITE-14863: Schema evolution. Add and remove column. (#173)
add c5fb166 IGNITE-14903 Bump calcite version up to 1.27.0 (#198)
add 7871f79 IGNITE-14951: Schema update. Rename column. (#184)
add 8df9d39 IGNITE-14733: Rename NativeTypes to match them with public ColumnType types. (#199)
add 80eb596 IGNITE-14839 Migrate JRaft tests to JUnit 5 - Fixes #202.
add 10f52bb IGNITE-15044 Introduce work directory for tests (#196)
add d7b295e IGNITE-15055 Fixed an issue with creation a table that already exists. Fixes #200
add b96acd6 IGNITE-14833 Bring back checksum support. Fixes #206
add 7ada2bb IGNITE-14861 Live-schema. Upgrade schema when new column detected. (#212)
add fc7b39d IGNITE-15057 Implemented LockManager to handle concurrency control in transactions - Fixes #211.
add b67df02 IGNITE-15086 Public transactions API - Fixes #214.
add c9a1ab9 IGNITE-14864: Schema update. Merge multiple converters stages. (#194)
add 79edfa4 IGNITE-15019 Fixed flaky testFollowerStartStopFollowing test. Fixes #215
add eb0980a IGNITE-15076 Calcite. Correct additional calcite dependencies. (#204)
add 2c7c75f IGNITE-15130 Generate "hashCode" and "equals" for network messages (#220)
add d06aabc IGNITE-14743: Row layout. Support compact formats for vartable. (#168)
add 8c70ec8 IGNITE-15144 Added missing @return in Javadoc for LoggerMessageHelper#arrayFormat. Fixes #223
add 8167d63 IGNITE-15137 Fixed javadoc phase for ignite-cli module. Fixes #222
add 058af76 IGNITE-14896: Schema update. Changing default value. (#201)
add cdff008 Merge branch 'main' into ignite-14591
No new revisions were added by this update.
Summary of changes:
RELEASE.md | 20 +-
docs/_docs/ignite-cli-tool.adoc | 7 +-
.../includes/ignite-cli-download-windows.adoc | 2 +-
docs/_docs/index.adoc | 15 +
docs/_docs/quick-start/getting-started-guide.adoc | 82 ++--
.../example/table/KeyValueBinaryViewExample.java | 7 +-
.../apache/ignite/example/table/TableExample.java | 7 +-
.../internal/affinity/AffinityManagerTest.java | 3 +-
.../main/java/org/apache/ignite/app/Ignite.java | 8 +
.../main/java/org/apache/ignite/app/Ignition.java | 33 +-
.../org/apache/ignite/app/IgnitionManager.java | 46 +-
.../schemas/table/ColumnConfigurationSchema.java | 2 -
.../schema/{PrimaryIndex.java => SchemaMode.java} | 18 +-
.../apache/ignite/table/KeyValueBinaryView.java | 5 +
.../java/org/apache/ignite/table/KeyValueView.java | 15 +
.../java/org/apache/ignite/table/RecordView.java | 4 +
.../main/java/org/apache/ignite/table/Table.java | 12 +
.../java/org/apache/ignite/table/TableView.java | 15 +
.../main/java/org/apache/ignite/table/Tuple.java | 6 +-
.../apache/ignite/table/manager/IgniteTables.java | 24 +-
.../org/apache/ignite/tx/IgniteTransactions.java} | 28 +-
.../java/org/apache/ignite/tx/Transaction.java} | 37 +-
.../java/com/facebook/presto/bytecode/Access.java | 12 +-
.../bytecode/AddFakeLineNumberClassVisitor.java | 12 +-
.../presto/bytecode/AnnotationDefinition.java | 12 +-
.../com/facebook/presto/bytecode/ArrayOpCode.java | 12 +-
.../presto/bytecode/ByteCodeTooLargeException.java | 12 +-
.../facebook/presto/bytecode/BytecodeBlock.java | 26 +-
.../com/facebook/presto/bytecode/BytecodeNode.java | 12 +-
.../facebook/presto/bytecode/BytecodeUtils.java | 12 +-
.../facebook/presto/bytecode/BytecodeVisitor.java | 12 +-
.../facebook/presto/bytecode/ClassDefinition.java | 12 +-
.../facebook/presto/bytecode/ClassGenerator.java | 12 +-
.../java/com/facebook/presto/bytecode/Comment.java | 14 +-
.../presto/bytecode/CompilationException.java | 12 +-
.../presto/bytecode/DumpBytecodeVisitor.java | 24 +-
.../presto/bytecode/DynamicClassLoader.java | 12 +-
.../facebook/presto/bytecode/FieldDefinition.java | 12 +-
.../facebook/presto/bytecode/MethodDefinition.java | 11 +-
.../presto/bytecode/MethodGenerationContext.java | 16 +-
.../java/com/facebook/presto/bytecode/OpCode.java | 14 +-
.../com/facebook/presto/bytecode/Parameter.java | 12 +-
.../presto/bytecode/ParameterizedType.java | 12 +-
.../java/com/facebook/presto/bytecode/Scope.java | 13 +-
.../facebook/presto/bytecode/SmartClassWriter.java | 11 +-
.../com/facebook/presto/bytecode/Variable.java | 13 +-
.../presto/bytecode/control/CaseStatement.java | 14 +-
.../presto/bytecode/control/DoWhileLoop.java | 14 +-
.../presto/bytecode/control/FlowControl.java | 12 +-
.../facebook/presto/bytecode/control/ForLoop.java | 14 +-
.../presto/bytecode/control/IfStatement.java | 14 +-
.../presto/bytecode/control/SwitchStatement.java | 23 +-
.../facebook/presto/bytecode/control/TryCatch.java | 13 +-
.../presto/bytecode/control/WhileLoop.java | 13 +-
.../facebook/presto/bytecode/debug/DebugNode.java | 12 +-
.../presto/bytecode/debug/LineNumberNode.java | 14 +-
.../presto/bytecode/debug/LocalVariableNode.java | 14 +-
.../bytecode/expression/AndBytecodeExpression.java | 14 +-
.../expression/ArithmeticBytecodeExpression.java | 14 +-
.../expression/ArrayLengthBytecodeExpression.java | 14 +-
.../bytecode/expression/BytecodeExpression.java | 24 +-
.../bytecode/expression/BytecodeExpressions.java | 20 +-
.../expression/CastBytecodeExpression.java | 14 +-
.../expression/ComparisonBytecodeExpression.java | 14 +-
.../expression/ConstantBytecodeExpression.java | 14 +-
.../expression/GetElementBytecodeExpression.java | 14 +-
.../expression/GetFieldBytecodeExpression.java | 18 +-
.../expression/InlineIfBytecodeExpression.java | 14 +-
.../expression/InstanceOfBytecodeExpression.java | 14 +-
.../expression/InvokeBytecodeExpression.java | 20 +-
.../InvokeDynamicBytecodeExpression.java | 20 +-
.../expression/NegateBytecodeExpression.java | 14 +-
.../expression/NewArrayBytecodeExpression.java | 18 +-
.../expression/NewInstanceBytecodeExpression.java | 18 +-
.../bytecode/expression/NotBytecodeExpression.java | 14 +-
.../bytecode/expression/OrBytecodeExpression.java | 14 +-
.../bytecode/expression/PopBytecodeExpression.java | 13 +-
.../expression/ReturnBytecodeExpression.java | 13 +-
.../SetArrayElementBytecodeExpression.java | 13 +-
.../expression/SetFieldBytecodeExpression.java | 17 +-
.../presto/bytecode/instruction/Constant.java | 14 +-
.../bytecode/instruction/FieldInstruction.java | 18 +-
.../bytecode/instruction/InstructionNode.java | 12 +-
.../bytecode/instruction/InvokeInstruction.java | 24 +-
.../bytecode/instruction/JumpInstruction.java | 14 +-
.../presto/bytecode/instruction/LabelNode.java | 14 +-
.../bytecode/instruction/TypeInstruction.java | 13 +-
.../bytecode/instruction/VariableInstruction.java | 13 +-
.../presto/bytecode/TestBytecodeUtils.java | 11 +-
.../presto/bytecode/TestClassGenerator.java | 11 +-
.../expression/BytecodeExpressionAssertions.java | 22 +-
.../TestArithmeticBytecodeExpression.java | 11 +-
.../expression/TestArrayBytecodeExpressions.java | 17 +-
.../expression/TestCastBytecodeExpression.java | 11 +-
.../TestComparisonBytecodeExpression.java | 11 +-
.../expression/TestConstantBytecodeExpression.java | 11 +-
.../expression/TestGetFieldBytecodeExpression.java | 11 +-
.../expression/TestInlineIfBytecodeExpression.java | 11 +-
.../expression/TestInvokeBytecodeExpression.java | 11 +-
.../TestInvokeDynamicBytecodeExpression.java | 11 +-
.../expression/TestLogicalBytecodeExpression.java | 11 +-
.../TestNewInstanceBytecodeExpression.java | 11 +-
.../expression/TestPopBytecodeExpression.java | 11 +-
.../expression/TestSetFieldBytecodeExpression.java | 17 +-
.../TestSetVariableBytecodeExpression.java | 15 +-
modules/calcite/pom.xml | 5 +
.../query/calcite/exec/exp/RexImpTable.java | 9 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 7 +-
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 19 +-
.../calcite/rule/logical/LogicalOrToUnionRule.java | 7 +-
.../processors/query/calcite/util/RexUtils.java | 2 +-
.../query/calcite/planner/PlannerTest.java | 4 +-
modules/cli/pom.xml | 37 +-
.../configuration/processor/Processor.java | 4 +-
modules/configuration/pom.xml | 5 +
.../configuration/ConfigurationManager.java | 9 +-
modules/core/pom.xml | 6 +
.../ignite/internal/manager/EventListener.java | 5 +-
.../internal/manager/ListenerRemovedException.java | 12 +
.../apache/ignite/internal/manager/Producer.java | 15 +-
.../internal/util/{Cursor.java => Constants.java} | 20 +-
.../apache/ignite/internal/util/IgniteUtils.java | 110 ++++-
.../java/org/apache/ignite/lang/ByteArray.java | 40 +-
.../apache/ignite/lang/LoggerMessageHelper.java | 1 +
...ystemPropertiesList.java => WorkDirectory.java} | 15 +-
.../testframework/WorkDirectoryExtension.java | 155 +++++++
.../ignite/internal/util/IgniteUtilsTest.java | 58 +++
.../client/ITMetaStorageServiceTest.java | 2 -
.../internal/metastorage/MetaStorageManager.java | 152 +++----
.../ITTransferableObjectProcessorTest.java | 10 +
...tiveMessage.java => InheritedMessageClash.java} | 14 +-
.../internal/network/processor/MessageClass.java | 44 +-
.../processor/TransferableObjectProcessor.java | 18 +-
.../internal/network/processor/TypeUtils.java | 51 ++-
.../messages/MessageBuilderGenerator.java | 4 +-
.../processor/messages/MessageImplGenerator.java | 140 +++++-
.../internal/network/processor/EmptyMessage.java} | 6 +-
.../network/processor/EmptyMessageTest.java} | 30 +-
.../network/processor/InheritedMessage.java} | 22 +-
...ionOrderTest.java => InheritedMessageTest.java} | 44 +-
.../network/processor/SerializationOrderTest.java | 8 +-
.../network/processor/TestMessageGroup.java | 6 +
.../internal/network/AllTypesMessageTest.java | 65 +++
.../internal/network/netty/InboundDecoderTest.java | 68 +--
modules/raft/pom.xml | 13 +-
.../ignite/raft/jraft/core/ITCliServiceTest.java | 18 +-
.../apache/ignite/raft/jraft/core/ITNodeTest.java | 36 +-
.../raft/server/ITJRaftCounterServerTest.java | 22 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 4 +-
.../internal/raft/server/impl/JRaftServerImpl.java | 2 +-
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 3 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 37 --
.../apache/ignite/raft/jraft/core/NodeImpl.java | 4 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 5 +-
.../ignite/raft/jraft/entity/RaftOutter.java | 5 +
.../ignite/raft/jraft/option/RaftOptions.java | 2 +-
.../raft/jraft/rpc/message/EntryMetaImpl.java | 13 +
.../snapshot/local/LocalSnapshotCopier.java | 13 +-
.../snapshot/local/LocalSnapshotStorage.java | 18 +-
.../org/apache/ignite/raft/jraft/util/Utils.java | 64 +--
.../jraft/util/concurrent/AdjustableSemaphore.java | 1 -
.../org/apache/ignite/raft/jraft/StatusTest.java | 12 +-
.../raft/jraft/closure/ClosureQueueTest.java | 10 +-
.../jraft/closure/SynchronizedClosureTest.java | 12 +-
.../raft/jraft/conf/ConfigurationEntryTest.java | 16 +-
.../raft/jraft/conf/ConfigurationManagerTest.java | 15 +-
.../ignite/raft/jraft/conf/ConfigurationTest.java | 11 +-
.../ignite/raft/jraft/core/BallotBoxTest.java | 29 +-
.../ignite/raft/jraft/core/ExpectClosure.java | 2 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 24 +-
.../ignite/raft/jraft/core/IteratorImplTest.java | 40 +-
.../ignite/raft/jraft/core/IteratorTest.java | 40 +-
.../raft/jraft/core/ReadOnlyServiceTest.java | 33 +-
.../raft/jraft/core/ReplicatorGroupTest.java | 39 +-
.../ignite/raft/jraft/core/ReplicatorTest.java | 69 +--
.../apache/ignite/raft/jraft/core/TestCluster.java | 20 +-
.../ignite/raft/jraft/entity/BallotTest.java | 10 +-
.../ignite/raft/jraft/entity/LogEntryTest.java | 17 +-
.../apache/ignite/raft/jraft/entity/LogIdTest.java | 6 +-
.../ignite/raft/jraft/entity/PeerIdTest.java | 8 +-
.../entity/codec/BaseLogEntryCodecFactoryTest.java | 19 +-
.../jraft/entity/codec/LogEntryCodecPerfTest.java | 12 +-
.../raft/jraft/rpc/AbstractClientServiceTest.java | 29 +-
.../raft/jraft/rpc/RpcResponseFactoryTest.java | 22 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 17 +
.../ignite/raft/jraft/rpc/impl/FutureTest.java | 12 +-
.../jraft/rpc/impl/PingRequestProcessorTest.java | 4 +-
.../impl/cli/AbstractCliRequestProcessorTest.java | 16 +-
.../impl/cli/AddLearnersRequestProcessorTest.java | 8 +-
.../rpc/impl/cli/AddPeerRequestProcessorTest.java | 8 +-
.../rpc/impl/cli/BaseCliRequestProcessorTest.java | 22 +-
.../impl/cli/ChangePeersRequestProcessorTest.java | 8 +-
.../rpc/impl/cli/GetPeersRequestProcessorTest.java | 4 +-
.../cli/RemoveLearnersRequestProcessorTest.java | 6 +-
.../impl/cli/RemovePeerRequestProcessorTest.java | 8 +-
.../cli/ResetLearnersRequestProcessorTest.java | 6 +-
.../impl/cli/ResetPeersRequestProcessorTest.java | 4 +-
.../rpc/impl/cli/SnapshotRequestProcessorTest.java | 4 +-
.../TransferLeadershipRequestProcessorTest.java | 4 +-
.../core/AppendEntriesRequestProcessorTest.java | 26 +-
.../impl/core/BaseNodeRequestProcessorTest.java | 18 +-
.../core/InstallSnapshotRequestProcessorTest.java | 4 +-
.../rpc/impl/core/NodeRequestProcessorTest.java | 14 +-
.../rpc/impl/core/PreVoteRequestProcessorTest.java | 4 +-
.../impl/core/ReadIndexRequestProcessorTest.java | 4 +-
.../impl/core/RequestVoteRequestProcessorTest.java | 4 +-
.../impl/core/TimeoutNowRequestProcessorTest.java | 4 +-
.../ignite/raft/jraft/storage/BaseStorageTest.java | 26 +-
.../ignite/raft/jraft/storage/FileServiceTest.java | 39 +-
.../raft/jraft/storage/SnapshotExecutorTest.java | 229 +++++-----
.../jraft/storage/impl/BaseLogStorageTest.java | 35 +-
.../jraft/storage/impl/LocalLogStorageTest.java | 2 +-
.../storage/impl/LocalRaftMetaStorageTest.java | 29 +-
.../raft/jraft/storage/impl/LogManagerTest.java | 51 +--
.../jraft/storage/impl/RocksDBLogManagerTest.java | 2 +-
.../jraft/storage/impl/RocksDBLogStorageTest.java | 2 +-
.../raft/jraft/storage/io/LocalFileReaderTest.java | 14 +-
.../raft/jraft/storage/io/MessageFileTest.java | 10 +-
.../snapshot/ThroughputSnapshotThrottleTest.java | 8 +-
.../snapshot/local/LocalSnapshotCopierTest.java | 81 ++--
.../snapshot/local/LocalSnapshotMetaTableTest.java | 56 ++-
.../snapshot/local/LocalSnapshotReaderTest.java | 26 +-
.../snapshot/local/LocalSnapshotStorageTest.java | 23 +-
.../snapshot/local/LocalSnapshotWriterTest.java | 30 +-
.../snapshot/local/SnapshotFileReaderTest.java | 17 +-
.../storage/snapshot/remote/CopySessionTest.java | 24 +-
.../snapshot/remote/RemoteFileCopierTest.java | 23 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 2 +-
.../apache/ignite/raft/jraft/test/TestUtils.java | 27 +-
.../raft/jraft/util/AdaptiveBufAllocatorTest.java | 8 +-
.../ignite/raft/jraft/util/ArrayDequeTest.java | 8 +-
.../raft/jraft/util/AsciiStringUtilTest.java | 10 +-
.../apache/ignite/raft/jraft/util/BitsTest.java | 4 +-
.../raft/jraft/util/ByteBufferCollectorTest.java | 14 +-
.../ignite/raft/jraft/util/BytesUtilTest.java | 51 ++-
.../ignite/raft/jraft/util/CountDownEventTest.java | 9 +-
.../apache/ignite/raft/jraft/util/CrcUtilTest.java | 4 +-
.../ignite/raft/jraft/util/EndpointTest.java | 4 +-
.../jraft/util/FileOutputSignalHandlerTest.java | 16 +-
.../jraft/util/RecyclableByteBufferListTest.java | 12 +-
.../ignite/raft/jraft/util/RecyclersTest.java | 33 +-
.../ignite/raft/jraft/util/RepeatedTimerTest.java | 12 +-
.../ignite/raft/jraft/util/SegmentListTest.java | 16 +-
.../ignite/raft/jraft/util/ThreadIdTest.java | 12 +-
.../apache/ignite/raft/jraft/util/UtilsTest.java | 59 +--
.../util/concurrent/AdjustableSemaphoreTest.java | 45 +-
.../LongHeldDetectingReadWriteLockTest.java | 24 +-
.../concurrent/MpscSingleThreadExecutorTest.java | 31 +-
modules/runner/pom.xml | 7 +
.../runner/app/AbstractSchemaChangeTest.java | 288 ++++++++++++
.../runner/app/DynamicTableCreationTest.java | 117 ++---
.../ignite/internal/runner/app/IgnitionTest.java | 35 +-
.../runner/app/LiveSchemaChangeKVViewTest.java | 220 +++++++++
.../runner/app/LiveSchemaChangeTableTest.java | 325 ++++++++++++++
.../runner/app/SchemaChangeKVViewTest.java | 305 +++++++++++++
.../runner/app/SchemaChangeTableViewTest.java | 334 ++++++++++++++
.../internal/runner/app/TableCreationTest.java | 240 +++++-----
.../org/apache/ignite/app/IgniteCliRunner.java | 15 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 26 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 98 ++++-
.../storage/DistributedConfigurationStorage.java | 7 +-
.../storage/LocalConfigurationStorage.java | 6 +-
.../apache/ignite/internal/schema/BinaryRow.java | 38 +-
.../ignite/internal/schema/ByteBufferRow.java | 4 +-
.../org/apache/ignite/internal/schema/Column.java | 11 +-
.../org/apache/ignite/internal/schema/Columns.java | 17 +
.../internal/schema/InvalidTypeException.java | 4 +-
.../ignite/internal/schema/NativeTypeSpec.java | 25 +-
.../apache/ignite/internal/schema/NativeTypes.java | 33 +-
.../org/apache/ignite/internal/schema/README.md | 16 +-
.../ignite/internal/schema/SchemaDescriptor.java | 23 +-
...RegistryException.java => SchemaException.java} | 10 +-
.../ignite/internal/schema/SchemaManager.java | 124 +++++-
...ption.java => SchemaModificationException.java} | 12 +-
.../ignite/internal/schema/SchemaRegistry.java | 24 +-
.../schema/builder/SchemaTableBuilderImpl.java | 3 +
.../SchemaConfigurationConverter.java | 48 ++
.../configuration/SchemaDescriptorConverter.java | 96 +++-
.../ignite/internal/schema/event/SchemaEvent.java | 3 +
.../internal/schema/mapping/ColumnMapper.java | 61 +++
.../internal/schema/mapping/ColumnMapperImpl.java | 79 ++++
.../internal/schema/mapping/ColumnMapping.java | 102 +++++
.../schema/marshaller/AbstractSerializer.java | 4 +-
.../internal/schema/marshaller/BinaryMode.java | 16 +-
.../internal/schema/marshaller/MarshallerUtil.java | 4 +-
.../marshaller/asm/AsmSerializerGenerator.java | 27 +-
.../asm/IdentityMarshallerCodeGenerator.java | 2 +-
.../asm/ObjectMarshallerCodeGenerator.java | 2 +-
.../marshaller/reflection/FieldAccessor.java | 4 +-
.../marshaller/reflection/JavaSerializer.java | 17 +-
.../schema/marshaller/reflection/Marshaller.java | 4 +-
.../schema/registry/SchemaRegistryException.java | 4 +-
.../schema/registry/SchemaRegistryImpl.java | 86 +++-
.../schema/registry/UpgradingRowAdapter.java | 374 ++++++++++++++++
.../schema/{ => row}/ExpandableByteBuf.java | 82 ++--
.../ignite/internal/schema/{ => row}/Row.java | 331 ++++++++------
.../internal/schema/{ => row}/RowAssembler.java | 426 +++++++++++-------
.../ignite/internal/schema/row/VarTableFormat.java | 268 +++++++++++
.../benchmarks/SerializerBenchmarkTest.java | 8 +-
.../apache/ignite/internal/schema/ColumnTest.java | 4 +-
.../apache/ignite/internal/schema/ColumnsTest.java | 190 ++++----
.../internal/schema/ExpandableByteBufTest.java | 1 +
.../ignite/internal/schema/NativeTypeTest.java | 36 +-
.../schema/RowAssemblerAdvancedSchemaTest.java | 191 ++++----
.../schema/RowAssemblerSimpleSchemaTest.java | 429 +++++++++---------
.../org/apache/ignite/internal/schema/RowTest.java | 223 ++++++++--
.../internal/schema/SchemaDescriptorTest.java | 8 +-
.../apache/ignite/internal/schema/TestUtils.java | 8 +-
.../SchemaDescriptorConverterTest.java | 8 +-
.../schema/marshaller/JavaSerializerTest.java | 50 +--
.../marshaller/reflection/FieldAccessorTest.java | 32 +-
.../{ => registry}/SchemaRegistryImplTest.java | 178 +++++---
modules/storage-rocksdb/pom.xml | 7 +
.../storage/rocksdb/RocksDbStorageTest.java | 27 +-
modules/table/pom.xml | 13 +
.../ignite/distributed/ITDistributedTableTest.java | 27 +-
.../internal/schema/marshaller/KVSerializer.java | 2 +-
.../schema/marshaller/RecordSerializer.java | 2 +-
.../schema/marshaller/TupleMarshaller.java | 2 +-
.../ignite/internal/table/AbstractTableView.java | 22 +-
.../internal/table/ColumnNotFoundException.java | 6 +-
.../ignite/internal/table/InternalTable.java | 61 ++-
.../ignite/internal/table/KVBinaryViewImpl.java | 72 ++-
.../apache/ignite/internal/table/KVViewImpl.java | 17 +-
.../internal/table/LiveSchemaTupleBuilderImpl.java | 145 ++++++
.../ignite/internal/table/RecordViewImpl.java | 21 +-
.../ignite/internal/table/RowChunkAdapter.java | 13 +-
.../internal/table/SchemaMismatchException.java | 6 +-
.../apache/ignite/internal/table/TableImpl.java | 78 ++--
.../org/apache/ignite/internal/table/TableRow.java | 25 +-
.../ignite/internal/table/TupleBuilderImpl.java | 29 +-
.../ignite/internal/table/TupleMarshallerImpl.java | 155 ++-----
.../internal/table/distributed/TableManager.java | 478 +++++++++++++++-----
.../distributed/storage/InternalTableImpl.java | 51 ++-
.../ignite/internal/table/event/TableEvent.java | 3 +
.../TupleMarshallerFixlenOnlyBenchmark.java | 150 +++++++
.../TupleMarshallerVarlenOnlyBenchmark.java | 170 +++++++
.../org/apache/ignite/internal/table/Example.java | 2 +-
.../internal/table/KVViewOperationsTest.java | 49 ++-
.../internal/table/StrictSchemaOperationsTest.java | 18 +-
.../table/TableBinaryViewOperationsTest.java | 66 +--
.../ignite/internal/table/TableManagerTest.java | 51 ++-
.../org/apache/ignite/internal/table/TxTest.java | 208 +++++++++
.../raft/PartitionCommandListenerTest.java | 17 +-
.../table/impl/DummyInternalTableImpl.java | 44 +-
.../table/impl/DummySchemaManagerImpl.java | 14 +
.../internal/table/impl/TestTupleBuilder.java | 20 +-
modules/transactions/README.md | 126 ++++++
modules/{raft-client => transactions}/pom.xml | 9 +-
.../apache/ignite/internal/tx/LockException.java} | 23 +-
.../org/apache/ignite/internal/tx/LockManager.java | 70 +++
.../org/apache/ignite/internal/tx/Timestamp.java | 85 ++++
.../org/apache/ignite/internal/tx/Waiter.java} | 14 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 335 ++++++++++++++
.../internal/tx/AbstractLockManagerTest.java | 489 +++++++++++++++++++++
.../ignite/internal/tx/HeapLockManagerTest.java} | 11 +-
modules/vault/pom.xml | 18 +
.../PersistencePropertiesVaultServiceTest.java | 97 ++++
.../persistence/PersistentVaultServiceTest.java} | 29 +-
.../vault/{common/Entry.java => VaultEntry.java} | 42 +-
.../apache/ignite/internal/vault/VaultManager.java | 109 ++---
.../internal/vault/{service => }/VaultService.java | 15 +-
.../internal/vault/impl/VaultServiceImpl.java | 103 -----
.../vault/inmemory/InMemoryVaultService.java | 119 +++++
.../vault/persistence/PersistentVaultService.java | 207 +++++++++
.../vault/persistence/RocksIteratorAdapter.java | 100 +++++
.../internal/vault/CompletableFutureMatcher.java | 69 +++
.../ignite/internal/vault/VaultManagerTest.java | 73 +++
.../ignite/internal/vault/VaultServiceTest.java | 289 ++++++++++++
.../vault/impl/VaultBaseContractsTest.java | 221 ----------
.../vault/inmemory/InMemoryVaultServiceTest.java} | 20 +-
parent/pom.xml | 41 +-
pom.xml | 12 +
373 files changed, 11188 insertions(+), 4276 deletions(-)
copy modules/api/src/main/java/org/apache/ignite/schema/{PrimaryIndex.java => SchemaMode.java} (59%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java => api/src/main/java/org/apache/ignite/tx/IgniteTransactions.java} (62%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationNamedListListener.java => api/src/main/java/org/apache/ignite/tx/Transaction.java} (53%)
copy modules/core/src/main/java/org/apache/ignite/internal/util/{Cursor.java => Constants.java} (67%)
copy modules/core/src/test/java/org/apache/ignite/internal/testframework/{SystemPropertiesList.java => WorkDirectory.java} (74%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/testframework/WorkDirectoryExtension.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsTest.java
copy modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/network/processor/{TransitiveMessage.java => InheritedMessageClash.java} (85%)
copy modules/network-annotation-processor/src/{integrationTest/resources/org/apache/ignite/internal/network/processor/InvalidReturnTypeGetterMessage.java => test/java/org/apache/ignite/internal/network/processor/EmptyMessage.java} (90%)
copy modules/{schema/src/test/java/org/apache/ignite/internal/schema/builder/PartialIndexBuilderTest.java => network-annotation-processor/src/test/java/org/apache/ignite/internal/network/processor/EmptyMessageTest.java} (58%)
copy modules/network-annotation-processor/src/{integrationTest/resources/org/apache/ignite/internal/network/processor/TransitiveMessage.java => test/java/org/apache/ignite/internal/network/processor/InheritedMessage.java} (80%)
copy modules/network-annotation-processor/src/test/java/org/apache/ignite/internal/network/processor/{SerializationOrderTest.java => InheritedMessageTest.java} (58%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/AllTypesMessageTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/AbstractSchemaChangeTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/LiveSchemaChangeKVViewTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/LiveSchemaChangeTableTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/SchemaChangeKVViewTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/SchemaChangeTableViewTest.java
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/{registry/SchemaRegistryException.java => SchemaException.java} (80%)
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/{registry/SchemaRegistryException.java => SchemaModificationException.java} (76%)
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/mapping/ColumnMapper.java
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/mapping/ColumnMapperImpl.java
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/mapping/ColumnMapping.java
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/registry/UpgradingRowAdapter.java
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/{ => row}/ExpandableByteBuf.java (82%)
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/{ => row}/Row.java (66%)
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/{ => row}/RowAssembler.java (52%)
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/row/VarTableFormat.java
rename modules/schema/src/test/java/org/apache/ignite/internal/schema/{ => registry}/SchemaRegistryImplTest.java (77%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/LiveSchemaTupleBuilderImpl.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/benchmarks/TupleMarshallerFixlenOnlyBenchmark.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/benchmarks/TupleMarshallerVarlenOnlyBenchmark.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/TxTest.java
create mode 100644 modules/transactions/README.md
copy modules/{raft-client => transactions}/pom.xml (92%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java => transactions/src/main/java/org/apache/ignite/internal/tx/LockException.java} (66%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/LockManager.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/Timestamp.java
copy modules/{api/src/main/java/org/apache/ignite/schema/SortOrder.java => transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java} (79%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/HeapLockManager.java
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/AbstractLockManagerTest.java
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java} (76%)
create mode 100644 modules/vault/src/integrationTest/java/org/apache/ignite/internal/vault/persistence/PersistencePropertiesVaultServiceTest.java
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeSystem.java => vault/src/integrationTest/java/org/apache/ignite/internal/vault/persistence/PersistentVaultServiceTest.java} (55%)
rename modules/vault/src/main/java/org/apache/ignite/internal/vault/{common/Entry.java => VaultEntry.java} (62%)
rename modules/vault/src/main/java/org/apache/ignite/internal/vault/{service => }/VaultService.java (87%)
delete mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/impl/VaultServiceImpl.java
create mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/inmemory/InMemoryVaultService.java
create mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/persistence/PersistentVaultService.java
create mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/persistence/RocksIteratorAdapter.java
create mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/CompletableFutureMatcher.java
create mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/VaultManagerTest.java
create mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/VaultServiceTest.java
delete mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/impl/VaultBaseContractsTest.java
copy modules/{api/src/main/java/org/apache/ignite/schema/PartialIndex.java => vault/src/test/java/org/apache/ignite/internal/vault/inmemory/InMemoryVaultServiceTest.java} (69%)