一、docker介绍1、容器（Container）：(1)概念：容器是一种用于运行和部署应用程序的技术。它将应用程序及其所有依赖项（例如代码、运行时、系统工具、系统库等）打包在一个独立的、可移植的运行环境中，使应用程序可以在不同的计算机上以相同的方式运行。(2)传统虚拟机与容器的区别：①传统虚拟机（virtualmachine）：传统虚拟机技术是在主操作系统上安装虚拟机管理系统(如VMware)，创建出虚拟机，并在虚拟机上安装运行另一个种操作系统，从而安装部署各种应用。②Linux容器（LinuxContainer，LXC）：Linux容器不是模拟一个完整的操作系统，而是从另一个镜像运行，将软
一、端到端精准一次先来讲讲状态一致性状态一致性概念：一致性其实就是结果的正确性。对于分布式系统而言，强调的是不同节点中相同数据的副本应该总是“一致的”。而对于Flink来说，多个节点并行处理不同的任务，我们要保证计算结果是正确的，就必须不漏掉任何一个数据，而且也不会重复处理同一个数据。流式计算本身就是一个一个来的，所以正常处理的过程中结果肯定是正确的；但在发生故障、需要恢复状态进行回滚时就需要更多的保障机制了。状态一致性分类：最多一次（AT-MOST-ONCE）当任务发生故障时，最简单的做法就是直接重启，别的什么都不干；既不恢复丢失的状态，也不重放丢失的数据。每个数据在正常情况下会被处理一次，
Flink系列文章一、Flink专栏Flink专栏系统介绍某一知识点，并辅以具体的示例进行说明。1、Flink部署系列本部分介绍Flink的部署、配置相关基础内容。2、Flink基础系列本部分介绍Flink的基础部分，比如术语、架构、编程模型、编程指南、基本的datastreamapi用法、四大基石等内容。3、FlikTableAPI和SQL基础系列本部分介绍FlinkTableApi和SQL的基本用法，比如TableAPI和SQL创建库、表用法、查询、窗口函数、catalog等等内容。4、FlikTableAPI和SQL提高与应用系列本部分是tableapi和sql的应用部分，和实际的生产应
Flink内置了很多Connector，可以满足大部分场景。但是还是有一些场景无法满足，比如RocketMQ。需要消费RocketMQ的消息，需要自定时Source。一、自定义FlinkRocketMQConsumer参考FlinkKafkaConsumer：publicclassFlinkKafkaConsumerextendsFlinkKafkaConsumerBase{}publicabstractclassFlinkKafkaConsumerBaseextendsRichParallelSourceFunctionimplementsCheckpointListener,ResultT
🎬鸽芷咕：个人主页 🔥个人专栏:《C语言初阶篇》《C语言进阶篇》⛺️生活的理想，就是为了理想的生活!文章目录一、文件和目录操作命令1.1rm删除文件或目录1.3cp1.2mv移动文件或改名1.mv基本用法移动文件：2.mv基本用法强制移动：3.mv基本用法改名：4.不覆盖移动rm-vn1.3dd命令📝全篇总结一、文件和目录操作命令前俩篇我们给大家介绍完了，linux的常用文件操作和目录操作。而今天介绍的命令可就厉害了既可以操作文件又可以操作目录有rmcpmv等快来看看吧！1.1rm删除文件或目录命令名称：rm。英文原意：removefilesordirectories。所在路径：/usr/bi
现实世界中，所有的数据都是以流式的形态产生的，不管是哪里产生的数据，在产生的过程中都是一条条地生成，最后经过了存储和转换处理，形成了各种类型的数据集。如下图所示，根据现实的数据产生方式和数据产生是否含有边界（具有起始点和终止点）角度，将数据分为两种类型的数据集，一种是有界数据集，另外一种是无界数据集。有界数据集有界数据集具有时间边界，在处理过程中数据一定会在某个时间范围内起始和结束，有可能是一分钟，也有可能是一天内的交易数据。对有界数据集的数据处理方式被称为批计算BatchProcessing，例如将数据从RDBMS或文件系统等系统中读取出来，然后在分布式系统内处理，最后再将处理结果写入存储介
一、Git常用命令速查gitbranch查看本地所有分支gitstatus查看当前状态gitcommit提交gitbranch-a查看所有的分支gitbranch-r查看远程所有分支gitcommit-am"init"提交并且加注释gitremoteaddorigingit@192.168.1.119:ndshowgitpushoriginmaster将文件给推到服务器上gitremoteshoworigin显示远程库origin里的资源gitpushoriginmaster:developgitpushoriginmaster:hb-dev将本地库与服务器上的库进行关联gitcheckout
这个问题也可以是如何选专业、职业？1程序员的优势1.1早期可以拿到相对不错的薪资，确保前期发育稳定发育这个事情，一步快则步步快。你快别人一步，领先的不止是一个身位，你发育的速度也更快。就像打游戏，你比别人先升级、先解锁科技树了，你就比别人发育都快很多。别人还在造农民呢，你已经出了步兵了。吃了时代红利的老架构师们就是。1.2程序员早期，可用最少点数获得最优发展路径程序员这个职业的最大优势，就是初期不像其他职业要点多个技能树，而是集中点技术就行了。普通人升级的点数有限，四处瞎点，整体素质就上不了，而程序员不一样，可以用同样的点数，比别人进步更快。比如其他职业要加的点数包括：沟通、情商、各类认证、各
1.查看进程ps-ef|grepjava：ps-ef表示列出所有进程的详细信息，包括进程号、用户、CPU占用率等等，而grep则用于过滤ps-ef命令的输出结果，只显示包含指定关键字的进程信息。ps-ef|greppython可以列出所有正在运行的Python进程信息。top：实时显示系统中运行的进程，按CPU使用率排序。2.查看端口netstat-tulnnetstat-tuln|grep5432lsof-i:5432 3.查看内存占用 free-h4.查看磁盘 df-h：显示所有挂载的文件系统的使用情况，包括文件系统的挂载点、总容量、已用空间、可用空间和使用百分比。du-h：查看文件或目录
1.基本环境 1.17.02.类文件packagecom.flink.tablesql;importorg.apache.commons.io.FileUtils;importorg.apache.commons.lang3.StringUtils;importorg.apache.flink.streaming.api.environment.StreamExecutionEnvironment;importorg.apache.flink.table.api.bridge.java.StreamTableEnvironment;importjava.io.File;importjava
