This is an automated email from the ASF dual-hosted git repository.
dlmarion pushed a change to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git
from c8cd5809f9 Merge branch '2.1'
new d465815cf1 Added On-Demand table feature
new 83bc60a4df Updated ITs that used offline command to unload on-demand
tablets
new fa8077457b Suppress TableNotFoundException raised by new onDemand code
new 6409f84a81 Updated OnDemand table code based on pull request feedback
new 8738077b7e OnDemand table documentation and test improvements
new e8523f7501 Merge branch 'elasticity' into elasticity-on-demand-tables
new ce4c9304c6 Merge pull request #39 from cshannon/merge-elasticity-3250
new 85d34f93b5 Updated on-demand-tablet PR based on review comments
new b2e1246f95 Update ManagerAssignmentIT with changes from #3257
new 6a56f24146 Merge pull request #3250 from
dlmarion/elasticity-on-demand-tables
The 11767 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../core/client/admin/TableOperations.java | 36 +
.../core/clientImpl/TableOperationsImpl.java | 98 +-
.../accumulo/core/clientImpl/TabletLocator.java | 4 +
.../core/clientImpl/TabletLocatorImpl.java | 84 ++
.../org/apache/accumulo/core/conf/Property.java | 10 +
.../core/manager/state/tables/TableState.java | 3 +
.../core/metadata/MetadataLocationObtainer.java | 4 +-
.../core/metadata/TabletLocationState.java | 9 +-
.../accumulo/core/metadata/schema/Ample.java | 4 +
.../core/metadata/schema/MetadataSchema.java | 5 +
.../core/metadata/schema/TabletMetadata.java | 17 +-
.../core/metadata/schema/TabletsMetadata.java | 4 +
.../accumulo/core/metrics/MetricsProducer.java | 18 +
.../TabletManagementClientServiceThriftClient.java | 35 +-
.../ondemand/DefaultOnDemandTabletUnloader.java | 64 +
.../core/spi/ondemand/OnDemandTabletUnloader.java | 79 ++
.../core/tabletserver/UnloaderParamsImpl.java | 70 ++
.../org/apache/accumulo/core/util/Validators.java | 11 +
.../core/clientImpl/thrift/TableOperation.java | 5 +-
.../core/manager/thrift/FateOperation.java | 5 +-
.../thrift/TabletManagementClientService.java | 1319 ++++++++++++++++++++
core/src/main/thrift/client.thrift | 1 +
core/src/main/thrift/manager.thrift | 1 +
core/src/main/thrift/tabletmgmt.thrift | 9 +
.../core/clientImpl/TableOperationsHelperTest.java | 15 +-
.../core/clientImpl/TabletLocatorImplTest.java | 42 +-
.../core/metadata/schema/TabletMetadataTest.java | 3 +-
.../server/constraints/MetadataConstraints.java | 13 +-
.../server/manager/state/CurrentState.java | 2 +
.../server/manager/state/MetaDataTableScanner.java | 9 +-
.../manager/state/TabletStateChangeIterator.java | 22 +-
.../server/manager/state/ZooTabletStateStore.java | 2 +-
.../server/metadata/TabletMutatorBase.java | 13 +
.../server/security/AuditedSecurityOperation.java | 7 +-
.../server/security/SecurityOperation.java | 2 +-
.../accumulo/server/tables/TableManager.java | 24 +-
...Tablets.java => ListOnlineOnDemandTablets.java} | 56 +-
.../manager/state/RootTabletStateStoreTest.java | 8 +-
.../manager/state/TabletLocationStateTest.java | 28 +-
.../main/java/org/apache/accumulo/gc/GCRun.java | 2 +-
.../gc/GarbageCollectWriteAheadLogsTest.java | 4 +-
.../accumulo/manager/FateServiceHandler.java | 36 +-
.../java/org/apache/accumulo/manager/Manager.java | 37 +-
.../accumulo/manager/TabletGroupWatcher.java | 8 +-
.../manager/tableOps/ChangeTableState.java | 5 +-
.../manager/tableOps/bulkVer2/LoadFiles.java | 1 +
.../manager/tableOps/clone/FinishCloneTable.java | 4 +-
.../apache/accumulo/tserver/AssignmentHandler.java | 3 +
.../accumulo/tserver/TabletClientHandler.java | 16 +
.../org/apache/accumulo/tserver/TabletServer.java | 171 ++-
.../accumulo/tserver/UnloadTabletHandler.java | 5 +-
.../tserver/metrics/TabletServerMetrics.java | 9 +
.../tserver/metrics/TabletServerMetricsUtil.java | 14 +
.../org/apache/accumulo/tserver/tablet/Tablet.java | 14 +-
.../apache/accumulo/tserver/tablet/TabletData.java | 9 +-
.../tserver/DefaultOnDemandTabletUnloaderTest.java | 87 ++
.../main/java/org/apache/accumulo/shell/Shell.java | 7 +-
.../{OnlineCommand.java => OndemandCommand.java} | 15 +-
.../org/apache/accumulo/test/AuditMessageIT.java | 5 +-
.../java/org/apache/accumulo/test/LocatorIT.java | 6 +
.../accumulo/test/MultiTableBatchWriterIT.java | 61 +
.../test/functional/ManagerAssignmentIT.java | 306 ++++-
.../accumulo/test/functional/OnDemandIT.java | 209 ++++
.../functional/TabletStateChangeIteratorIT.java | 76 +-
.../apache/accumulo/test/manager/MergeStateIT.java | 7 +-
.../apache/accumulo/test/metrics/MetricsIT.java | 3 +-
.../accumulo/test/performance/NullTserver.java | 4 +
67 files changed, 3086 insertions(+), 179 deletions(-)
create mode 100644
core/src/main/java/org/apache/accumulo/core/spi/ondemand/DefaultOnDemandTabletUnloader.java
create mode 100644
core/src/main/java/org/apache/accumulo/core/spi/ondemand/OnDemandTabletUnloader.java
create mode 100644
core/src/main/java/org/apache/accumulo/core/tabletserver/UnloaderParamsImpl.java
copy
server/base/src/main/java/org/apache/accumulo/server/util/{FindOfflineTablets.java
=> ListOnlineOnDemandTablets.java} (68%)
create mode 100644
server/tserver/src/test/java/org/apache/accumulo/tserver/DefaultOnDemandTabletUnloaderTest.java
copy
shell/src/main/java/org/apache/accumulo/shell/commands/{OnlineCommand.java =>
OndemandCommand.java} (79%)
create mode 100644
test/src/main/java/org/apache/accumulo/test/functional/OnDemandIT.java
