相关文章
Flink知识点总结 Flink简介
Flink简介 Flink 是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。并且 Flink 提供了数据分布、容错机制以及资源管理等核心功能。Flink提供了诸多高抽象层的API以便...
【入门教程】Eureka快速起步
Eureka [源码：](https://github.com/benwang6/spring-cloud-repo) Eureka的四条运行机制： 注册 客户端会反复注册，直到注册成功 拉取 客户端...
数据仓库工具Hive的安装和配置
是一个基于 ，可以将结构化数据映射到 的分布式文件系统上，并提供SQL查询功能。以下是 步骤： 1. Java环境： 需要Java环境支持，可以通过以下命令 ： sudo apt-get instal...
大数据技术基础知识总结六
抵扣说明： 1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。 2.余额无法直接购买下载，可以购买VIP、C币套餐、付费专栏及课程。 Original: https://blog.cs...
预备知识-python核心用法常用数据分析库（下）
导读： 验证码作为网络安全的第一道屏障，其重要程度不言而喻。当前，卷积神经网络的高速发展使得许多验证码的安全性大大降低，一些新型验证码甚至选择牺牲可用性从而保证安全性。针对对抗样本技术的研究，给验证码...
运维笔记–Docker方式部署rabbitmq & 延时队列插件
1. 安装： docker pull rabbitmq:3.7.21-management [root@test ~]# docker images REPOSITORY TAG IMAGE ID C...
微服务技术栈02-服务拆分+远程调用+注册中心
2.服务拆分及远程调用 任何分布式架构都离不开服务的拆分，微服务也是一样。 2.1.服务拆分原则 这里我总结了微服务拆分时的几个原则： 不同微服务，不要重复开发相同业务 微服务数据独立，不要访问其它微...
eureka+configserver+gateway集群使用https/http2
本文介绍spring cloud 集群配置https 。 ssl证书的生成这里就不再赘述，网上有一大堆。 集群成员 eureka：注册中心 configserver：配置中心 gateway：网关 其...
Linux快速入门(六)Linux网络管理
导读： 验证码作为网络安全的第一道屏障，其重要程度不言而喻。当前，卷积神经网络的高速发展使得许多验证码的安全性大大降低，一些新型验证码甚至选择牺牲可用性从而保证安全性。针对对抗样本技术的研究，给验证码...
【运维心得】为什么Kafka也算消息队列？
之前的系统中使用了Kafka，不过对于Kafka的运行机制一直不太了解，同时也不知道为啥别人都说它比其他三个著名的消息队列更好用。今天就把积累出来的认知总结一下，便于今后自己学习和记忆，主要是个人的理...
flink-sql中hive-join碰到的问题
title: flink-sql中hive-join碰到的问题 date: 2021-12-22 23:41:20 tags: [flink,sql,hive,join] categories: fl...
kafka re-blance 重平衡、堆积、自动提交
因为公司的项目是由一个第三方的旧系统迁移过渡开发过来的，而且时间很急，所以有许多数据需要修正。为了不影响线上的业务，修复数据的逻辑是在另一个应用的，可以通过管理系统圈定数据范围，然后发送到kafka。...
Flink CDC同步 MySQL 分库分表分片数据
mysql-cdc支撑正则表达式的库名表名来匹配多个库多个表来获取分库分表情况下的mysql数据。只需要在创建flink源表时在数据库和表名上使用正则匹配即可。 建表语句: DROP TABLE IF...
Dockerfile 指令 VOLUME 介绍（转）
1）容器是基于镜像创建的，最后的容器文件系统包括镜像的只读层+可写层，容器中的进程操作的数据持久化都是保存在容器的可写层上。一旦容器删除后，这些数据就没了，除非我们人工备份下来（或者基于容器创建新的镜...
Apache Flink源码解析-StreamOperator接口实现
1、StreamOperator接口实现 如图所示，StreamOperator的定义如下 图1- StreamOperator接口 StreamOperator接口主要包括如下核心方法 open()...