This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-20339
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from fc76424ff8 Styles.
add 41e09209ef IGNITE-20482 Simplify write intent resolution in
PartitionReplicaListener (#2625)
add f2fc9528fb IGNITE-19806 Port new log storage (PR #696) from
"sofa-jraft" (#2245)
add fa78192988 IGNITE-20480 Rename "org.apache.ignite.lang" in "core"
module. (#2621)
add e85139ff56 IGNITE-20336 Sql. Remove conversion from java types to
TypeSpec (#2615)
add d7970190a4 IGNITE-20467 Use replica message instead of directly using
raft client when building indexes (#2630)
add e003ec2743 Merge branch 'main' into ignite-20339
add 4d84190639 Minor after review.
No new revisions were added by this update.
Summary of changes:
build.gradle | 13 +
gradle/libs.versions.toml | 4 +
.../affinity/RendezvousAffinityFunction.java | 2 +-
.../org/apache/ignite/InitParametersBuilder.java | 5 +-
.../apache/ignite/lang/util/IgniteNameUtils.java | 2 +-
.../org/apache/ignite/lang/util/StringUtils.java | 73 ---
.../apache/ignite/lang/util/StringUtilsTest.java | 45 --
.../internal/binarytuple/BinaryTupleCommon.java | 2 +-
.../binarytuple/BinaryTupleFormatException.java | 2 +-
.../binarytuple/BinaryTupleCommonTest.java | 2 +-
.../internal/catalog/CatalogManagerImpl.java | 2 +-
.../catalog/CatalogParamsValidationUtils.java | 4 +-
.../catalog/CatalogValidationException.java | 4 +-
.../ignite/internal/catalog/ClockWaiter.java | 2 +-
.../commands/AbstractCreateIndexCommand.java | 2 +-
.../commands/AlterTableAddColumnCommand.java | 2 +-
.../commands/AlterTableAlterColumnCommand.java | 2 +-
.../commands/AlterTableDropColumnCommand.java | 2 +-
.../internal/catalog/commands/CatalogUtils.java | 2 +-
.../catalog/commands/CreateSystemViewCommand.java | 2 +-
.../catalog/commands/CreateTableCommand.java | 2 +-
.../catalog/commands/DropIndexCommand.java | 2 +-
.../ignite/internal/catalog/storage/UpdateLog.java | 2 +-
.../internal/catalog/storage/UpdateLogImpl.java | 6 +-
.../internal/catalog/CatalogManagerSelfTest.java | 4 +-
...AlterTableAlterColumnCommandValidationTest.java | 2 +-
.../catalog/storage/UpdateLogImplTest.java | 2 +-
.../internal/cli/call/connect/ConnectCall.java | 2 +-
.../cli/call/connect/ConnectionChecker.java | 2 +-
.../questions/ConnectToClusterQuestion.java | 2 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 2 +-
.../ignite/internal/cli/core/JdbcUrlFactory.java | 2 +-
.../internal/cli/core/rest/ApiClientFactory.java | 2 +-
.../ignite/internal/cli/logger/CliLoggers.java | 2 +-
.../resources/cli.java.util.logging.properties | 2 +-
.../resources/ignite.java.util.logging.properties | 2 +-
.../ignite/client/handler/ClientHandlerModule.java | 2 +-
.../handler/ClientInboundMessageHandler.java | 2 +-
.../client/handler/ClientResourceRegistry.java | 4 +-
.../client/handler/JdbcQueryCursorHandlerImpl.java | 2 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 6 +-
.../requests/sql/ClientSqlCursorCloseRequest.java | 2 +-
.../sql/ClientSqlCursorNextPageRequest.java | 2 +-
.../requests/sql/ClientSqlExecuteRequest.java | 4 +-
.../handler/requests/table/ClientTableCommon.java | 4 +-
.../ClientTablePartitionAssignmentGetRequest.java | 2 +-
.../requests/tx/ClientTransactionBeginRequest.java | 2 +-
.../tx/ClientTransactionCommitRequest.java | 2 +-
.../tx/ClientTransactionRollbackRequest.java | 2 +-
.../src/test/java/ClientResourceRegistryTest.java | 4 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 2 +-
.../org/apache/ignite/client/IgniteClient.java | 2 +-
.../ignite/client/IgniteClientConfiguration.java | 2 +-
.../ClientSchemaVersionMismatchException.java | 2 +-
.../apache/ignite/internal/client/ClientUtils.java | 2 +-
.../client/IgniteClientConfigurationImpl.java | 2 +-
.../ignite/internal/client/table/ClientTable.java | 2 +-
.../client/table/ClientTupleSerializer.java | 2 +-
.../apache/ignite/client/ClientLoggingTest.java | 2 +-
.../apache/ignite/client/ConsoleLoggerFactory.java | 2 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 2 +-
.../apache/ignite/client/TestLoggerFactory.java | 2 +-
.../ignite/client/fakes/FakeInternalTable.java | 2 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 2 +-
.../cluster/management/ItClusterManagerTest.java | 4 +-
.../management/raft/ItCmgRaftServiceTest.java | 4 +-
.../cluster/management/ClusterInitializer.java | 2 +-
.../management/ClusterManagementGroupManager.java | 4 +-
.../internal/cluster/management/InitException.java | 2 +-
.../cluster/management/InternalInitException.java | 2 +-
.../cluster/management/LocalStateStorage.java | 2 +-
.../network/CmgMessageHandlerFactory.java | 2 +-
.../management/raft/CmgRaftGroupListener.java | 2 +-
.../cluster/management/raft/CmgRaftService.java | 2 +-
.../raft/IllegalInitArgumentException.java | 2 +-
.../management/raft/JoinDeniedException.java | 2 +-
.../raft/RocksDbClusterStateStorage.java | 2 +-
.../management/raft/TestClusterStateStorage.java | 4 +-
.../metastore/DeploymentUnitStoreImpl.java | 2 +-
.../metastore/status/ClusterStatusKey.java | 2 +-
.../deployunit/metastore/status/NodeStatusKey.java | 2 +-
.../deployunit/metastore/status/UnitKey.java | 2 +-
.../internal/compute/ComputeComponentImpl.java | 4 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 2 +-
.../internal/compute/loader/JobContextManager.java | 2 +-
.../internal/compute/ComputeComponentImplTest.java | 2 +-
.../compute/loader/JobContextManagerTest.java | 2 +-
.../ComponentNotStartedException.java | 2 +-
.../configuration/ConfigurationChanger.java | 4 +-
.../validation/ConfigurationValidatorImpl.java | 2 +-
.../internal/causality/BaseVersionedValue.java | 2 +-
.../internal/causality/OutdatedTokenException.java | 4 +-
.../internal/components/LongJvmPauseDetector.java | 6 +-
.../DistributionZoneAlreadyExistsException.java | 2 +-
.../DistributionZoneBindTableException.java | 2 +-
.../DistributionZoneNotFoundException.java | 2 +-
.../ignite/{ => internal}/lang/ByteArray.java | 2 +-
.../ignite/{ => internal}/lang/IgniteBiTuple.java | 2 +-
.../{ => internal}/lang/IgniteExceptionMapper.java | 4 +-
.../lang/IgniteExceptionMapperUtil.java | 9 +-
.../lang/IgniteExceptionMappersProvider.java | 4 +-
.../lang/IgniteInternalCheckedException.java | 3 +-
.../lang/IgniteInternalException.java | 7 +-
.../{ => internal}/lang/IgnitePentaFunction.java | 2 +-
.../{ => internal}/lang/IgniteQuadFunction.java | 2 +-
.../{ => internal}/lang/IgniteStringBuilder.java | 2 +-
.../{ => internal}/lang/IgniteStringFormatter.java | 2 +-
.../lang/IgniteSystemProperties.java | 2 +-
.../{ => internal}/lang/IgniteTriConsumer.java | 2 +-
.../{ => internal}/lang/IgniteTriFunction.java | 2 +-
.../ignite/{ => internal}/lang/IgniteTuple3.java | 2 +-
.../ignite/{ => internal}/lang/IgniteUuid.java | 2 +-
.../{ => internal}/lang/IgniteUuidGenerator.java | 2 +-
.../{ => internal}/lang/JavaLoggerFormatter.java | 2 +-
.../ignite/{ => internal}/lang/LoggerFactory.java | 2 +-
.../{ => internal}/lang/NodeStoppingException.java | 2 +-
.../{ => internal}/lang/RemoteException.java | 4 +-
.../ignite/{ => internal}/lang/package-info.java | 2 +-
.../ignite/internal/logger/IgniteLogger.java | 2 +-
.../org/apache/ignite/internal/logger/Loggers.java | 2 +-
.../internal/properties/IgniteProductVersion.java | 2 +-
.../internal/properties/IgniteProperties.java | 2 +-
.../internal/tostring/IgniteToStringBuilder.java | 18 +-
.../internal/tostring/IgniteToStringInclude.java | 2 +-
.../tostring/StringBuilderLimitedLength.java | 6 +-
.../apache/ignite/internal/util/ArrayUtils.java | 2 +-
.../org/apache/ignite/internal/util/ByteUtils.java | 2 +-
.../org/apache/ignite/internal/util/Cursor.java | 2 +-
.../ignite/internal/util/ExceptionUtils.java | 8 +-
.../ignite/internal/util/HashCalculator.java | 2 +-
.../util/IgniteConcurrentMultiPairQueue.java | 2 +-
.../apache/ignite/internal/util/IgniteUtils.java | 60 ++-
.../ignite/internal/util/OffheapReadWriteLock.java | 6 +-
.../util/PendingComparableValuesTracker.java | 2 +-
.../util/{HexStringUtils.java => StringUtils.java} | 52 +-
.../util/subscription/AccumulateException.java | 2 +-
.../causality/IncrementalVersionedValueTest.java | 2 +-
.../ignite/{ => internal}/lang/ErrorGroupTest.java | 8 +-
.../{ => internal}/lang/ExceptionUtilsTest.java | 4 +-
.../lang/IgniteExceptionMapperUtilTest.java | 19 +-
.../{ => internal}/lang/IgniteExceptionTest.java | 5 +-
.../{ => internal}/lang/LoggerHelperTest.java | 2 +-
.../lang/TestIgniteExceptionMappersProvider.java | 12 +-
.../tostring/IgniteToStringBuilderSelfTest.java | 8 +-
.../tostring/SensitiveDataToStringTest.java | 4 +-
.../util/IgniteConcurrentMultiPairQueueTest.java | 2 +-
.../ignite/internal/util/IgniteUtilsTest.java | 15 +
...exStringUtilsTest.java => StringUtilsTest.java} | 26 +-
.../testframework/BaseIgniteAbstractTest.java | 4 +-
.../internal/testframework/IgniteTestUtils.java | 4 +-
.../testframework/IntegrationTestBase.java | 2 +-
.../testframework/WorkDirectoryExtension.java | 2 +-
.../distributionzones/DistributionZoneManager.java | 8 +-
.../distributionzones/DistributionZonesUtil.java | 2 +-
.../CausalityDataNodesEngine.java | 2 +-
.../DistributionZoneWasRemovedException.java | 2 +-
.../distributionzones/rebalance/RebalanceUtil.java | 2 +-
.../DistributionZonesSchedulersTest.java | 2 +-
.../DistributionZoneCausalityDataNodesTest.java | 2 +-
.../DistributionZoneRebalanceEngineTest.java | 4 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 2 +-
.../DistributionZonesTestUtil.java | 2 +-
.../apache/ignite/internal/index/IndexManager.java | 4 +-
.../internal/marshaller/MarshallerException.java | 2 +-
.../apache/ignite/internal/util/ObjectFactory.java | 2 +-
.../internal/metastorage/MetaStorageManager.java | 4 +-
.../internal/metastorage/dsl/Conditions.java | 2 +-
.../internal/metastorage/dsl/Operations.java | 2 +-
.../exceptions/MetaStorageException.java | 2 +-
.../impl/ItMetaStorageManagerImplTest.java | 2 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 4 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 2 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 4 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 4 +-
.../server/raft/ItMetaStorageRaftGroupTest.java | 2 +-
.../metastorage/command/GetAllCommand.java | 2 +-
.../internal/metastorage/impl/CursorPublisher.java | 2 +-
.../metastorage/impl/CursorSubscription.java | 2 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 4 +-
.../metastorage/impl/MetaStorageService.java | 2 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 2 +-
.../server/raft/MetaStorageWriteHandler.java | 2 +-
.../metastorage/server/time/ClusterTimeImpl.java | 2 +-
.../metastorage/impl/CursorPublisherTest.java | 2 +-
.../metastorage/impl/MetaStorageRangeTest.java | 2 +-
.../server/BasicOperationsKeyValueStorageTest.java | 2 +-
.../impl/StandaloneMetaStorageManager.java | 2 +-
.../ignite/internal/metrics/MetricManager.java | 2 +-
.../ignite/internal/metrics/MetricProvider.java | 2 +-
.../ignite/internal/metrics/MetricRegistry.java | 2 +-
.../metrics/exporters/BasicMetricExporter.java | 2 +-
.../ignite/internal/metrics/JmxExporterTest.java | 2 +-
.../internal/metrics/MetricEntitiesTest.java | 2 +-
.../messages/MarshallableTypesBlackList.java | 2 +-
.../serialization/BaseMethodNameResolver.java | 2 +-
.../MessageCollectionItemTypeConverter.java | 2 +-
.../serialization/marshal/MarshalException.java | 2 +-
.../serialization/marshal/UnmarshalException.java | 2 +-
.../ignite/network/annotations/Transferable.java | 2 +-
.../network/serialization/MessageReader.java | 2 +-
.../network/serialization/MessageWriter.java | 2 +-
.../network/netty/ItConnectionManagerTest.java | 2 +-
.../network/scalecube/ItClusterServiceTest.java | 2 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 4 +-
.../SslConfigurationValidatorImpl.java | 2 +-
.../network/direct/DirectMessageReader.java | 2 +-
.../network/direct/DirectMessageWriter.java | 2 +-
.../direct/stream/DirectByteBufferStream.java | 2 +-
.../stream/DirectByteBufferStreamImplV1.java | 2 +-
.../internal/network/netty/ConnectionManager.java | 4 +-
.../ignite/internal/network/netty/NettyClient.java | 2 +-
.../ignite/internal/network/netty/NettyServer.java | 2 +-
.../internal/network/recovery/VaultStateIds.java | 2 +-
.../network/serialization/BuiltInType.java | 2 +-
.../network/serialization/ReflectionException.java | 2 +-
.../network/serialization/SerializationType.java | 2 +-
.../SpecialMethodInvocationException.java | 2 +-
.../serialization/marshal/BuiltInMarshalling.java | 2 +-
.../marshal/InstantiationException.java | 2 +-
.../ignite/network/DefaultMessagingService.java | 2 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 2 +-
.../ScaleCubeDirectMarshallerTransport.java | 2 +-
.../internal/network/AllTypesMessageGenerator.java | 4 +-
.../internal/network/netty/NettyClientTest.java | 2 +-
.../internal/network/netty/NettyServerTest.java | 2 +-
.../network/recovery/VaultStateIdsTest.java | 2 +-
...efaultUserObjectMarshallerWithBuiltinsTest.java | 2 +-
.../network/processor/AllTypesMessage.java | 2 +-
.../internal/network/messages/AllTypesMessage.java | 2 +-
.../tree/AbstractBplusTreePageMemoryTest.java | 6 +-
.../tree/AbstractBplusTreeReusePageMemoryTest.java | 2 +-
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 4 +-
.../CorruptedDataStructureException.java | 2 +-
.../ignite/internal/pagememory/FullPageId.java | 2 +-
.../internal/pagememory/PageIdAllocator.java | 2 +-
.../ignite/internal/pagememory/PageMemory.java | 2 +-
.../ignite/internal/pagememory/PageSupport.java | 2 +-
.../ignite/internal/pagememory/Storable.java | 2 +-
.../pagememory/datapage/DataPageReader.java | 2 +-
.../datapage/NonFragmentableDataPageReader.java | 2 +-
.../pagememory/datastructure/DataStructure.java | 7 +-
.../pagememory/evict/PageEvictionTracker.java | 2 +-
.../pagememory/freelist/AbstractFreeList.java | 2 +-
.../internal/pagememory/freelist/FreeList.java | 2 +-
.../internal/pagememory/freelist/PagesList.java | 8 +-
.../pagememory/freelist/io/PagesListMetaIo.java | 2 +-
.../pagememory/freelist/io/PagesListNodeIo.java | 2 +-
.../pagememory/inmemory/VolatilePageMemory.java | 8 +-
.../internal/pagememory/io/AbstractDataPageIo.java | 4 +-
.../ignite/internal/pagememory/io/PageIo.java | 4 +-
.../internal/pagememory/io/PageIoRegistry.java | 2 +-
.../pagememory/mem/IgniteOutOfMemoryException.java | 2 +-
.../pagememory/mem/unsafe/UnsafeChunk.java | 4 +-
.../mem/unsafe/UnsafeMemoryProvider.java | 2 +-
...iteInternalDataIntegrityViolationException.java | 2 +-
.../internal/pagememory/persistence/PagePool.java | 2 +-
.../persistence/PageReadWriteManager.java | 2 +-
.../pagememory/persistence/PageStoreWriter.java | 2 +-
.../persistence/PartitionMetaManager.java | 2 +-
.../persistence/PersistentPageMemory.java | 8 +-
.../pagememory/persistence/ReplaceCandidate.java | 2 +-
.../persistence/RobinHoodBackwardShiftHashMap.java | 2 +-
.../pagememory/persistence/WriteDirtyPage.java | 2 +-
.../checkpoint/CheckpointDirtyPages.java | 2 +-
.../persistence/checkpoint/CheckpointListener.java | 2 +-
.../persistence/checkpoint/CheckpointManager.java | 2 +-
.../persistence/checkpoint/CheckpointPages.java | 2 +-
.../checkpoint/CheckpointPagesWriter.java | 4 +-
.../CheckpointReadLockTimeoutException.java | 2 +-
.../checkpoint/CheckpointReadWriteLock.java | 2 +-
.../checkpoint/CheckpointTimeoutLock.java | 4 +-
.../persistence/checkpoint/CheckpointWorkflow.java | 4 +-
.../persistence/checkpoint/Checkpointer.java | 8 +-
.../ReentrantReadWriteLockWithTracking.java | 4 +-
.../persistence/compaction/Compactor.java | 2 +-
.../pagememory/persistence/io/PartitionMetaIo.java | 2 +-
.../replacement/ClockPageReplacementPolicy.java | 2 +-
.../replacement/DelayedDirtyPageWrite.java | 2 +-
.../replacement/PageReplacementPolicy.java | 2 +-
.../RandomLruPageReplacementPolicy.java | 2 +-
.../SegmentedLruPageReplacementPolicy.java | 2 +-
.../persistence/store/AbstractFilePageStoreIo.java | 10 +-
.../persistence/store/DeltaFilePageStoreIo.java | 2 +-
.../store/DeltaFilePageStoreIoHeader.java | 2 +-
.../persistence/store/FilePageStore.java | 2 +-
.../persistence/store/FilePageStoreFactory.java | 2 +-
.../persistence/store/FilePageStoreHeader.java | 2 +-
.../persistence/store/FilePageStoreIo.java | 2 +-
.../persistence/store/FilePageStoreManager.java | 6 +-
.../pagememory/persistence/store/PageStore.java | 2 +-
.../internal/pagememory/reuse/ReuseList.java | 2 +-
.../internal/pagememory/reuse/ReuseListImpl.java | 2 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 12 +-
.../pagememory/tree/BplusTreeRuntimeException.java | 2 +-
.../pagememory/tree/CorruptedTreeException.java | 2 +-
.../internal/pagememory/tree/IgniteTree.java | 2 +-
.../internal/pagememory/tree/io/BplusInnerIo.java | 2 +-
.../internal/pagememory/tree/io/BplusIo.java | 4 +-
.../internal/pagememory/tree/io/BplusMetaIo.java | 2 +-
.../internal/pagememory/util/PageHandler.java | 2 +-
.../internal/pagememory/util/PageIdUtils.java | 4 +-
.../AbstractPageMemoryNoLoadSelfTest.java | 2 +-
.../internal/pagememory/PageIoRegistryTest.java | 2 +-
.../pagememory/freelist/AbstractFreeListTest.java | 2 +-
.../pagememory/freelist/TestDataPageIo.java | 2 +-
.../checkpoint/CheckpointDirtyPagesTest.java | 2 +-
.../checkpoint/CheckpointPagesTest.java | 2 +-
.../checkpoint/CheckpointPagesWriterTest.java | 2 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 4 +-
.../checkpoint/CheckpointWorkflowTest.java | 2 +-
.../persistence/checkpoint/CheckpointerTest.java | 2 +-
.../ReentrantReadWriteLockWithTrackingTest.java | 2 +-
.../store/FilePageStoreFactoryTest.java | 2 +-
.../store/FilePageStoreManagerTest.java | 2 +-
.../store/LongOperationAsyncExecutorTest.java | 2 +-
.../internal/pagememory/util/PageIdUtilsTest.java | 6 +-
.../internal/pagememory/TestPageIoModule.java | 2 +-
.../placementdriver/BasePlacementDriverTest.java | 2 +-
.../MultiActorPlacementDriverTest.java | 2 +-
.../PlacementDriverManagerTest.java | 2 +-
.../placementdriver/AssignmentsTracker.java | 4 +-
.../internal/placementdriver/LeaseUpdater.java | 4 +-
.../placementdriver/PlacementDriverManager.java | 4 +-
.../placementdriver/PlacementDriverTest.java | 2 +-
.../apache/ignite/internal/raft/RaftManager.java | 2 +-
modules/raft/build.gradle | 1 +
.../ignite/internal/raft/ItLearnersTest.java | 2 +-
.../internal/raft/ItRaftGroupServiceTest.java | 2 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 2 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 11 +-
.../raft/server/ItJraftCounterServerTest.java | 2 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 6 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 2 +-
.../internal/raft/server/impl/JraftServerImpl.java | 4 +-
.../storage/impl/VolatileLogStorageFactory.java | 2 +-
.../impl/VolatileLogStorageFactoryCreator.java | 2 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 2 +-
.../raft/jraft/disruptor/StripedDisruptor.java | 2 +-
.../raft/jraft/entity/LocalFileMetaOutter.java | 31 +-
.../ignite/raft/jraft/rpc/impl/RaftException.java | 2 +-
.../jraft/storage/impl/LogStorageException.java | 2 +-
.../ignite/raft/jraft/storage/logit/LibC.java | 59 +++
.../storage/logit/LogitLogStorageFactory.java | 70 +++
.../jraft/storage/logit/option/StoreOptions.java | 120 +++++
.../raft/jraft/storage/logit}/package-info.java | 4 +-
.../storage/logit/storage/LogitLogStorage.java | 554 ++++++++++++++++++++
.../jraft/storage/logit/storage/db/AbstractDB.java | 415 +++++++++++++++
.../jraft/storage/logit/storage/db/ConfDB.java} | 23 +-
.../jraft/storage/logit/storage/db/IndexDB.java | 147 ++++++
.../storage/logit/storage/db/SegmentLogDB.java} | 23 +-
.../logit/storage/factory/LogStoreFactory.java | 100 ++++
.../storage/logit/storage/file/AbstractFile.java | 523 +++++++++++++++++++
.../storage/logit/storage/file/FileHeader.java | 112 ++++
.../storage/logit/storage/file/FileManager.java | 577 +++++++++++++++++++++
.../storage/logit/storage/file/FileType.java} | 28 +-
.../logit/storage/file/assit/AbortFile.java | 73 +++
.../logit/storage/file/assit/Checkpoint.java | 80 +++
.../file/assit/FirstLogIndexCheckpoint.java | 68 +++
.../storage/file/assit/FlushStatusCheckpoint.java | 81 +++
.../logit/storage/file/index/IndexFile.java | 280 ++++++++++
.../logit/storage/file/index/IndexType.java} | 21 +-
.../logit/storage/file/segment/SegmentFile.java | 209 ++++++++
.../logit/storage/service/AllocateFileService.java | 157 ++++++
.../logit/storage/service/ServiceManager.java | 79 +++
.../raft/jraft/storage/logit/util/Pair.java} | 44 +-
.../logit/util/concurrent/ReferenceResource.java | 84 +++
.../logit/util/concurrent/ShutdownAbleThread.java | 82 +++
.../snapshot/local/LocalSnapshotWriter.java | 5 +-
.../apache/ignite/raft/jraft/util/Platform.java | 19 +
.../ignite/disruptor/StripedDisruptorTest.java | 2 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 4 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 2 +-
.../jraft/storage/impl/BaseLogStorageTest.java | 20 +-
.../raft/jraft/storage/io/MessageFileTest.java | 12 +-
.../jraft/storage/logit/BaseLogitStorageTest.java | 77 +++
.../jraft/storage/logit/LogitLogStorageTest.java | 126 +++++
.../raft/jraft/storage/logit/db/ConfDBTest.java | 117 +++++
.../raft/jraft/storage/logit/db/IndexDBTest.java | 154 ++++++
.../jraft/storage/logit/db/SegmentLogDBTest.java | 121 +++++
.../jraft/storage/logit/file/FileManagerTest.java | 136 +++++
.../storage/logit/file/index/IndexFileTest.java | 135 +++++
.../logit/file/segment/SegmentFileTest.java | 125 +++++
.../snapshot/local/LocalSnapshotMetaTableTest.java | 10 +-
.../snapshot/local/LocalSnapshotWriterTest.java | 6 +-
.../snapshot/local/SnapshotFileReaderTest.java | 2 +-
.../apache/ignite/raft/jraft/test/TestUtils.java | 14 +-
.../ItPlacementDriverReplicaSideTest.java | 4 +-
.../raft/client/TopologyAwareRaftGroupService.java | 2 +-
.../apache/ignite/internal/replicator/Replica.java | 2 +-
.../ignite/internal/replicator/ReplicaManager.java | 2 +-
.../ignite/internal/replicator/ReplicaService.java | 4 +-
.../exception/PrimaryReplicaMissException.java | 44 +-
.../ReplicaIsAlreadyStartedException.java | 4 +-
.../replicator/exception/ReplicationException.java | 2 +-
.../exception/ReplicationTimeoutException.java | 2 +-
.../UnsupportedReplicaRequestException.java | 4 +-
.../internal/rest/api/cluster/InitCommand.java | 2 +-
.../apache/ignite/internal/rest/RestComponent.java | 2 +-
.../rest/cluster/ClusterManagementController.java | 2 +-
.../IgniteInternalCheckedExceptionHandler.java | 2 +-
.../handler/IgniteInternalExceptionHandler.java | 2 +-
.../apache/ignite/internal/rocksdb/RocksUtils.java | 2 +-
.../rocksdb/snapshot/RocksSnapshotManager.java | 2 +-
.../ignite/internal/BaseIgniteRestartTest.java | 4 +-
.../ignite/internal/benchmark/InsertBenchmark.java | 2 +-
.../zones/ItDistributionZonesFilterTest.java | 2 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 6 +-
.../rebalance/ItRebalanceDistributedTest.java | 4 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 6 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 4 +-
.../internal/runner/app/ItTablesApiTest.java | 2 +-
.../sql/engine/ClusterPerClassIntegrationTest.java | 2 +-
.../internal/sql/engine/ItBuildIndexTest.java | 18 +-
.../internal/sql/engine/ItDataTypesTest.java | 2 +-
.../sql/engine/ItDynamicParameterTest.java | 2 +-
.../internal/sql/engine/ItFunctionsTest.java | 2 +-
.../internal/sql/engine/ItImplicitCastsTest.java | 2 +-
.../ignite/internal/sql/engine/ItIntervalTest.java | 2 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 2 +-
.../sql/engine/datatypes/DataTypeTestSpecs.java | 2 +-
.../datatypes/tests/BaseAggregateDataTypeTest.java | 2 +-
.../engine/datatypes/tests/BaseDataTypeTest.java | 2 +-
.../datatypes/tests/BaseDmlDataTypeTest.java | 2 +-
.../tests/BaseExpressionDataTypeTest.java | 2 +-
.../datatypes/tests/BaseIndexDataTypeTest.java | 2 +-
.../datatypes/tests/BaseJoinDataTypeTest.java | 2 +-
.../datatypes/tests/BaseQueryDataTypeTest.java | 2 +-
.../engine/datatypes/tests/TestDataSamples.java | 2 +-
.../datatypes/tests/TestTypeArgumentsTest.java | 2 +-
.../sql/engine/datatypes/uuid/ItUuidDmlTest.java | 2 +-
.../datatypes/uuid/ItUuidExpressionTest.java | 2 +-
.../sql/engine/datatypes/uuid/ItUuidQueryTest.java | 2 +-
.../datatypes/varbinary/ItVarBinaryIndexTest.java | 8 +-
.../datatypes/varbinary/ItVarBinaryQueryTest.java | 2 +-
.../ignite/internal/sqllogic/ItSqlLogicTest.java | 4 +-
.../org/apache/ignite/internal/sqllogic/Query.java | 4 +-
.../internal/table/ItReadOnlyTransactionTest.java | 2 +-
.../ignite/internal/table/ItRoReadsTest.java | 2 +-
.../ignite/internal/table/ItTableScanTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 4 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 2 +-
.../ignite/internal/app/LifecycleManager.java | 2 +-
.../storage/DistributedConfigurationStorage.java | 2 +-
.../storage/LocalConfigurationStorage.java | 4 +-
.../DistributedConfigurationStorageTest.java | 2 +-
.../java/org/apache/ignite/internal/Cluster.java | 2 +-
.../ignite/internal/schema/AssemblyException.java | 2 +-
.../internal/schema/CatalogSchemaManager.java | 8 +-
.../ignite/internal/schema/SchemaException.java | 2 +-
.../configuration/ValueSerializationHelper.java | 10 +-
.../marshaller/asm/AsmMarshallerGenerator.java | 2 +-
.../marshaller/asm/ColumnAccessCodeGenerator.java | 2 +-
.../SchemaRegistrationConflictException.java | 2 +-
.../apache/ignite/internal/util/ObjectFactory.java | 2 +-
.../internal/schema/CatalogSchemaManagerTest.java | 2 +-
.../AuthenticationProvidersValidatorImpl.java | 2 +-
.../ignite/internal/sql/api/SessionImpl.java | 4 +-
.../internal/sql/engine/AsyncSqlCursorImpl.java | 2 +-
.../ignite/internal/sql/engine/QueryCancel.java | 2 +-
.../internal/sql/engine/SqlQueryProcessor.java | 6 +-
.../sql/engine/exec/AbstractIndexScan.java | 2 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 4 +-
.../internal/sql/engine/exec/ExecutionContext.java | 2 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 8 +-
.../internal/sql/engine/exec/SqlRowHandler.java | 2 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 2 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 2 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 2 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 4 +-
.../internal/sql/engine/exec/rel/Outbox.java | 4 +-
.../internal/sql/engine/externalize/RelJson.java | 2 +-
.../sql/engine/externalize/RelJsonReader.java | 2 +-
.../sql/engine/externalize/RelJsonWriter.java | 2 +-
.../sql/engine/metadata/FragmentMapping.java | 2 +-
.../metadata/RemoteFragmentExecutionException.java | 2 +-
.../internal/sql/engine/prepare/IgnitePlanner.java | 2 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 2 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 2 +-
.../internal/sql/engine/property/BuilderImpl.java | 2 +-
.../sql/engine/property/PropertiesHolderImpl.java | 2 +-
.../engine/property/PropertyNotFoundException.java | 2 +-
.../sql/engine/rel/agg/MapReduceAggregates.java | 2 +-
.../internal/sql/engine/session/Session.java | 2 +-
.../engine/session/SessionNotFoundException.java | 4 +-
.../internal/sql/engine/sql/IgniteSqlParser.java | 4 +-
.../internal/sql/engine/trait/TraitUtils.java | 4 +-
.../engine/type/IgniteCustomTypeCoercionRules.java | 2 +-
.../ignite/internal/sql/engine/util/Commons.java | 4 +-
.../engine/util/SqlExceptionMapperProvider.java | 6 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 67 +--
.../sql/engine/exec/ExecutionServiceImplTest.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 28 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 42 +-
.../sql/engine/exec/rel/ExecutionTest.java | 74 ++-
.../rel/HashAggregateSingleGroupExecutionTest.java | 54 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 11 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 23 +-
.../exec/rel/NestedLoopJoinExecutionTest.java | 30 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 2 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 7 +-
.../exec/rel/TableScanNodeExecutionTest.java | 11 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 4 +-
.../sql/engine/exec/row/RowSchemaTypesTest.java | 2 +-
.../sql/engine/framework/NoOpTransaction.java | 2 +-
.../sql/engine/framework/TestBuilders.java | 2 +-
.../internal/sql/engine/framework/TestIndex.java | 2 +-
.../internal/sql/engine/framework/TestTable.java | 2 +-
.../sql/engine/planner/AbstractPlannerTest.java | 2 +-
.../sql/engine/planner/ImplicitCastsTest.java | 2 +-
.../planner/IndexSearchBoundsPlannerTest.java | 2 +-
.../sql/engine/planner/JoinCommutePlannerTest.java | 2 +-
.../planner/datatypes/BaseTypeCoercionTest.java | 2 +-
.../DistributionZoneSqlToCommandConverterTest.java | 2 +-
.../engine/sql/IgniteSqlDecimalLiteralTest.java | 2 +-
.../engine/sql/SqlAlterColumnDdlParserTest.java | 2 +-
.../sql/engine/sql/SqlLiteralArchTest.java | 2 +-
.../sql/engine/sql/SqlReservedWordsTest.java | 2 +-
.../internal/sql/engine/util/StatementChecker.java | 2 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 2 +-
.../sql/engine/util/QueryCheckerExtension.java | 2 +-
.../ignite/internal/storage/StorageException.java | 4 +-
.../storage/StorageRebalanceException.java | 2 +-
.../storage/index/BinaryTupleComparator.java | 2 +-
.../internal/storage/util/MvPartitionStorages.java | 2 +-
.../ignite/internal/storage/util/StorageUtils.java | 4 +-
.../storage/index/BinaryTupleComparatorTest.java | 2 +-
.../storage/AbstractMvPartitionStorageTest.java | 2 +-
.../storage/AbstractMvTableStorageTest.java | 2 +-
.../internal/storage/BaseMvStoragesTest.java | 2 +-
.../PersistentPageMemoryStorageEngine.java | 2 +-
.../PersistentPageMemoryTableStorage.java | 4 +-
.../pagememory/VolatilePageMemoryDataRegion.java | 2 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 2 +-
.../index/AbstractPageMemoryIndexStorage.java | 4 +-
.../pagememory/index/freelist/IndexColumns.java | 2 +-
.../index/freelist/IndexColumnsFreeList.java | 2 +-
.../index/freelist/io/IndexColumnsDataIo.java | 2 +-
.../pagememory/index/hash/HashIndexTree.java | 2 +-
.../hash/InsertHashIndexRowInvokeClosure.java | 2 +-
.../index/hash/PageMemoryHashIndexStorage.java | 2 +-
.../hash/RemoveHashIndexRowInvokeClosure.java | 2 +-
.../index/hash/io/HashIndexTreeInnerIo.java | 2 +-
.../pagememory/index/hash/io/HashIndexTreeIo.java | 2 +-
.../index/hash/io/HashIndexTreeLeafIo.java | 4 +-
.../storage/pagememory/index/meta/IndexMeta.java | 4 +-
.../pagememory/index/meta/IndexMetaTree.java | 2 +-
.../UpdateLastRowIdUuidToBuiltInvokeClosure.java | 2 +-
.../sorted/InsertSortedIndexRowInvokeClosure.java | 2 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 2 +-
.../sorted/RemoveSortedIndexRowInvokeClosure.java | 2 +-
.../pagememory/index/sorted/SortedIndexTree.java | 2 +-
.../index/sorted/io/SortedIndexTreeInnerIo.java | 2 +-
.../index/sorted/io/SortedIndexTreeIo.java | 2 +-
.../index/sorted/io/SortedIndexTreeLeafIo.java | 4 +-
.../pagememory/mv/AbortWriteInvokeClosure.java | 2 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 4 +-
.../mv/AbstractPartitionTimestampCursor.java | 2 +-
.../mv/AddWriteCommittedInvokeClosure.java | 2 +-
.../pagememory/mv/AddWriteInvokeClosure.java | 2 +-
.../storage/pagememory/mv/BlobStorage.java | 2 +-
.../pagememory/mv/CommitWriteInvokeClosure.java | 2 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 2 +-
.../mv/RemoveWriteOnGcInvokeClosure.java | 2 +-
.../storage/pagememory/mv/RowVersionFreeList.java | 2 +-
.../storage/pagememory/mv/VersionChainTree.java | 2 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 4 +-
.../internal/storage/pagememory/mv/gc/GcQueue.java | 2 +-
.../storage/pagememory/mv/io/BlobFragmentIo.java | 2 +-
.../storage/pagememory/mv/io/RowVersionDataIo.java | 2 +-
.../VolatilePageMemoryMvTableStorageTest.java | 2 +-
.../storage/rocksdb/ColumnFamilyUtils.java | 2 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 2 +-
.../rocksdb/index/AbstractRocksDbIndexStorage.java | 2 +-
.../rocksdb/instance/SharedRocksDbInstance.java | 2 +-
.../instance/SharedRocksDbInstanceCreator.java | 2 +-
.../ignite/internal/systemview/NodeSystemView.java | 2 +-
.../ignite/internal/systemview/SystemView.java | 2 +-
.../internal/systemview/SystemViewColumn.java | 2 +-
.../ItInternalTableReadWriteScanTest.java | 2 +-
.../ignite/distributed/ItTablePersistenceTest.java | 12 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 2 +-
.../ignite/internal/table/ItColocationTest.java | 4 +-
.../marshaller/TupleMarshallerException.java | 2 +-
.../ignite/internal/table/AbstractTableView.java | 2 +-
.../internal/table/IgniteTablesInternal.java | 2 +-
.../ignite/internal/table/InternalTable.java | 3 +-
.../internal/table/KeyValueBinaryViewImpl.java | 2 +-
.../ignite/internal/table/KeyValueViewImpl.java | 2 +-
.../internal/table/RecordBinaryViewImpl.java | 2 +-
.../ignite/internal/table/RecordViewImpl.java | 2 +-
.../apache/ignite/internal/table/TableImpl.java | 2 +-
.../internal/table/distributed/LowWatermark.java | 4 +-
.../internal/table/distributed/PartitionMover.java | 4 +-
.../table/distributed/StorageUpdateHandler.java | 105 ++--
.../internal/table/distributed/TableManager.java | 12 +-
.../table/distributed/TableMessageGroup.java | 6 +
.../distributed/command/BuildIndexCommand.java | 21 +-
.../ignite/internal/table/distributed/gc/MvGc.java | 2 +-
.../table/distributed/index/IndexBuildTask.java | 48 +-
.../table/distributed/index/IndexBuilder.java | 49 +-
.../distributed/raft/PartitionDataStorage.java | 8 +-
.../table/distributed/raft/PartitionListener.java | 6 +-
.../raft/RebalanceRaftGroupEventsListener.java | 2 +-
.../distributed/raft/snapshot/PartitionAccess.java | 2 +-
.../raft/snapshot/PartitionAccessImpl.java | 4 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 2 +-
.../SnapshotAwarePartitionDataStorage.java | 10 +
.../request/BuildIndexReplicaRequest.java} | 29 +-
.../replicator/PartitionReplicaListener.java | 169 +++---
.../replicator/TransactionStateResolver.java | 2 +-
.../distributed/storage/InternalTableImpl.java | 10 +-
.../ignite/internal/utils/RebalanceUtil.java | 2 +-
.../RepeatedFinishReadWriteTransactionTest.java | 2 +-
.../internal/table/distributed/IndexBaseTest.java | 9 +-
.../table/distributed/LowWatermarkTest.java | 2 +-
.../table/distributed/PartitionMoverTest.java | 2 +-
.../distributed/StorageUpdateHandlerTest.java | 10 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../gc/AbstractGcUpdateHandlerTest.java | 4 +-
.../internal/table/distributed/gc/MvGcTest.java | 2 +-
.../PersistentPageMemoryGcUpdateHandlerTest.java | 2 +-
.../distributed/gc/RocksDbGcUpdateHandlerTest.java | 2 +-
.../distributed/gc/TestGcUpdateHandlerTest.java | 2 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 2 +-
.../raft/PartitionCommandListenerTest.java | 33 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 2 +-
.../PartitionReplicaListenerIndexLockingTest.java | 2 +-
.../replication/PartitionReplicaListenerTest.java | 4 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../distributed/TestPartitionDataStorage.java | 23 +-
.../table/impl/DummyInternalTableImpl.java | 6 +-
.../ignite/internal/tx/InternalTransaction.java | 2 +-
.../tx/TransactionInternalCheckedException.java | 2 +-
.../org/apache/ignite/internal/tx/TxManager.java | 4 +-
.../org/apache/ignite/internal/tx/TxState.java | 6 +
.../ignite/internal/tx/impl/HeapLockManager.java | 2 +-
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 2 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 2 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 10 +-
.../tx/message/TxFinishReplicaRequest.java | 2 +-
.../internal/tx/storage/state/TxStateStorage.java | 4 +-
.../tx/storage/state/TxStateTableStorage.java | 2 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 6 +-
.../state/rocksdb/TxStateRocksDbTableStorage.java | 2 +-
.../internal/tx/AbstractLockManagerTest.java | 2 +-
.../ignite/internal/tx/AbstractLockingTest.java | 2 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 4 +-
.../state/rocksdb/RocksDbTxStateStorageTest.java | 2 +-
.../storage/state/AbstractTxStateStorageTest.java | 4 +-
.../tx/storage/state/test/TestTxStateStorage.java | 4 +-
.../apache/ignite/internal/vault/VaultEntry.java | 2 +-
.../apache/ignite/internal/vault/VaultManager.java | 2 +-
.../apache/ignite/internal/vault/VaultService.java | 2 +-
.../vault/persistence/PersistentVaultService.java | 4 +-
.../ignite/internal/vault/VaultServiceTest.java | 2 +-
.../ItPersistencePropertiesVaultServiceTest.java | 2 +-
.../vault/inmemory/InMemoryVaultService.java | 2 +-
658 files changed, 6500 insertions(+), 1462 deletions(-)
delete mode 100644
modules/api/src/main/java/org/apache/ignite/lang/util/StringUtils.java
delete mode 100644
modules/api/src/test/java/org/apache/ignite/lang/util/StringUtilsTest.java
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/ByteArray.java (98%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteBiTuple.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteExceptionMapper.java (96%)
mode change 100755 => 100644
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteExceptionMapperUtil.java (94%)
mode change 100755 => 100644
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteExceptionMappersProvider.java (94%)
mode change 100755 => 100644
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteInternalCheckedException.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteInternalException.java (98%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgnitePentaFunction.java (97%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteQuadFunction.java (97%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteStringBuilder.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteStringFormatter.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteSystemProperties.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteTriConsumer.java (98%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteTriFunction.java (97%)
mode change 100755 => 100644
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteTuple3.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteUuid.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/IgniteUuidGenerator.java (98%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/JavaLoggerFormatter.java (99%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/LoggerFactory.java (96%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/NodeStoppingException.java (98%)
rename modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/RemoteException.java (94%)
copy modules/core/src/main/java/org/apache/ignite/{ =>
internal}/lang/package-info.java (95%)
rename
modules/core/src/main/java/org/apache/ignite/internal/util/{HexStringUtils.java
=> StringUtils.java} (72%)
rename modules/core/src/test/java/org/apache/ignite/{ =>
internal}/lang/ErrorGroupTest.java (93%)
rename modules/core/src/test/java/org/apache/ignite/{ =>
internal}/lang/ExceptionUtilsTest.java (98%)
mode change 100755 => 100644
rename modules/core/src/test/java/org/apache/ignite/{ =>
internal}/lang/IgniteExceptionMapperUtilTest.java (91%)
mode change 100755 => 100644
rename modules/core/src/test/java/org/apache/ignite/{ =>
internal}/lang/IgniteExceptionTest.java (97%)
rename modules/core/src/test/java/org/apache/ignite/{ =>
internal}/lang/LoggerHelperTest.java (99%)
rename modules/core/src/test/java/org/apache/ignite/{ =>
internal}/lang/TestIgniteExceptionMappersProvider.java (78%)
mode change 100755 => 100644
rename
modules/core/src/test/java/org/apache/ignite/internal/util/{HexStringUtilsTest.java
=> StringUtilsTest.java} (70%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/LibC.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/LogitLogStorageFactory.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/option/StoreOptions.java
rename modules/{core/src/main/java/org/apache/ignite/lang =>
raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit}/package-info.java
(83%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/LogitLogStorage.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/db/AbstractDB.java
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java
=>
raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/db/ConfDB.java}
(62%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/db/IndexDB.java
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshalException.java
=>
raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/db/SegmentLogDB.java}
(63%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/factory/LogStoreFactory.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/AbstractFile.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/FileHeader.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/FileManager.java
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/InternalInitException.java
=>
raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/FileType.java}
(57%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/assit/AbortFile.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/assit/Checkpoint.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/assit/FirstLogIndexCheckpoint.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/assit/FlushStatusCheckpoint.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/index/IndexFile.java
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/serialization/marshal/MarshalException.java
=>
raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/index/IndexType.java}
(69%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/file/segment/SegmentFile.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/service/AllocateFileService.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/storage/service/ServiceManager.java
copy
modules/{binary-tuple/src/main/java/org/apache/ignite/internal/binarytuple/BinaryTupleFormatException.java
=>
raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/util/Pair.java}
(57%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/util/concurrent/ReferenceResource.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/logit/util/concurrent/ShutdownAbleThread.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/BaseLogitStorageTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/LogitLogStorageTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/db/ConfDBTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/db/IndexDBTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/db/SegmentLogDBTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/file/FileManagerTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/file/index/IndexFileTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/storage/logit/file/segment/SegmentFileTest.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{command/BuildIndexCommand.java
=> replication/request/BuildIndexReplicaRequest.java} (64%)
