本文整理了Java中org.apache.hadoop.hbase.HBaseTestingUtility.getRandomDir()
方法的一些代码示例,展示了HBaseTestingUtility.getRandomDir()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HBaseTestingUtility.getRandomDir()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.HBaseTestingUtility
类名称:HBaseTestingUtility
方法名:getRandomDir
暂无
代码示例来源:origin: apache/hbase
@Before
public void setUp() throws Exception {
this.restoreDir = TEST_UTIL.getRandomDir();
}
代码示例来源:origin: apache/hbase
String temPath1 = utility1.getRandomDir().toString();
String temPath2 = "/tmp2";
代码示例来源:origin: apache/phoenix
@Before
public void before() throws SQLException, IOException {
// create table
Connection conn = DriverManager.getConnection(getUrl());
tableName = generateUniqueName();
conn.createStatement().execute(String.format(CREATE_TABLE, tableName));
conn.commit();
// configure Phoenix M/R job to read snapshot
conf = getUtility().getConfiguration();
job = Job.getInstance(conf);
tmpDir = getUtility().getRandomDir();
}
代码示例来源:origin: apache/phoenix
private void collectStatsOnSnapshot(Connection conn, String fullTableName,
String guidePostWidth, String localPhysicalTableName) throws Exception {
UpdateStatisticsTool tool = new UpdateStatisticsTool();
Configuration conf = utility.getConfiguration();
Admin admin = conn.unwrap(PhoenixConnection.class).getQueryServices().getAdmin();
String snapshotName = "UpdateStatisticsTool_" + generateUniqueName();
admin.snapshot(snapshotName, TableName.valueOf(localPhysicalTableName));
LOG.info("Successfully created snapshot " + snapshotName + " for " + localPhysicalTableName);
Path randomDir = getUtility().getRandomDir();
if (guidePostWidth != null) {
conn.createStatement().execute("ALTER TABLE " + fullTableName + " SET GUIDE_POSTS_WIDTH = " + guidePostWidth);
}
Job job = tool.configureJob(conf, fullTableName, snapshotName, randomDir);
assertEquals(job.getConfiguration().get(MAPREDUCE_JOB_TYPE), UPDATE_STATS.name());
tool.runJob(job, true);
}
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
@Before
public void setUp() throws Exception {
this.restoreDir = TEST_UTIL.getRandomDir();
}
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
@Before
public void setUp() throws Exception {
this.restoreDir = TEST_UTIL.getRandomDir();
}
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
String temPath1 = utility1.getRandomDir().toString();
String temPath2 = "/tmp2";
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
String temPath1 = utility1.getRandomDir().toString();
String temPath2 = "/tmp2";
内容来源于网络,如有侵权,请联系作者删除!