org.apache.hadoop.hbase.zookeeper.ZKSplitLog.getFileName()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.2k)|赞(0)|评价(0)|浏览(74)

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

ZKSplitLog.getFileName介绍

暂无

代码示例

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

@Override
 public String getWALFile() {
  return ZKSplitLog.getFileName(taskNode);
 }
}

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

LOG.info("Task " + path + " entered state=" + slt.toString());
if (taskFinisher != null && !ZKSplitLog.isRescanNode(watcher, path)) {
 if (taskFinisher.finish(slt.getServerName(), ZKSplitLog.getFileName(path)) == Status.DONE) {
  setDone(path, SUCCESS);
 } else {

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

if (node.startsWith("RESCAN")) {
 String name = ZKSplitLog.getEncodedNodeName(zkw, node);
 String fn = ZKSplitLog.getFileName(name);
 byte [] data = ZKUtil.getData(zkw,
     ZNodePaths.joinZNode(zkw.getZNodePaths().splitLogZNode, fn));

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

@Override
 public String getWALFile() {
  return ZKSplitLog.getFileName(taskNode);
 }
}

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

TaskExecutor.Status status;
status = splitTaskExecutor.exec(ZKSplitLog.getFileName(currentTask),
  new CancelableProgressable() {

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

t = ZKSplitLog.getFileName(t);
ServerName serverName = DefaultWALProvider.getServerNameFromWALDirectoryName(new Path(t));
if (serverName != null) {

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

if (taskFinisher != null && !ZKSplitLog.isRescanNode(watcher, path)) {
 if (taskFinisher.finish(TaskState.TASK_DONE.getWriterName(data),
   ZKSplitLog.getFileName(path)) == Status.DONE) {
  setDone(path, SUCCESS);
 } else {

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

if (node.startsWith("RESCAN")) {
 String name = ZKSplitLog.getEncodedNodeName(zkw, node);
 String fn = ZKSplitLog.getFileName(name);
 byte [] data = ZKUtil.getData(zkw,
     ZNodePaths.joinZNode(zkw.getZNodePaths().splitLogZNode, fn));

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

LOG.info("task " + path + " entered state: " + slt.toString());
if (taskFinisher != null && !ZKSplitLog.isRescanNode(watcher, path)) {
 if (taskFinisher.finish(slt.getServerName(), ZKSplitLog.getFileName(path)) == Status.DONE) {
  setDone(path, SUCCESS);
 } else {

相关文章