FsStateBackend/*** 从Kafka读取数据处理完毕写入Redis*/public class KafkaToRedis {public static void main(String[] args) throws Exception {StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEn

关联MySQL中的维度表示例/*** @Description:* 从Kafka中读数据，然后关联MySQL的维表，最后将结果输出到MySQL中*/public class MySQLDimensionDemo {public static void main(String[] args) {StreamExecutionEnvironment env = StreamExecutionEnvir

kafka-run-class.sh kafka.tools.DumpLogSegments --print-data-log --files ./00000000000000000286.timeindex

shell--buckload数据准备1,zss,23,M2,lss,33,M3,fj,35,F4,ny,42,M5,xq,44,F1)在hbase中创建表create'tb_friends' , 'cf'2) 使用shell命令将数据转换成hfile文件hbase org.apache.hadoop.hbase.mapreduce.ImportTsv \-- 使用类执行操作-Dimporttsv

Region为什么要拆分?随着数据的增加,一个Region管理的数据条数越来越多,出现传统SQL数据库的单节点并发问题,将region拆分,将region移动均衡到其他的节点!1.默认的拆分策略(大小)当region的大小达到一定大小的时候会被拆分IncreasingToUpperBoundRegionSplitPolicysplit策略实现类<property><name&gt