没有合适的资源?快使用搜索试试~ 我知道了~
storm-asynchbase:AsyncHBase 风暴映射器
共41个文件
java:38个
xml:1个
gitignore:1个
需积分: 10 0 下载量 69 浏览量
2021-06-07
22:04:09
上传
评论
收藏 59KB ZIP 举报
温馨提示
使用 AsyncHBase 客户端的 HBase 风暴连接器 这个用于 Apache Storm 的连接器使用 AsyncHBase 客户端将原始数据和 Trident 状态保存到 Apache HBase。 好处 AyncHBase 客户端是 Apache HBase 的完全异步和线程安全的客户端。 与传统的 HBase 客户端 (HTable) 不同,每个要与之交互的 HBase 集群只需要一个客户端实例。 即使您想与多个表进行交互。 它避免了不必要的等待线程,即使在同步模式下也允许批量请求并行运行。 客户端提供客户端缓冲,这可能会在您的拓扑中引起一些延迟。 如果您关心延迟,您可以调整默认的 100 毫秒刷新间隔。 这个连接器试图提供灵活性和高性能,非阻塞方式应该减少 Storm 和 HBase 的压力。 我建议您阅读 javadoc 以获取所有更详细的信息。 用法 使用示例可以在s
资源推荐
资源详情
资源评论
收起资源包目录
storm-asynchbase-master.zip (41个子文件)
storm-asynchbase-master
src
main
java
storm
asynchbase
utils
serializer
DoubleSerializer.java 625B
BooleanSerializer.java 656B
AsyncHBaseTimestampSerializer.java 606B
ShortSerializer.java 577B
AsyncHBaseIncrementSerializer.java 620B
AsyncHBaseDeserializer.java 667B
StringSerializer.java 537B
AsyncHBaseSerializer.java 640B
LongSerializer.java 576B
FloatSerializer.java 618B
IntegerSerializer.java 577B
AsyncHBaseClientFactory.java 4KB
example
topology
AsyncHBaseTridentMapStateExampleTopology.java 4KB
AsyncHBaseBoltExampleTopology.java 4KB
AsyncHBaseBoltMapExampleTopology.java 4KB
AsyncHBaseTridentStateExampleTopology.java 5KB
AsyncHBaseTridentExampleTopology.java 6KB
spout
RandomKeyValueBatchSpout.java 3KB
RandomKeyValueSpout.java 2KB
trident
operation
StreamRateAggregator.java 1KB
AverageAggregator.java 1KB
bolt
AsyncHBaseBolt.java 9KB
mapper
AsyncHBaseMapper.java 1KB
IAsyncHBaseFieldMapper.java 2KB
IAsyncHBaseMapper.java 693B
AsyncHBaseFieldMapper.java 40KB
ExtractKeyValuesBolt.java 7KB
trident
state
AsyncHBaseStateUpdater.java 4KB
AsyncHBaseStateQuery.java 3KB
AsyncHBaseMapState.java 10KB
AsyncHBaseStateFactory.java 1KB
AsyncHBaseState.java 3KB
mapper
IAsyncHBaseTridentMapper.java 718B
AsyncHBaseTridentMapper.java 1KB
AsyncHBaseTridentFieldMapper.java 40KB
IAsyncHBaseTridentFieldMapper.java 2KB
operation
ExecuteHBaseRpcs.java 10KB
ExtractKeyValues.java 6KB
README.md 6KB
pom.xml 2KB
.gitignore 119B
共 41 条
- 1
资源评论
我和这个世界
- 粉丝: 22
- 资源: 4616
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- 基于cruise的燃料电池功率跟随仿真,按照丰田氢能源车型搭建,在wltc工况下跟随效果好,最高车速175,最大爬坡30,百公里9s均已实现 1.模型通过cruise simulink联合仿真,策略
- C#源码 上位机 联合Visionpro 通用框架开发源码,已应用于多个项目,整套设备程序,可以根据需求编出来,具体Vpp功能自己编 程序包含功能 1.自动设置界面窗体个数及分布 2.照方式以命令触
- 程序名称:悬架设计计算程序 开发平台:基于matlab平台 计算内容:悬架偏频刚度挠度;螺旋弹簧,多片簧,少片簧,稳定杆,减震器的匹配计算;悬架垂向纵向侧向力学、纵倾、侧倾校核等;独立悬架杠杆比,等效
- 华为OD+真题及解析+智能驾驶
- jQuery信息提示插件
- 基于stm32的通信系统,sim800c与服务器通信,无线通信监测,远程定位,服务器通信系统,gps,sim800c,心率,温度,stm32 由STM32F103ZET6单片机核心板电路、DS18B2
- 充电器检测9-YOLO(v5至v11)、COCO、Create充电器检测9L、Paligemma、TFRecord、VOC数据集合集.rar
- 华为OD+考试真题+实现过程
- 保险箱检测51-YOLO(v5至v11)、COCO、CreateML、Paligemma、TFRecord、VOC数据集合集.rar
- 五相电机邻近四矢量SVPWM模型-MATLAB-Simulink仿真模型包括: (1)原理说明文档(重要):包括扇区判断、矢量作用时间计算、矢量作用顺序及切时间计算、PWM波的生成; (2)输出部分仿
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功