![240](https://upload.jianshu.io/users/upload_avatars/23240184/30b0ca54-b411-4c17-8fc9-a29467ab9767.jpg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
因为项目环境限制,流处理引擎只能使用阿里云 Blink3.3.0 版本,翻阅阿里云官网 Blink 和 GitHub Flink 的Blink分...
设计模式是一套被反复使用、多人知晓的、经过分类编目的、代码设计经验的总结;为了可重用代码、使代码易理解易维护、并保证代码可靠性;设计3大原则:抽...
流数据实时处理一直是大数据领域的重点,随着流引擎的发展,flink正被越来越多人使用,本文主要记录初始学习flink时构建工程的注意事项 一、前...
查询topic列表: 获取消费组消息: 或 若显示 kafka.tools.ConsumerOffsetChecker 不存在,则当前版本kaf...
常用HDFS命令 递归创建目录 查看 上传文件或目录 删除目录 查看最后几行 随机返回指定行数的样本数据: 返回前几行: 复制文件 移动 最后几...
常用hbase shell 命令 条件查询 hbase shell 将结果输出到文件 执行脚本:hbase shell mytest.txt,m...
创建Hbase 表: 插入多列的数据: 创建hive映射表: 建Hive库: 建Hive HBase映射表: 原创不易,转载请注明出处。
使用4种方式进行HBase数据备份 一、使用快照 1.开启快照许可: 2.在hbase sehll中创建快照: 3.退出hbase sehll,...
记录Elasticsearch使用过程中印象深刻的语法结构 基础语法 查看索引 查看安装的插件 创建索引指定分片 创建索引指定分片和字段类型为k...