-
Notifications
You must be signed in to change notification settings - Fork 3.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
HBASE-24627 Normalize one table at a time
Introduce an additional method to our Admin interface that allow an operator to selectivly run the normalizer. The IPC protocol supports general table name select via compound filter.
- Loading branch information
Showing
17 changed files
with
445 additions
and
121 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
91 changes: 91 additions & 0 deletions
91
hbase-client/src/main/java/org/apache/hadoop/hbase/client/NormalizeTableFilterParams.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,91 @@ | ||
| /* | ||
| * Licensed to the Apache Software Foundation (ASF) under one | ||
| * or more contributor license agreements. See the NOTICE file | ||
| * distributed with this work for additional information | ||
| * regarding copyright ownership. The ASF licenses this file | ||
| * to you under the Apache License, Version 2.0 (the | ||
| * "License"); you may not use this file except in compliance | ||
| * with the License. You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
| package org.apache.hadoop.hbase.client; | ||
|
|
||
| import java.util.List; | ||
| import org.apache.hadoop.hbase.TableName; | ||
| import org.apache.yetus.audience.InterfaceAudience; | ||
| import org.apache.yetus.audience.InterfaceStability; | ||
|
|
||
| /** | ||
| * A collection of criteria used for table selection. | ||
| */ | ||
| @InterfaceAudience.Public | ||
| @InterfaceStability.Evolving | ||
| public class NormalizeTableFilterParams { | ||
| private final List<TableName> tableNames; | ||
| private final String regex; | ||
| private final String namespace; | ||
|
|
||
| public NormalizeTableFilterParams( | ||
| final List<TableName> tableNames, | ||
| final String regex, | ||
| final String namespace | ||
| ) { | ||
| this.tableNames = tableNames; | ||
| this.regex = regex; | ||
| this.namespace = namespace; | ||
| } | ||
|
|
||
| public List<TableName> getTableNames() { | ||
| return tableNames; | ||
| } | ||
|
|
||
| public String getRegex() { | ||
| return regex; | ||
| } | ||
|
|
||
| public String getNamespace() { | ||
| return namespace; | ||
| } | ||
|
|
||
| /** | ||
| * Used to instantiate an instance of {@link NormalizeTableFilterParams}. | ||
| */ | ||
| public static class Builder { | ||
| private List<TableName> tableNames; | ||
| private String regex; | ||
| private String namespace; | ||
|
|
||
| public Builder tableFilterParams(final NormalizeTableFilterParams ntfp) { | ||
| this.tableNames = ntfp.getTableNames(); | ||
| this.regex = ntfp.getRegex(); | ||
| this.namespace = ntfp.getNamespace(); | ||
| return this; | ||
| } | ||
|
|
||
| public Builder tableNames(final List<TableName> tableNames) { | ||
| this.tableNames = tableNames; | ||
| return this; | ||
| } | ||
|
|
||
| public Builder regex(final String regex) { | ||
| this.regex = regex; | ||
| return this; | ||
| } | ||
|
|
||
| public Builder namespace(final String namespace) { | ||
| this.namespace = namespace; | ||
| return this; | ||
| } | ||
|
|
||
| public NormalizeTableFilterParams build() { | ||
| return new NormalizeTableFilterParams(tableNames, regex, namespace); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.