org.apache.hadoop.hbase.regionserver.HStore.getStoreHomedir()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(7.0k)|赞(0)|评价(0)|浏览(113)

本文整理了Java中org.apache.hadoop.hbase.regionserver.HStore.getStoreHomedir()方法的一些代码示例,展示了HStore.getStoreHomedir()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HStore.getStoreHomedir()方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.HStore
类名称:HStore
方法名:getStoreHomedir

HStore.getStoreHomedir介绍

暂无

代码示例

代码示例来源:origin: apache/hbase

/**
 * @param tabledir {@link Path} to where the table is being stored
 * @param hri {@link RegionInfo} for the region.
 * @param family {@link ColumnFamilyDescriptor} describing the column family
 * @return Path to family/Store home directory.
 */
@Deprecated
public static Path getStoreHomedir(final Path tabledir,
  final RegionInfo hri, final byte[] family) {
 return getStoreHomedir(tabledir, hri.getEncodedName(), family);
}

代码示例来源:origin: apache/hbase

/**
 * 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));
}

代码示例来源:origin: apache/hbase

/**
 * Gets 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 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,
                    RegionInfo region,
  byte[] family) throws IOException {
 Path rootDir = FSUtils.getRootDir(conf);
 Path tableArchiveDir = getTableArchivePath(rootDir, region.getTable());
 return HStore.getStoreHomedir(tableArchiveDir, region, family);
}

代码示例来源:origin: apache/hbase

private Path createReferences(final MasterServices services,
  final TableDescriptor td, final HRegionInfo parent,
  final HRegionInfo daughter, final byte [] midkey, final boolean top)
throws IOException {
 Path rootdir = services.getMasterFileSystem().getRootDir();
 Path tabledir = FSUtils.getTableDir(rootdir, parent.getTable());
 Path storedir = HStore.getStoreHomedir(tabledir, daughter,
  td.getColumnFamilies()[0].getName());
 Reference ref =
  top? Reference.createTopReference(midkey): Reference.createBottomReference(midkey);
 long now = System.currentTimeMillis();
 // Reference name has this format: StoreFile#REF_NAME_PARSER
 Path p = new Path(storedir, Long.toString(now) + "." + parent.getEncodedName());
 FileSystem fs = services.getMasterFileSystem().getFileSystem();
 ref.write(fs, p);
 return p;
}

代码示例来源:origin: apache/hbase

Path tabledir = FSUtils.getTableDir(rootdir, td.getTableName());
Path parentdir = new Path(tabledir, parent.getEncodedName());
Path storedir = HStore.getStoreHomedir(tabledir, splita, td.getColumnFamilies()[0].getName());
Reference ref = Reference.createTopReference(Bytes.toBytes("ccc"));
long now = System.currentTimeMillis();

代码示例来源:origin: apache/hbase

Path storedir = HStore.getStoreHomedir(tabledir, parent, td.getColumnFamilies()[0].getName());
Path storeArchive =
  HFileArchiveUtil.getStoreArchivePath(this.masterServices.getConfiguration(), parent,

代码示例来源:origin: apache/hbase

Path storedir = HStore.getStoreHomedir(tabledir, parent, td.getColumnFamilies()[0].getName());
System.out.println("Old root:" + rootdir);
System.out.println("Old table:" + tabledir);

代码示例来源:origin: harbby/presto-connectors

/**
 * @param tabledir {@link Path} to where the table is being stored
 * @param hri {@link HRegionInfo} for the region.
 * @param family {@link HColumnDescriptor} describing the column family
 * @return Path to family/Store home directory.
 */
@Deprecated
public static Path getStoreHomedir(final Path tabledir,
  final HRegionInfo hri, final byte[] family) {
 return getStoreHomedir(tabledir, hri.getEncodedName(), family);
}

代码示例来源:origin: harbby/presto-connectors

/**
 * 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));
}

代码示例来源:origin: harbby/presto-connectors

/**
 * 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 {
 TableName tableName =
   FSUtils.getTableName(tabledir);
 Path rootDir = FSUtils.getRootDir(conf);
 Path tableArchiveDir = getTableArchivePath(rootDir, tableName);
 return HStore.getStoreHomedir(tableArchiveDir, region, family);
}

代码示例来源:origin: org.apache.hbase/hbase-server

private Path createReferences(final MasterServices services,
  final TableDescriptor td, final HRegionInfo parent,
  final HRegionInfo daughter, final byte [] midkey, final boolean top)
throws IOException {
 Path rootdir = services.getMasterFileSystem().getRootDir();
 Path tabledir = FSUtils.getTableDir(rootdir, parent.getTable());
 Path storedir = HStore.getStoreHomedir(tabledir, daughter,
  td.getColumnFamilies()[0].getName());
 Reference ref =
  top? Reference.createTopReference(midkey): Reference.createBottomReference(midkey);
 long now = System.currentTimeMillis();
 // Reference name has this format: StoreFile#REF_NAME_PARSER
 Path p = new Path(storedir, Long.toString(now) + "." + parent.getEncodedName());
 FileSystem fs = services.getMasterFileSystem().getFileSystem();
 ref.write(fs, p);
 return p;
}

代码示例来源:origin: org.apache.hbase/hbase-server

Path storedir = HStore.getStoreHomedir(tabledir, parent, td.getColumnFamilies()[0].getName());
Path storeArchive =
  HFileArchiveUtil.getStoreArchivePath(this.masterServices.getConfiguration(), parent,

代码示例来源:origin: org.apache.hbase/hbase-server

Path storedir = HStore.getStoreHomedir(tabledir, parent, td.getColumnFamilies()[0].getName());
System.out.println("Old root:" + rootdir);
System.out.println("Old table:" + tabledir);

代码示例来源:origin: org.apache.hbase/hbase-server

Path tabledir = FSUtils.getTableDir(rootdir, td.getTableName());
Path parentdir = new Path(tabledir, parent.getEncodedName());
Path storedir = HStore.getStoreHomedir(tabledir, splita, td.getColumnFamilies()[0].getName());
Reference ref = Reference.createTopReference(Bytes.toBytes("ccc"));
long now = System.currentTimeMillis();

相关文章

HStore类方法