You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2023/06/27 20:43:06 UTC
[accumulo] branch elasticity updated (9c50447bc0 -> 459153a649)
This is an automated email from the ASF dual-hosted git repository.
kturner pushed a change to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git
from 9c50447bc0 Merge branch 'main' into elasticity
add 459153a649 implements most of user compactions in the manager (#3513)
No new revisions were added by this update.
Summary of changes:
.../core/manager/state/TabletManagement.java | 8 +-
.../accumulo/core/metadata/schema/Ample.java | 26 +-
.../schema/ExternalCompactionMetadata.java | 42 +-
.../core/metadata/schema/MetadataSchema.java | 8 +
.../core/metadata/schema/SelectedFiles.java | 103 +++++
.../core/metadata/schema/TabletMetadata.java | 22 +-
.../metadata/schema/TabletMetadataBuilder.java | 284 +++++++++++++
.../core/metadata/schema}/TabletMutatorBase.java | 38 +-
.../core/metadata/schema/TabletsMetadata.java | 4 +
.../miniclusterImpl/MiniAccumuloClusterImpl.java | 23 +-
.../miniclusterImpl/MiniAccumuloConfigImpl.java | 16 +-
.../server/compaction/CompactionConfigStorage.java | 80 ++++
.../server/compaction/CompactionJobGenerator.java | 100 +++--
.../server/compaction/CompactionPluginUtils.java | 262 ++++++++++++
.../server/constraints/MetadataConstraints.java | 13 +-
.../manager/state/TabletManagementIterator.java | 1 +
.../manager/state/TabletMetadataImposter.java | 14 +-
.../metadata/ConditionalTabletMutatorImpl.java | 112 +++--
.../server/metadata/RootTabletMutatorImpl.java | 3 +-
.../accumulo/server/metadata/ServerAmpleImpl.java | 1 +
.../server/metadata/TabletMutatorImpl.java | 3 +-
.../iterators/CompactionsExistsIterator.java | 52 ---
.../metadata/iterators/SetEqualityIterator.java | 189 +++++++++
.../accumulo/server/util/ManagerMetadataUtil.java | 6 +-
.../accumulo/server/util/MetadataTableUtil.java | 16 +-
.../constraints/MetadataConstraintsTest.java | 26 ++
.../manager/state/RootTabletStateStoreTest.java | 2 +-
.../accumulo/manager/TabletGroupWatcher.java | 3 +-
.../coordinator/CompactionCoordinator.java | 453 +++++++++++++++++----
.../manager/tableOps/bulkVer2/LoadFiles.java | 5 +-
.../manager/tableOps/compact/CompactionDriver.java | 189 ++++++---
.../manager/tableOps/create/PopulateMetadata.java | 14 +-
server/tserver/pom.xml | 4 -
.../accumulo/tserver/tablet/CompactableImpl.java | 5 +-
.../accumulo/tserver/tablet/CompactableUtils.java | 61 +--
.../accumulo/tserver/tablet/DatafileManager.java | 5 +-
.../org/apache/accumulo/tserver/tablet/Tablet.java | 62 +--
.../tserver/tablet/CompactableImplTest.java | 10 +-
.../test/compaction/ExternalCompaction_1_IT.java | 4 +
.../test/functional/AmpleConditionalWriterIT.java | 209 +++++++---
.../apache/accumulo/test/functional/BulkNewIT.java | 6 +-
.../accumulo/test/functional/CompactionIT.java | 6 +-
42 files changed, 1915 insertions(+), 575 deletions(-)
create mode 100644 core/src/main/java/org/apache/accumulo/core/metadata/schema/SelectedFiles.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/metadata/schema/TabletMetadataBuilder.java
rename {server/base/src/main/java/org/apache/accumulo/server/metadata => core/src/main/java/org/apache/accumulo/core/metadata/schema}/TabletMutatorBase.java (91%)
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/compaction/CompactionConfigStorage.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/compaction/CompactionPluginUtils.java
delete mode 100644 server/base/src/main/java/org/apache/accumulo/server/metadata/iterators/CompactionsExistsIterator.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/metadata/iterators/SetEqualityIterator.java