• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java MasterObserver类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.hbase.coprocessor.MasterObserver的典型用法代码示例。如果您正苦于以下问题:Java MasterObserver类的具体用法?Java MasterObserver怎么用?Java MasterObserver使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



MasterObserver类属于org.apache.hadoop.hbase.coprocessor包,在下文中一共展示了MasterObserver类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: preShutdown

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preShutdown() throws IOException {
  // While stopping the cluster all coprocessors method should be executed first then the
  // coprocessor should be cleaned up.
  if (coprocEnvironments.isEmpty()) {
    return;
  }
  execShutdown(new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preShutdown(this);
    }
    @Override
    public void postEnvCall() {
      // invoke coprocessor stop method
      shutdown(this.getEnvironment());
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:19,代码来源:MasterCoprocessorHost.java


示例2: preEnableReplicationPeer

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preEnableReplicationPeer(final String peerId) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preEnableReplicationPeer(this, peerId);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例3: postCreateNamespace

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postCreateNamespace(final NamespaceDescriptor ns) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postCreateNamespace(this, ns);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例4: preDeleteNamespace

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preDeleteNamespace(final String namespaceName) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preDeleteNamespace(this, namespaceName);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例5: postRemoveServers

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postRemoveServers(final Set<Address> servers)
    throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postRemoveServers(this, servers);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例6: postRequestLock

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postRequestLock(String namespace, TableName tableName, RegionInfo[] regionInfos,
    LockType type, String description) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postRequestLock(this, namespace, tableName, regionInfos, description);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例7: postGetNamespaceDescriptor

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postGetNamespaceDescriptor(final NamespaceDescriptor ns)
    throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postGetNamespaceDescriptor(this, ns);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例8: preListNamespaceDescriptors

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preListNamespaceDescriptors(final List<NamespaceDescriptor> descriptors)
    throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preListNamespaceDescriptors(this, descriptors);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例9: postListNamespaceDescriptors

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postListNamespaceDescriptors(final List<NamespaceDescriptor> descriptors)
    throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postListNamespaceDescriptors(this, descriptors);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例10: preMoveServers

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preMoveServers(final Set<Address> servers, final String targetGroup)
    throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preMoveServers(this, servers, targetGroup);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例11: postCreateTable

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postCreateTable(final TableDescriptor htd, final RegionInfo[] regions)
    throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postCreateTable(this, htd, regions);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例12: preClearDeadServers

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preClearDeadServers() throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preClearDeadServers(this);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例13: postCompletedCreateTableAction

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postCompletedCreateTableAction(
    final TableDescriptor htd, final RegionInfo[] regions, final User user) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postCompletedCreateTableAction(this, htd, regions);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例14: preDeleteTable

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preDeleteTable(final TableName tableName) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preDeleteTable(this, tableName);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例15: postDeleteTable

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postDeleteTable(final TableName tableName) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postDeleteTable(this, tableName);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例16: preDeleteTableAction

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preDeleteTableAction(final TableName tableName, final User user) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preDeleteTableAction(this, tableName);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例17: postCompletedDeleteTableAction

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postCompletedDeleteTableAction(final TableName tableName, final User user)
    throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postCompletedDeleteTableAction(this, tableName);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:MasterCoprocessorHost.java


示例18: preTruncateTable

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preTruncateTable(final TableName tableName) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preTruncateTable(this, tableName);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例19: postTruncateTable

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void postTruncateTable(final TableName tableName) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.postTruncateTable(this, tableName);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java


示例20: preRemoveReplicationPeer

import org.apache.hadoop.hbase.coprocessor.MasterObserver; //导入依赖的package包/类
public void preRemoveReplicationPeer(final String peerId) throws IOException {
  execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {
    @Override
    public void call(MasterObserver observer) throws IOException {
      observer.preRemoveReplicationPeer(this, peerId);
    }
  });
}
 
开发者ID:apache,项目名称:hbase,代码行数:9,代码来源:MasterCoprocessorHost.java



注:本文中的org.apache.hadoop.hbase.coprocessor.MasterObserver类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java GetApplicationAttemptsResponse类代码示例发布时间:2022-05-22
下一篇:
Java ObservableFloat类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap