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

WALPlayer.<init>介绍

暂无

代码示例

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

/**
 * Main entry point.
 * @param args The command line parameters.
 * @throws Exception When running the job fails.
 */
public static void main(String[] args) throws Exception {
 int ret = ToolRunner.run(new WALPlayer(HBaseConfiguration.create()), args);
 System.exit(ret);
}

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

protected void walToHFiles(List<String> dirPaths, List<String> tableList) throws IOException {
 Tool player = new WALPlayer();
 // Player reads all files in arbitrary directory structure and creates
 // a Map task for each file. We use ';' as separator
 // because WAL file names contains ','
 String dirs = StringUtils.join(dirPaths, ';');
 String jobname = "Incremental_Backup-" + backupId ;
 Path bulkOutputPath = getBulkOutputDir();
 conf.set(WALPlayer.BULK_OUTPUT_CONF_KEY, bulkOutputPath.toString());
 conf.set(WALPlayer.INPUT_FILES_SEPARATOR_KEY, ";");
 conf.setBoolean(WALPlayer.MULTI_TABLES_SUPPORT, true);
 conf.set(JOB_NAME_CONF_KEY, jobname);
 String[] playerArgs = { dirs, StringUtils.join(tableList, ",") };
 try {
  player.setConf(conf);
  int result = player.run(playerArgs);
  if(result != 0) {
   throw new IOException("WAL Player failed");
  }
  conf.unset(WALPlayer.INPUT_FILES_SEPARATOR_KEY);
  conf.unset(JOB_NAME_CONF_KEY);
 } catch (IOException e) {
  throw e;
 } catch (Exception ee) {
  throw new IOException("Can not convert from directory " + dirs
    + " (check Hadoop, HBase and WALPlayer M/R job logs) ", ee);
 }
}

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

WALPlayer player = new WALPlayer(configuration);
String optionName="_test_.name";
configuration.set(optionName, "1000");

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Main entry point.
 *
 * @param args  The command line parameters.
 * @throws Exception When running the job fails.
 */
public static void main(String[] args) throws Exception {
 int ret = ToolRunner.run(new WALPlayer(HBaseConfiguration.create()), args);
 System.exit(ret);
}

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

/**
 * Main entry point.
 *
 * @param args  The command line parameters.
 * @throws Exception When running the job fails.
 */
public static void main(String[] args) throws Exception {
 int ret = ToolRunner.run(new WALPlayer(HBaseConfiguration.create()), args);
 System.exit(ret);
}

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

/**
 * Main entry point.
 *
 * @param args  The command line parameters.
 * @throws Exception When running the job fails.
 */
public static void main(String[] args) throws Exception {
 int ret = ToolRunner.run(new WALPlayer(HBaseConfiguration.create()), args);
 System.exit(ret);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-mapreduce

/**
 * Main entry point.
 *
 * @param args  The command line parameters.
 * @throws Exception When running the job fails.
 */
public static void main(String[] args) throws Exception {
 int ret = ToolRunner.run(new WALPlayer(HBaseConfiguration.create()), args);
 System.exit(ret);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-mapreduce

WALPlayer player = new WALPlayer(configuration);
String optionName="_test_.name";
configuration.set(optionName, "1000");

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

WALPlayer player = new WALPlayer(configuration);
String optionName="_test_.name";
configuration.set(optionName, "1000");

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

WALPlayer player = new WALPlayer(configuration);
String optionName="_test_.name";
configuration.set(optionName, "1000");

代码示例来源：origin: com.aliyun.hbase/alihbase-mapreduce

WALPlayer player = new WALPlayer(configuration);
String optionName="_test_.name";
configuration.set(optionName, "1000");