| /** |
| * 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.util; |
| |
| import java.io.IOException; |
| |
| import org.apache.hadoop.conf.Configuration; |
| import org.apache.hadoop.fs.Path; |
| import org.apache.hadoop.hbase.TableName; |
| import org.apache.hadoop.hbase.HConstants; |
| import org.apache.hadoop.hbase.HRegionInfo; |
| import org.apache.hadoop.hbase.regionserver.HRegion; |
| import org.apache.hadoop.hbase.regionserver.HStore; |
| |
| /** |
| * Helper class for all utilities related to archival/retrieval of HFiles |
| */ |
| public class HFileArchiveUtil { |
| private HFileArchiveUtil() { |
| // non-external instantiation - util class |
| } |
| |
| /** |
| * Get the directory to archive a store directory |
| * @param conf {@link Configuration} to read for the archive directory name |
| * @param tableName table name under which the store currently lives |
| * @param regionName region encoded name under which the store currently lives |
| * @param familyName name of the family in the store |
| * @return {@link Path} to the directory to archive the given store or |
| * <tt>null</tt> if it should not be archived |
| */ |
| public static Path getStoreArchivePath(final Configuration conf, |
| final TableName tableName, |
| final String regionName, final String familyName) throws IOException { |
| Path tableArchiveDir = getTableArchivePath(conf, tableName); |
| return HStore.getStoreHomedir(tableArchiveDir, regionName, Bytes.toBytes(familyName)); |
| } |
| |
| /** |
| * Get the directory to archive a store directory |
| * @param conf {@link Configuration} to read for the archive directory name. |
| * @param region parent region information under which the store currently lives |
| * @param tabledir directory for the table under which the store currently lives |
| * @param family name of the family in the store |
| * @return {@link Path} to the directory to archive the given store or <tt>null</tt> if it should |
| * not be archived |
| */ |
| public static Path getStoreArchivePath(Configuration conf, |
| HRegionInfo region, |
| Path tabledir, |
| byte[] family) throws IOException { |
| Path rootDir = FSUtils.getRootDir(conf); |
| Path tableArchiveDir = getTableArchivePath(rootDir, region.getTable()); |
| return HStore.getStoreHomedir(tableArchiveDir, region, family); |
| } |
| |
| /** |
| * Get the archive directory for a given region under the specified table |
| * @param tableName the table name. Cannot be null. |
| * @param regiondir the path to the region directory. Cannot be null. |
| * @return {@link Path} to the directory to archive the given region, or <tt>null</tt> if it |
| * should not be archived |
| */ |
| public static Path getRegionArchiveDir(Path rootDir, |
| TableName tableName, |
| Path regiondir) { |
| // get the archive directory for a table |
| Path archiveDir = getTableArchivePath(rootDir, tableName); |
| |
| // then add on the region path under the archive |
| String encodedRegionName = regiondir.getName(); |
| return HRegion.getRegionDir(archiveDir, encodedRegionName); |
| } |
| |
| /** |
| * Get the archive directory for a given region under the specified table |
| * @param rootDir {@link Path} to the root directory where hbase files are stored (for building |
| * the archive path) |
| * @param tableName name of the table to archive. Cannot be null. |
| * @return {@link Path} to the directory to archive the given region, or <tt>null</tt> if it |
| * should not be archived |
| */ |
| public static Path getRegionArchiveDir(Path rootDir, |
| TableName tableName, String encodedRegionName) { |
| // get the archive directory for a table |
| Path archiveDir = getTableArchivePath(rootDir, tableName); |
| return HRegion.getRegionDir(archiveDir, encodedRegionName); |
| } |
| |
| /** |
| * Get the path to the table archive directory based on the configured archive directory. |
| * <p> |
| * Get the path to the table's archive directory. |
| * <p> |
| * Generally of the form: /hbase/.archive/[tablename] |
| * @param rootdir {@link Path} to the root directory where hbase files are stored (for building |
| * the archive path) |
| * @param tableName Name of the table to be archived. Cannot be null. |
| * @return {@link Path} to the archive directory for the table |
| */ |
| public static Path getTableArchivePath(final Path rootdir, final TableName tableName) { |
| return FSUtils.getTableDir(getArchivePath(rootdir), tableName); |
| } |
| |
| /** |
| * Get the path to the table archive directory based on the configured archive directory. |
| * <p> |
| * Assumed that the table should already be archived. |
| * @param conf {@link Configuration} to read the archive directory property. Can be null |
| * @param tableName Name of the table to be archived. Cannot be null. |
| * @return {@link Path} to the archive directory for the table |
| */ |
| public static Path getTableArchivePath(final Configuration conf, |
| final TableName tableName) |
| throws IOException { |
| return FSUtils.getTableDir(getArchivePath(conf), tableName); |
| } |
| |
| /** |
| * Get the full path to the archive directory on the configured |
| * {@link org.apache.hadoop.hbase.master.MasterFileSystem} |
| * @param conf to look for archive directory name and root directory. Cannot be null. Notes for |
| * testing: requires a FileSystem root directory to be specified. |
| * @return the full {@link Path} to the archive directory, as defined by the configuration |
| * @throws IOException if an unexpected error occurs |
| */ |
| public static Path getArchivePath(Configuration conf) throws IOException { |
| return getArchivePath(FSUtils.getRootDir(conf)); |
| } |
| |
| /** |
| * Get the full path to the archive directory on the configured |
| * {@link org.apache.hadoop.hbase.master.MasterFileSystem} |
| * @param rootdir {@link Path} to the root directory where hbase files are stored (for building |
| * the archive path) |
| * @return the full {@link Path} to the archive directory, as defined by the configuration |
| */ |
| private static Path getArchivePath(final Path rootdir) { |
| return new Path(rootdir, HConstants.HFILE_ARCHIVE_DIRECTORY); |
| } |
| } |