一致性(Consistency model)主要是对存储器上的数据更新和读取规定了一系列规则,使得在这些规则限制下操作数据一定能得到正确的数据。简单理解为,consisten...
 发简信
    
    发简信
  
   
  一致性(Consistency model)主要是对存储器上的数据更新和读取规定了一系列规则,使得在这些规则限制下操作数据一定能得到正确的数据。简单理解为,consisten...
环境 centos7、jdk8、nacos-server-2.2.0.1.tar.gz jdk配置(略) 部署nacos 参照官方文档 https://nacos.io/zh...
1、在gradle文件中导包 2、编写自定义Worker,实现代码逻辑 3、用WorkManager将任务添加到后台 每15分钟执行一次的后台任务 执行一次的后台任务 4、移...
 
  用户行为日志分析是实时数据处理很常见的一个应用场景,比如常见的PV、UV统计。本文将基于Flink从0到1构建一个用户行为日志分析系统,包括架构设计与代码实现。本文分享将完整...
功能: 接收kafka的消息,存储到Hbase表中 导入依赖包 编写HbaseSinkFunction 编写flink处理代码 1. 获取流处理环境 2. 构建kafka数据...
参考官方文档:quickstart[http://kafka.apache.org/quickstart#quickstart_send] 一、准备环境 安装过程(略),关闭...
SpringBoot+Hbase 使用hbase-client,在Spring Boot中实现表创建和查询 一、初始化Spring Boot 登录SpringBoot初始化页...
本次安装环境为centos7,使用虚拟机安装,且为单机部署,不做集群,未使用Hadoop和zookeeper 软件包说明 步骤如下 安装VMware虚拟机,过程略 安装cen...
Hadoop+zookeeper+Hbase部署 一、安装环境和版本说明 最近学习Hbase的集群部署,折腾了三天才弄好,记录一下 centos7、jdk-8u291、had...
搭建工具 Vmware、CentOS-7-x86_64-Minimal-2009、jdk-8u291-linux-x64、hadoop-3.3.1 Hadoop搭建文章参考[...
 
  创建一个Mojo的类,继承AbstractMojo,实现execute方法,我这边设置了一个msg的变量,用于传递文件的根路径,并实现了一个检索该路径下所有的class 在终...
 
  1、下载maven的压缩文件,下载地址直接百度搜索官网下载的,地址:http://maven.apache.org/download.cgi[http://maven.apa...
 
  最近接手老项目,在系统通过接口推送信息时,经常会有部分失败部分推送的情况发生,导致经常需要下游进行数据清理并重新推送。 客户要求保证整体数据的完整性,所以将业务内部逻辑和推送...