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/08 13:33:46 UTC
[ignite-3] branch ignite-14743 updated (342fc64 -> e9f5e50)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
omit 342fc64 Minors.
omit a501142 Fix dependencies.
omit 31caee1 Minor.
omit 1181d7c Minor optimizations.
omit 1316302 Fix benchmarks
omit 9ce3e73 Minor.
omit 5d201c4 Add benchmarks
omit 0b79ebf Minor.
omit 28f2f46 Merge branch 'main' into ignite-14743-row-formats
add af81fef Minors after review.
add d127d0e Math operations optimization on hot-path.
add bb13145 Merge branch 'main' into ignite-14743
add 07b2d80 Inline row reader.
add 5cbb18b Row writer refactoring.
add ddfb6bd Styles.
add fdeff33 Inline ChunkWriter.
add 40b85de Simplify row size estimation. Fallback to single vartable format.
add fae6c3a Minor.
add f8cdbd8 Add compaction.
add b06f467 Add benchmark.
add c419b22 Add benchmarks
add 04d44cd Minor optimization.
add 796798c Minor.
add 8ab6653 Minor.
add bee6095 Minor.
add e1721c9 Minor.
add 637183e Styles.
add b9e1126 Styles.
add bbabf29 Styles.
add 607f764 Fix dependencies.
add fc7082d Minors.
add 2ef376c IGNITE-14890 Using SLF4J log format. Fixes #175
add 4c93ea1 IGNITE-14993 - Choose available port out of a range
add 262022f IGNITE-14994 - Topology snapshot print out
add 5b81332 IGNITE-14995 - Updated NOTICE
add adfc9d4 IGNITE-14996 - Added examples for Table and KeyValueBinaryView
add 9230f61 IGNITE-14996 - Updated examples structure
add 7140111 IGNITE-15005 - Binary distribution README
add e57bc8d IGNITE-14571 - Release procedure documentation
add 3fdeaf4 IGNITE-14957 Introduced the NetworkAddress class. Fixes #185
add 062550c IGNITE-14996 - Modules order fix.
add 62f4e65 IGNITE-15014 Explicit annotation processor dependency in api module. (#186)
add 8c7912d IGNITE-15016 Remove integration tests execution if maven.test.skip is set (#187)
add f5efe45 IGNITE-14745 Implemented Storage API for partitions and 2 basic implementations - CHM and RocksDB. (#169)
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 e9f5e50 Merge branch 'main' into ignite-14743
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 (342fc64)
\
N -- N -- N refs/heads/ignite-14743 (e9f5e50)
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:
NOTICE | 5 +
RELEASE.md | 87 ++++
assembly/NOTICE | 0
assembly/README | 0
assembly/README.md | 52 +++
assembly/assembly.xml | 27 +-
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 ++--
examples/README.md | 21 +
examples/config/ignite-config.json | 13 +
.../pom.xml => examples/pom-standalone.xml | 21 +-
{modules/cli-common => examples}/pom.xml | 9 +-
.../example/table/KeyValueBinaryViewExample.java | 116 ++++++
.../apache/ignite/example/table/TableExample.java | 112 ++++++
.../internal/affinity/AffinityManagerTest.java | 3 +-
.../affinity/RendezvousAffinityFunctionTest.java | 20 +-
modules/api/pom.xml | 7 +
.../main/java/org/apache/ignite/app/Ignition.java | 33 +-
.../org/apache/ignite/app/IgnitionManager.java | 46 ++-
.../schemas/table/ColumnConfigurationSchema.java | 2 -
.../apache/ignite/table/manager/IgniteTables.java | 9 +-
.../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 +-
.../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 +-
.../configuration/processor/Processor.java | 4 +-
modules/configuration/pom.xml | 5 +
.../configuration/ConfigurationManager.java | 9 +-
modules/core/pom.xml | 6 +
.../ignite/internal/manager/EventListener.java | 4 +-
.../org/apache/ignite/internal/util/ByteUtils.java | 5 +-
.../apache/ignite/internal/util/IgniteUtils.java | 142 ++++++-
.../java/org/apache/ignite/lang/ByteArray.java | 40 +-
.../java/org/apache/ignite/lang/IgniteLogger.java | 179 +++++++--
.../apache/ignite/lang/LoggerMessageHelper.java | 443 +++++++++++++++++++++
...ystemPropertiesList.java => WorkDirectory.java} | 15 +-
.../testframework/WorkDirectoryExtension.java | 155 +++++++
.../tostring/IgniteToStringBuilderSelfTest.java | 4 +-
.../ignite/internal/util/IgniteUtilsTest.java | 58 +++
.../org/apache/ignite/lang/LoggerHelperTest.java | 299 ++++++++++++++
.../client/ITMetaStorageServiceTest.java | 21 +-
.../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 +-
.../network/processor/InheritedMessage.java} | 22 +-
...ionOrderTest.java => InheritedMessageTest.java} | 44 +-
.../network/processor/SerializationOrderTest.java | 8 +-
.../network/processor/TestMessageGroup.java | 2 +
modules/network-api/pom.xml | 6 +
.../ignite/network/ClusterLocalConfiguration.java | 6 +-
.../org/apache/ignite/network/ClusterNode.java | 47 +--
.../apache/ignite/network/MessagingService.java | 8 +-
.../org/apache/ignite/network/NetworkAddress.java | 118 ++++++
.../ignite/network/NetworkMessageHandler.java | 4 +-
.../org/apache/ignite/network/TopologyService.java | 2 +-
.../apache/ignite/network/NetworkAddressTest.java | 80 ++++
.../network/scalecube/ITNodeRestartsTest.java | 23 +-
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 14 +-
.../internal/network/netty/ConnectionManager.java | 4 +-
.../ignite/internal/network/netty/NettyServer.java | 21 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 22 +-
.../ScaleCubeDirectMarshallerTransport.java | 9 +-
.../scalecube/ScaleCubeMessagingService.java | 37 +-
.../scalecube/ScaleCubeTopologyService.java | 25 +-
.../java/org/apache/ignite/raft/client/Peer.java | 29 +-
.../raft/client/service/RaftGroupServiceTest.java | 124 +++---
modules/raft/pom.xml | 13 +-
.../ignite/raft/jraft/core/ITCliServiceTest.java | 24 +-
.../apache/ignite/raft/jraft/core/ITNodeTest.java | 27 +-
.../raft/server/ITJRaftCounterServerTest.java | 50 ++-
.../raft/server/ITSimpleCounterServerTest.java | 11 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 3 +-
.../internal/raft/server/impl/JRaftServerImpl.java | 53 ++-
.../internal/raft/server/impl/RaftServerImpl.java | 13 +-
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 20 +-
.../apache/ignite/raft/jraft/entity/PeerId.java | 7 +-
.../apache/ignite/raft/jraft/rpc/RpcContext.java | 5 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 40 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 5 +-
.../rpc/impl/client/ActionRequestProcessor.java | 35 +-
.../rpc/impl/client/GetLeaderRequestProcessor.java | 10 +-
.../rpc/impl/client/SnapshotRequestProcessor.java | 18 +-
.../snapshot/local/LocalSnapshotCopier.java | 13 +-
.../snapshot/local/LocalSnapshotStorage.java | 18 +-
.../org/apache/ignite/raft/jraft/util/Utils.java | 62 +--
.../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 | 14 +-
.../ignite/raft/jraft/conf/ConfigurationTest.java | 10 +-
.../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 | 31 +-
.../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 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 12 +-
.../raft/jraft/rpc/RpcResponseFactoryTest.java | 22 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 10 +-
.../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 | 9 +-
.../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 | 173 ++++++++
.../runner/app/DynamicTableCreationTest.java | 52 ++-
.../ignite/internal/runner/app/IgnitionTest.java | 35 +-
.../runner/app/SchemaChangeKVViewTest.java | 169 ++++++++
.../runner/app/SchemaChangeTableViewTest.java | 161 ++++++++
.../internal/runner/app/TableCreationTest.java | 28 +-
.../org/apache/ignite/app/IgniteCliRunner.java | 15 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 20 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 111 +++++-
.../storage/DistributedConfigurationStorage.java | 7 +-
.../storage/LocalConfigurationStorage.java | 6 +-
.../apache/ignite/internal/schema/BinaryRow.java | 3 +
.../ignite/internal/schema/ByteBufferRow.java | 4 +-
.../org/apache/ignite/internal/schema/Column.java | 10 +-
.../org/apache/ignite/internal/schema/Columns.java | 8 +-
.../internal/schema/InvalidTypeException.java | 4 +-
.../ignite/internal/schema/NativeTypeSpec.java | 24 +-
.../apache/ignite/internal/schema/NativeTypes.java | 32 +-
.../org/apache/ignite/internal/schema/README.md | 8 +-
.../ignite/internal/schema/SchemaDescriptor.java | 23 +-
...RegistryException.java => SchemaException.java} | 10 +-
.../ignite/internal/schema/SchemaManager.java | 161 +++++++-
...ption.java => SchemaModificationException.java} | 12 +-
.../ignite/internal/schema/SchemaRegistry.java | 23 +-
.../configuration/SchemaDescriptorConverter.java | 96 ++++-
.../ignite/internal/schema/event/SchemaEvent.java | 3 +
.../internal/schema/mapping/ColumnMapper.java} | 20 +-
.../schema/mapping/ColumnMapperBuilder.java} | 19 +-
.../internal/schema/mapping/ColumnMapperImpl.java} | 44 +-
.../internal/schema/mapping/ColumnMapping.java} | 45 ++-
.../internal/schema/marshaller/BinaryMode.java | 16 +-
.../internal/schema/marshaller/MarshallerUtil.java | 3 +-
.../marshaller/asm/AsmSerializerGenerator.java | 10 +-
.../marshaller/reflection/JavaSerializer.java | 9 +-
.../schema/registry/SchemaRegistryException.java | 4 +-
.../schema/registry/SchemaRegistryImpl.java | 38 +-
.../schema/registry/UpgradingRowAdapter.java | 51 +++
.../ignite/internal/schema/row/ChunkReader.java | 212 ----------
.../ignite/internal/schema/row/ChunkWriter.java | 272 -------------
.../internal/schema/row/ExpandableByteBuf.java | 61 +--
.../org/apache/ignite/internal/schema/row/Row.java | 332 ++++++++++++---
.../ignite/internal/schema/row/RowAssembler.java | 361 ++++++++++-------
.../row/{ChunkFormat.java => VarTableFormat.java} | 262 ++++++------
.../benchmarks/SerializerBenchmarkTest.java | 8 +-
.../apache/ignite/internal/schema/ColumnTest.java | 4 +-
.../apache/ignite/internal/schema/ColumnsTest.java | 190 ++++-----
.../ignite/internal/schema/NativeTypeTest.java | 36 +-
.../schema/RowAssemblerAdvancedSchemaTest.java | 73 ++--
.../schema/RowAssemblerSimpleSchemaTest.java | 257 ++++++------
.../org/apache/ignite/internal/schema/RowTest.java | 66 +--
.../internal/schema/SchemaDescriptorTest.java | 8 +-
.../internal/schema/SchemaRegistryImplTest.java | 52 +--
.../apache/ignite/internal/schema/TestUtils.java | 8 +-
.../SchemaDescriptorConverterTest.java | 8 +-
.../schema/marshaller/JavaSerializerTest.java | 50 +--
.../marshaller/reflection/FieldAccessorTest.java | 28 +-
modules/{configuration-api => storage-api}/pom.xml | 31 +-
.../apache/ignite/internal/storage/DataRow.java} | 20 +-
.../ignite/internal/storage/InvokeClosure.java} | 24 +-
.../ignite/internal/storage}/OperationType.java | 18 +-
.../apache/ignite/internal/storage/SearchRow.java} | 20 +-
.../apache/ignite/internal/storage/Storage.java | 70 ++++
.../ignite/internal}/storage/StorageException.java | 22 +-
.../storage/basic/ConcurrentHashMapStorage.java | 140 +++++++
.../internal/storage/basic/SimpleDataRow.java} | 41 +-
.../storage/basic/SimpleReadInvokeClosure.java | 57 +++
.../storage/basic/SimpleRemoveInvokeClosure.java} | 36 +-
.../storage/basic/SimpleWriteInvokeClosure.java} | 38 +-
.../internal/storage/AbstractStorageTest.java | 205 ++++++++++
.../basic/ConcurrentHashMapStorageTest.java} | 16 +-
.../{configuration-api => storage-rocksdb}/pom.xml | 35 +-
.../internal/storage/rocksdb/RocksDbStorage.java | 255 ++++++++++++
.../storage/rocksdb/RocksDbStorageTest.java | 46 +++
modules/table/pom.xml | 6 +
.../ignite/distributed/ITDistributedTableTest.java | 43 +-
.../ignite/internal/table/KVBinaryViewImpl.java | 5 +-
.../apache/ignite/internal/table/TableImpl.java | 5 +-
.../org/apache/ignite/internal/table/TableRow.java | 4 +-
.../ignite/internal/table/TupleMarshallerImpl.java | 48 +--
.../internal/table/distributed/TableManager.java | 392 +++++++++++++-----
.../ignite/internal/table/event/TableEvent.java | 3 +
.../TupleMarshallerVarlenOnlyBenchmark.java | 13 +-
.../internal/table/KVViewOperationsTest.java | 28 +-
.../internal/table/StrictSchemaOperationsTest.java | 10 +-
.../table/TableBinaryViewOperationsTest.java | 48 +--
.../ignite/internal/table/TableManagerTest.java | 131 +++---
.../raft/PartitionCommandListenerTest.java | 8 +-
.../table/impl/DummySchemaManagerImpl.java | 14 +
modules/transactions/README.md | 126 ++++++
modules/{raft-client => transactions}/pom.xml | 2 +-
.../org/apache/ignite/internal/tx/LockManager.java | 54 +++
.../ignite/internal/tx/LockOrderException.java} | 13 +-
.../ignite/internal/tx/LockManagerTest.java} | 6 +-
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 | 60 ++-
pom.xml | 4 +
375 files changed, 9343 insertions(+), 4548 deletions(-)
create mode 100644 NOTICE
create mode 100644 RELEASE.md
delete mode 100644 assembly/NOTICE
delete mode 100644 assembly/README
create mode 100644 assembly/README.md
create mode 100644 examples/README.md
create mode 100644 examples/config/ignite-config.json
copy modules/cli-common/pom.xml => examples/pom-standalone.xml (76%)
copy {modules/cli-common => examples}/pom.xml (85%)
create mode 100644 examples/src/main/java/org/apache/ignite/example/table/KeyValueBinaryViewExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/table/TableExample.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/lang/LoggerMessageHelper.java
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
create mode 100644 modules/core/src/test/java/org/apache/ignite/lang/LoggerHelperTest.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/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-api/src/main/java/org/apache/ignite/network/NetworkAddress.java
create mode 100644 modules/network-api/src/test/java/org/apache/ignite/network/NetworkAddressTest.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/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%)
copy modules/{api/src/main/java/org/apache/ignite/schema/PartialIndex.java => schema/src/main/java/org/apache/ignite/internal/schema/mapping/ColumnMapper.java} (67%)
copy modules/{api/src/main/java/org/apache/ignite/schema/TableIndex.java => schema/src/main/java/org/apache/ignite/internal/schema/mapping/ColumnMapperBuilder.java} (72%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SortedIndex.java => schema/src/main/java/org/apache/ignite/internal/schema/mapping/ColumnMapperImpl.java} (57%)
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/storage/Data.java => schema/src/main/java/org/apache/ignite/internal/schema/mapping/ColumnMapping.java} (54%)
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/registry/UpgradingRowAdapter.java
delete mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/row/ChunkReader.java
delete mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/row/ChunkWriter.java
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/row/{ChunkFormat.java => VarTableFormat.java} (50%)
copy modules/{configuration-api => storage-api}/pom.xml (63%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlan.java => storage-api/src/main/java/org/apache/ignite/internal/storage/DataRow.java} (64%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Mailbox.java => storage-api/src/main/java/org/apache/ignite/internal/storage/InvokeClosure.java} (58%)
copy modules/{metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common => storage-api/src/main/java/org/apache/ignite/internal/storage}/OperationType.java (80%)
copy modules/{api/src/main/java/org/apache/ignite/schema/builder/SchemaObjectBuilder.java => storage-api/src/main/java/org/apache/ignite/internal/storage/SearchRow.java} (67%)
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/Storage.java
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration => storage-api/src/main/java/org/apache/ignite/internal}/storage/StorageException.java (75%)
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/ConcurrentHashMapStorage.java
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationNotificationEventImpl.java => storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleDataRow.java} (53%)
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleReadInvokeClosure.java
copy modules/{api/src/main/java/org/apache/ignite/schema/SortedIndex.java => storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleRemoveInvokeClosure.java} (58%)
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/notifications/ConfigurationNotificationEventImpl.java => storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleWriteInvokeClosure.java} (54%)
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/AbstractStorageTest.java
copy modules/{cli/src/test/java/org/apache/ignite/cli/AbstractCliTest.java => storage-api/src/test/java/org/apache/ignite/internal/storage/basic/ConcurrentHashMapStorageTest.java} (67%)
copy modules/{configuration-api => storage-rocksdb}/pom.xml (59%)
create mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorage.java
create mode 100644 modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorageTest.java
create mode 100644 modules/transactions/README.md
copy modules/{raft-client => transactions}/pom.xml (98%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/LockManager.java
copy modules/{api/src/main/java/org/apache/ignite/binary/BinaryObject.java => transactions/src/main/java/org/apache/ignite/internal/tx/LockOrderException.java} (76%)
copy modules/{api/src/main/java/org/apache/ignite/table/mapper/KeyMapper.java => transactions/src/test/java/org/apache/ignite/internal/tx/LockManagerTest.java} (88%)
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%)