没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
flink-kafka-hbase 功能:实现kafka消息实时落地hbase,支持csv/json字符串两种格式的消息,支持自定义组合rowkey,列簇和列名,支持按照kafka消息流中不同字段join不同的hbase表,并自定义写入列簇和列(join时需评估一下性能) 支持at least once语义 外部依赖:apollo配置中心,本项目依靠配置驱动,配置存储在apollo配置中心 配置: { "indexColumnMapping": { --indexColumnMapping即CSV格式消息的key和value按照value里的分隔符拼接后再分割后下标及写入hbase列的对应关系 "0": "basic:time", --第0列始终是kafka消息的key,如果不需要可以不指定 "1": "basic:user_id",
资源推荐
资源详情
资源评论
收起资源包目录
flink-kafka-hbase-master.zip (18个子文件)
flink-kafka-hbase-master
src
main
resources
logback.xml 534B
application.conf 40B
java
com
singgel
bigdata
flinksinkhbase
config
JobConfig.java 7KB
KafkaConfig.java 3KB
HbaseConfig.java 2KB
HbaseSink.java 15KB
FlinkRunner.java 3KB
common
HbaseUtil.java 6KB
CustomJsonDeserializationSchema.java 2KB
JobConfigManager.java 2KB
ValueFormat.java 247B
JoinTable.java 2KB
test
resources
logback.xml 2KB
java
com
singgel
bigdata
recommend
HbaseGetTest.java 8KB
HbaseByteTest.java 746B
JobConfigTest.java 9KB
pom.xml 5KB
README.md 26KB
共 18 条
- 1
资源评论
荒腔走兽
- 粉丝: 25
- 资源: 4663
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功