1 spark将hive上的数据同步到hbase将hive数据转换为hfile, 快速导入hbase ,里面有很多坑.比如 : 版本不一致.还有就是本地版本和集群版本不一致导致class不存在.写hbase代码最好是使用java和scala。我这里使用的是spark2.4 + hbase 2.1 切记不同版本使用的方法不一样。2 代码package com.test.taskimport java

1 spark将HDFS上的数据同步到hbase将hdfs数据转换为hfile, 快速导入hbase2 pom.xml<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-

1、mysql广播和kafka流合并主要应用于实时流关联广播.主要应该与实时流关联mysql上规则增加关联性.2、代码package com.funcimport com.bean.BuriedPointDetailBeanimport org.apache.flink.api.common.state.MapStateDescriptorimport org.apache.flink.strea

Flink实时标签，实时ETL