flink sql client:upsert-kafka connector

一、安装1.1、安装参考1.2、 修改默认端口涉及配置文件vim /etc/gitlab/gitlab.rb修改ngnix 端口nginx['listen_port'] = 18788#默认80端口修改unicorn端口unicorn['port'] = 18787#默认8080vim /var/opt/gitlab/nginx/conf/gitlab...

一、Hive动态分区插入数据时,由于乱码导致动态分区为乱码,无法删除,1.1.删除hdfs下分区找到表的路径， 删除分区表的hdfs目录desc extended TABLENAME;hdfs dfs -rm -f filePath;###1.2、删除MySQL下的元数据信息####1.2.1、找到tbl_idSELECT TBL_IDFROM TBLS WHERE...

二、算法介绍2.1、apriori算法

文章目录一、什么是数据湖？1.1、数据湖概述1.2、为什么需要数据湖？1.3、数据湖架构1.3.1、来源1.3.1.1、同质来源1.3.1.2、异构来源1.3.1.3、数据湖架构主要使用以下来源：1.3.2、数据处理层1.3.3、目标1.4、数据湖的优点与风险1.4.1、优点1.4.2、风险二、数据湖与数据仓库关注我的公众号【宝哥大数据】，更多干货一、什么是数据湖？1.1、数据湖概述是一个集中式存

flinksql -- join

1、需要添加elasticsearch-hadoop-version.jar, version对应集群的版本，2、代码# encoding=UTF-8# -*-coding:UTF-8-*-import jsonfrom pyspark.sql import SparkSession# 设置doc_iddef addId(data):return (data['id'], json.dumps(d

原理：数学原理，根据随机选择XY为-1到1的点落在半径为1的圆内的概率在一个边长为2的正方形内画个圆，正方形的面积 S1=4，圆的半径 r=1，面积 S2=πr^2=π现在只需要计算出S2就可以知道π，这里取圆心为坐标轴原点，在正方形中不断的随机选点，总共选n个点，计算在圆内的点的数目为count，则 S2=S1*count/n，然后就出来了package com.chb.scala...

hive到hbase

前言本文开始，将开始学习7种结构型模式：适配器模式、装饰模式、代理模式、外观模式、桥接模式、组合模式、享元模式。其中对象的适配器模式是各种模式的起源一、适配器模式1.1、类的适配器模式更形象的展示：代码展示public class Source {public void srcMethod() {System.out.println("我连接usb接口");}