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/11/29 09:12:28 UTC
[ignite-3] branch ignite-15784 updated (7b72d87 -> 3689d99)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15784
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 7b72d87 Fix tests.
add 2d600a1 IGNITE-16005 Added ORDER BY clause to SqlJdbcExample. Fixes #473
add 70726b1 IGNITE-15085 Transactions support phase 1: 2PL concurrency control
add 3689d99 Merge branch 'main' into ignite-15784
No new revisions were added by this update.
Summary of changes:
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 7 +-
.../ignite/example/sql/jdbc/SqlExamplesTest.java | 4 +-
.../builder/SortedIndexDefinitionBuilder.java | 1 +
.../java/org/apache/ignite/table/KeyValueView.java | 18 +-
.../org/apache/ignite/tx/IgniteTransactions.java | 43 +-
.../java/org/apache/ignite/tx/Transaction.java | 16 +-
.../apache/ignite/tx/TransactionException.java} | 30 +-
.../handler/requests/table/ClientTableCommon.java | 34 +-
.../table/ClientTupleDeleteAllExactRequest.java | 7 +-
.../table/ClientTupleDeleteAllRequest.java | 3 +-
.../requests/table/ClientTupleGetAllRequest.java | 3 +-
.../table/ClientTupleInsertAllRequest.java | 3 +-
.../ClientTupleInsertAllSchemalessRequest.java | 3 +-
.../ignite/internal/client/table/ClientTable.java | 8 +-
.../ignite/client/fakes/FakeInternalTable.java | 150 +-
.../ignite/client/fakes/FakeSchemaRegistry.java | 2 +-
.../internal/tostring/IgniteToStringBuilder.java | 26 +
.../internal/testframework/IgniteTestUtils.java | 13 +-
.../ItMetaStorageServicePersistenceTest.java | 8 +-
.../server/raft/MetaStorageListener.java | 8 +
.../internal/metastorage/MetaStorageManager.java | 4 +-
.../apache/ignite/network/MessagingService.java | 4 +-
.../ignite/internal/network/netty/NettyServer.java | 81 +-
.../dotnet/Apache.Ignite.Tests/Table/TableTests.cs | 4 +-
modules/platforms/dotnet/DEVNOTES.md | 3 +
.../raft/client/service/RaftGroupListener.java | 11 +
.../raft/client/service/RaftGroupService.java | 10 +
.../service/ItAbstractListenerSnapshotTest.java | 25 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 60 +-
.../apache/ignite/raft/server/CounterListener.java | 8 +
.../raft/server/ItJraftCounterServerTest.java | 25 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 57 +-
.../ignite/internal/raft/server/RaftServer.java | 10 +
.../internal/raft/server/impl/JraftServerImpl.java | 20 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 16 +-
.../raft/jraft/disruptor/StripedDisruptor.java | 10 +-
.../apache/ignite/raft/jraft/error/RaftError.java | 2 +-
.../ignite/raft/jraft/option/NodeOptions.java | 1 +
.../ignite/raft/jraft/option/ReadOnlyOption.java | 1 -
.../ignite/raft/jraft/rpc/RpcResponseClosure.java | 3 -
.../jraft/rpc/impl/ActionRequestProcessor.java | 171 ++-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 48 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 48 +-
.../rpc/impl/cli/AddLearnersRequestProcessor.java | 2 -
.../rpc/impl/cli/BaseCliRequestProcessor.java | 2 -
.../jraft/rpc/impl/core/NodeRequestProcessor.java | 1 -
.../rpc/impl/core/ReadIndexRequestProcessor.java | 3 -
.../rpc/impl/core/TimeoutNowRequestProcessor.java | 3 -
.../apache/ignite/raft/jraft/storage/Storage.java | 3 -
.../raft/jraft/storage/impl/LogManagerImpl.java | 3 +
.../apache/ignite/raft/jraft/util/ArrayDeque.java | 3 -
.../org/apache/ignite/raft/jraft/util/Bits.java | 3 -
.../apache/ignite/raft/jraft/util/Copiable.java | 3 -
.../DefaultFixedThreadsExecutorGroupFactory.java | 2 +-
.../internal/raft/server/impl/RaftServerImpl.java | 9 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 4 +-
.../ignite/raft/jraft/util/EndpointTest.java | 1 -
.../concurrent/SingleThreadExecutorBenchmark.java | 19 +-
.../ItDistributedConfigurationPropertiesTest.java | 4 +-
.../ItDistributedConfigurationStorageTest.java | 72 +-
.../internal/runner/app/ItNoThreadsLeftTest.java | 16 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 22 +-
modules/schema/pom.xml | 3 +-
.../ignite/internal/schema/ByteBufferRow.java | 11 +-
.../schema/registry/SchemaRegistryImpl.java | 6 +-
.../SchemaConfigurationConverterTest.java | 93 +-
.../basic/ConcurrentHashMapPartitionStorage.java | 40 +-
modules/table/pom.xml | 5 +
.../ignite/distributed/ItDistributedTableTest.java | 606 --------
.../distributed/ItInternalTableScanTest.java | 38 +-
.../ignite/distributed/ItTablePersistenceTest.java | 86 +-
.../distributed/ItTxDistributedTestSingleNode.java | 437 ++++++
.../ItTxDistributedTestSingleNodeCollocated.java} | 47 +-
...tTxDistributedTestThreeNodesThreeReplicas.java} | 46 +-
...utedTestThreeNodesThreeReplicasCollocated.java} | 45 +-
.../ignite/internal/table/AbstractTableView.java | 28 +-
.../ignite/internal/table/InternalTable.java | 49 +-
.../internal/table/KeyValueBinaryViewImpl.java | 176 +--
.../ignite/internal/table/KeyValueViewImpl.java | 21 +-
.../internal/table/RecordBinaryViewImpl.java | 229 ++-
.../apache/ignite/internal/table/TableImpl.java | 41 +-
.../org/apache/ignite/internal/table/TableRow.java | 4 +-
.../internal/table/distributed/TableManager.java | 83 +-
.../table/distributed/TableTxManagerImpl.java | 56 +
.../table/distributed/command/CommandUtils.java | 45 +-
.../distributed/command/DeleteAllCommand.java | 42 +-
.../table/distributed/command/DeleteCommand.java | 39 +-
.../distributed/command/DeleteExactAllCommand.java | 42 +-
.../distributed/command/DeleteExactCommand.java | 39 +-
.../table/distributed/command/FinishTxCommand.java | 59 +
.../table/distributed/command/GetAllCommand.java | 42 +-
.../distributed/command/GetAndDeleteCommand.java | 38 +-
.../distributed/command/GetAndReplaceCommand.java | 38 +-
.../distributed/command/GetAndUpsertCommand.java | 41 +-
.../table/distributed/command/GetCommand.java | 38 +-
.../distributed/command/InsertAllCommand.java | 42 +-
.../table/distributed/command/InsertCommand.java | 38 +-
...teExactAllCommand.java => MultiKeyCommand.java} | 45 +-
.../table/distributed/command/ReplaceCommand.java | 47 +-
.../distributed/command/ReplaceIfExistCommand.java | 37 +-
.../{DeleteCommand.java => SingleKeyCommand.java} | 32 +-
.../distributed/command/TransactionalCommand.java} | 28 +-
.../distributed/command/UpsertAllCommand.java | 42 +-
.../table/distributed/command/UpsertCommand.java | 38 +-
.../command/response/MultiRowsResponse.java | 2 +-
.../command/response/SingleRowResponse.java | 2 +-
.../table/distributed/raft/PartitionListener.java | 371 +++--
.../distributed/storage/InternalTableImpl.java | 325 +++--
.../distributed/storage/VersionedRowStore.java | 754 ++++++++++
.../org/apache/ignite/internal/table/Example.java | 39 +-
.../internal/table/InteropOperationsTest.java | 41 +-
.../table/KeyValueBinaryViewOperationsTest.java | 278 ++--
.../KeyValueViewOperationsSimpleSchemaTest.java | 25 +-
.../internal/table/KeyValueViewOperationsTest.java | 213 +--
.../table/RecordBinaryViewOperationsTest.java | 205 +--
.../internal/table/RecordViewOperationsTest.java | 155 +-
.../internal/table/SchemaValidationTest.java | 28 +-
.../ignite/internal/table/TableManagerTest.java | 16 +-
.../ignite/internal/table/TxAbstractTest.java | 1496 ++++++++++++++++++++
.../apache/ignite/internal/table/TxLocalTest.java | 91 ++
.../org/apache/ignite/internal/table/TxTest.java | 197 ---
.../raft/PartitionCommandListenerTest.java | 52 +-
.../table/impl/DummyInternalTableImpl.java | 357 ++---
.../table/impl/DummySchemaManagerImpl.java | 4 +-
modules/transactions/README.md | 174 ++-
modules/transactions/pom.xml | 152 +-
.../ignite/internal/tx/InternalTransaction.java | 74 +
.../apache/ignite/internal/tx/LockException.java | 2 +-
.../org/apache/ignite/internal/tx/LockManager.java | 17 +-
.../org/apache/ignite/internal/tx/Timestamp.java | 140 +-
.../org/apache/ignite/internal/tx/TxManager.java | 163 +++
.../org/apache/ignite/internal/tx/TxState.java} | 11 +-
.../java/org/apache/ignite/internal/tx/Waiter.java | 13 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 242 +++-
.../internal/tx/impl/IgniteTransactionsImpl.java | 100 ++
.../ignite/internal/tx/impl/TransactionImpl.java | 194 +++
.../ignite/internal/tx/impl/TxManagerImpl.java | 419 ++++++
.../internal/tx/message/TxFinishRequest.java} | 31 +-
.../internal/tx/message/TxFinishResponse.java} | 17 +-
.../internal/tx/message/TxMessageGroup.java} | 17 +-
.../internal/tx/AbstractLockManagerTest.java | 215 ++-
.../apache/ignite/internal/tx/TxManagerTest.java | 141 ++
parent/pom.xml | 6 +
143 files changed, 7461 insertions(+), 3464 deletions(-)
copy modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/StorageException.java => api/src/main/java/org/apache/ignite/tx/TransactionException.java} (64%)
delete mode 100644 modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItDistributedTableTest.java
create mode 100644 modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestSingleNode.java
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/VarlenNativeType.java => table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestSingleNodeCollocated.java} (51%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/VarlenNativeType.java => table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicas.java} (50%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/VarlenNativeType.java => table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicasCollocated.java} (51%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableTxManagerImpl.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/FinishTxCommand.java
copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/{DeleteExactAllCommand.java => MultiKeyCommand.java} (61%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/{DeleteCommand.java => SingleKeyCommand.java} (68%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SingleNode.java => table/src/main/java/org/apache/ignite/internal/table/distributed/command/TransactionalCommand.java} (65%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/VersionedRowStore.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/TxAbstractTest.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/TxLocalTest.java
delete mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/TxTest.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/InternalTransaction.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/TxManager.java
copy modules/{api/src/main/java/org/apache/ignite/binary/package-info.java => transactions/src/main/java/org/apache/ignite/internal/tx/TxState.java} (86%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/IgniteTransactionsImpl.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TransactionImpl.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java
copy modules/{raft/src/main/java/org/apache/ignite/raft/jraft/rpc/ActionRequest.java => transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishRequest.java} (58%)
copy modules/{raft/src/main/java/org/apache/ignite/raft/jraft/rpc/ActionResponse.java => transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishResponse.java} (66%)
copy modules/{raft/src/test/java/org/apache/ignite/raft/jraft/rpc/TestMessageGroup.java => transactions/src/main/java/org/apache/ignite/internal/tx/message/TxMessageGroup.java} (68%)
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/TxManagerTest.java