yl-hbase-rep:hbaseplicationsnapshot实现机制,源码解析,以及复制对等体的实现-源码解析

上传者: 42107561 | 上传时间: 2021-03-24 21:07:19 | 文件大小: 1.05MB | 文件类型: ZIP
yl-hbase-rep hbase快照,复制实现机制,源码解析 复制对等方的实现代码 批量加载代码示例 1个快照/复制实现机制 快照实现机制,快照文件生成过程,请参考快照内容 复制实现机制,源码解析,请参考 2复制对等体的实现 参考lily二级索引的实现机制,重新实现了一个简化版本的复制对等体 复制对等服务器从源hbase同步同步接收WAL编辑,并写入目标存储(例如:solr / kafka等) 最初的复制对等节点某个区域服务器角色 3 bulkload示例 bulkload方式从hive import hbase有现成的sql可以使用 如果输入是CSV文件或parquet文件,当然也可以先建立一个hive外部表,再从hive import到hbase 也可以通过编码的方式,通过bulkload生成hfile然后再合并到hbase 致谢 yl-hbase-rep实现机制参考了lily

文件下载

资源详情

[{"title":"( 44 个子文件 1.05MB ) yl-hbase-rep:hbaseplicationsnapshot实现机制,源码解析,以及复制对等体的实现-源码解析","children":[{"title":"yl-hbase-rep-master","children":[{"title":"hbase Split源码分析.md <span style='color:#111;'> 6.08KB </span>","children":null,"spread":false},{"title":"replication源码分析.md <span style='color:#111;'> 11.58KB </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 5.80KB </span>","children":null,"spread":false},{"title":"hbase_FSHLog流程.md <span style='color:#111;'> 2.83KB </span>","children":null,"spread":false},{"title":"img","children":[{"title":"snapshot_progress.png <span style='color:#111;'> 95.38KB </span>","children":null,"spread":false},{"title":"hbase_zk_node.png <span style='color:#111;'> 112.29KB </span>","children":null,"spread":false},{"title":"replication_sync_progress.png <span style='color:#111;'> 220.25KB </span>","children":null,"spread":false},{"title":"replication_class_relation.png <span style='color:#111;'> 55.11KB </span>","children":null,"spread":false},{"title":"WAL_rolling.png <span style='color:#111;'> 445.15KB </span>","children":null,"spread":false},{"title":"table_snapshot_data.png <span style='color:#111;'> 109.74KB </span>","children":null,"spread":false}],"spread":true},{"title":"hbase RegionServer源码分析.md <span style='color:#111;'> 24.44KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"example","children":[{"title":"hbase","children":[{"title":"bulkload","children":[{"title":"BulkloadDriver.java <span style='color:#111;'> 2.26KB </span>","children":null,"spread":false},{"title":"KVMapperOnParquetIn.java <span style='color:#111;'> 7.48KB </span>","children":null,"spread":false},{"title":"HColumnEnum.java <span style='color:#111;'> 530B </span>","children":null,"spread":false},{"title":"KVMapperOnCSVIn.java <span style='color:#111;'> 4.80KB </span>","children":null,"spread":false}],"spread":true},{"title":"peer","children":[{"title":"server","children":[{"title":"conf","children":[{"title":"ConfKeys.java <span style='color:#111;'> 1.26KB </span>","children":null,"spread":false},{"title":"SlaveParams.java <span style='color:#111;'> 545B </span>","children":null,"spread":false},{"title":"HBaseSlaveConf.java <span style='color:#111;'> 1.58KB </span>","children":null,"spread":false}],"spread":false},{"title":"FakeRegionServer.java <span style='color:#111;'> 3.33KB </span>","children":null,"spread":false},{"title":"Test.java <span style='color:#111;'> 278B </span>","children":null,"spread":false}],"spread":false},{"title":"seplistener","children":[{"title":"LogEventListener.java <span style='color:#111;'> 1.46KB </span>","children":null,"spread":false}],"spread":false},{"title":"sepapi","children":[{"title":"EventListener.java <span style='color:#111;'> 688B </span>","children":null,"spread":false},{"title":"BaseHRegionServer.java <span style='color:#111;'> 7.10KB </span>","children":null,"spread":false},{"title":"SepModel.java <span style='color:#111;'> 1.13KB </span>","children":null,"spread":false},{"title":"PayloadExtractor.java <span style='color:#111;'> 779B </span>","children":null,"spread":false},{"title":"util","children":[{"title":"zk","children":[{"title":"ZooKeeperImpl.java <span style='color:#111;'> 11.08KB </span>","children":null,"spread":false},{"title":"ZkUtil.java <span style='color:#111;'> 7.67KB </span>","children":null,"spread":false},{"title":"ZkConnectException.java <span style='color:#111;'> 876B </span>","children":null,"spread":false},{"title":"ZooKeeperOperation.java <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"StateWatchingZooKeeper.java <span style='color:#111;'> 7.74KB </span>","children":null,"spread":false},{"title":"ZooKeeperItf.java <span style='color:#111;'> 5.54KB </span>","children":null,"spread":false}],"spread":false},{"title":"io","children":[{"title":"Closer.java <span style='color:#111;'> 2.01KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"RowData.java <span style='color:#111;'> 321B </span>","children":null,"spread":false}],"spread":false},{"title":"sepimpl","children":[{"title":"SepConsumer.java <span style='color:#111;'> 11.24KB </span>","children":null,"spread":false},{"title":"SepEventRowData.java <span style='color:#111;'> 1.66KB </span>","children":null,"spread":false},{"title":"SepEventExecutor.java <span style='color:#111;'> 3.18KB </span>","children":null,"spread":false},{"title":"SepEvent.java <span style='color:#111;'> 3.38KB </span>","children":null,"spread":false},{"title":"SepModelImpl.java <span style='color:#111;'> 7.06KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"hbase Compaction源码分析.md <span style='color:#111;'> 9.05KB </span>","children":null,"spread":false},{"title":"hbase启用replication.md <span style='color:#111;'> 829B </span>","children":null,"spread":false},{"title":"hbase zk nodes.md <span style='color:#111;'> 3.49KB </span>","children":null,"spread":false},{"title":"hbase snapshot过程.md <span style='color:#111;'> 5.03KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 1.00KB </span>","children":null,"spread":false},{"title":"WAL相关.md <span style='color:#111;'> 1.80KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}]

评论信息

免责申明

【只为小站】的资源来自网友分享,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论 【只为小站】 经营者是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二条之规定,若资源存在侵权或相关问题请联系本站客服人员,zhiweidada#qq.com,请把#换成@,本站将给予最大的支持与配合,做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明