flink demo
写了一个flinkcdc的简单demo，大概说一下实现过程和建议点
架构图大致如下： 版本信息大致如下，具体版本信息根据自己的需求进行调整即可： oracle：19c flinkcdc：2.4.0 kafka：3.1.2 flink：1.15.4 mysql：8.0.27 springboot：2.5.6 实现需求： 1.使用flinkcdc采集oracle中的数据 ......
使用Flink完成流数据统计
Flink程序构建的基本单元是stream和transformation（DataSet实质上也是stream）。stream是一个中间结果数据，transformation对数据的加工和操作，该操作以一个或多个stream为输入，计算输出一个或多个stream为结果，最后可以sink来存储数据。 ......
flink事件时间的水印延迟不会导致延迟数据在上一个窗口内
设窗口为5，延迟为3。 假如数据为：0 1 2 5 6 7 3 4 8 则两个窗口为 ： window = TimeWindow{start=0, end=5} 0 1 2 3 4 window = TimeWindow{start=5, end=10} 5 6 7 8 即：5 6 7 的数据不会包 ......
真机调试 Flutter 报错：Lookup failed: title in @getters in MyHomePage in package:flutter_demo02/main.dart
发生缘由 学习 Flutter 更改 lib 目录下面的 main.dart 文件之后真机调试运行 flutter run 报错： 1 # 小组件库异常 2 ══╡ EXCEPTION CAUGHT BY WIDGETS LIBRARY ╞══════════════════════════════ ......
C#读取SQL数据库，并将读取的数据上传至服务简易Demo
1.使用的NuGet包 2.IRepository 接口 { IEnumerable<Package> GetAllPackages(); void DeleteByCodePackages(string code); // void InitRepository(); } 3.SimpleRepo ......
kafka数据入paimon（flink-sql）
1.创建CATALOG CREATE CATALOG paimon_hive WITH ( 'type' = 'paimon', 'metastore' = 'hive', 'uri' = 'thrift://hadoopm111:9083', 'warehouse' = 'hdfs:///apps ......
Flink State 状态原理解析
State 用于记录 Flink 应用在运行过程中，算子的中间计算结果或者元数据信息。运行中的 Flink 应用如果需要上次计算结果进行处理的，则需要使用状态存储中间计算结果。如 Join、窗口聚合场景。 ......
vue3 demo
<script setup> import { computed, ref } from "vue"; // const blog = ref({ // title: "Vue3 基础教程", // content: "Vue3 在 Vue2 的基础上做了很多优化", // link: "https ......
js定时器demo
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Document< ......
jmeter测试计划中的“独立运行每个线程组”Demo演示
一：jmeter的运行顺序 测试计划-->线程组 其次执行顺序为：配置元件、前置处理器、定时器、取样器、后置处理器、断言、监听器 当一个测试计划中有多个线程组，当多个线程组都是是执行状态时，就会用到测试计划中的 “独立运行每个线程组”勾选框 不勾选时的执行顺序如下：测试计划中的多个线程组按照并发逻辑 ......
软件工程第九组-卡卡记账Demo
小组成员分工 郝文章：小程序主界面 申子昂：小程序个人界面 王龙龙和邹宇鹏：小程序订单界面 邹宇鹏和胡致文：SpringBoot后端程序 download 微信 SpringBoot ......
LWIP官方DEMO使用之httpd服务
前言 LWIP的移植可以参考上篇文章 《HC32F4A0 lwip移植 - USTHzhanglu - 博客园 (cnblogs.com）》 参数 MCU型号 HC32F4A0PIHB 库版本 HC32F4A0_DDL_Rev2.0.0 LWIP版本 lwip-STABLE-2_2_0_RC1 PH ......
redis_demo
redis安装：Redis 安装 | 菜鸟教程 (runoob.com) redis概念：Jedis入门 - 知乎 (zhihu.com) jedis参考demo：Jedis入门教程_jedis教程-CSDN博客 模块目录结构： pom.xml: <project xmlns="http://mav ......
h5新增标签demo【+清空浮动】
直接上代码 <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Doc ......
NaLLM Demo
NaLLM 项目总结 前后端分离，前端Vue3，后端Fastapi 项目的整体界面如图： 主要实现三种功能： Unstructured Import：实现非结构化文本的知识图谱提取和实体关系、去重等操作，最终返回提取的实体、关系和对应的属性，本项目也提供了将原始提取结果转换为CSV文件的类，便于结果 ......
int和long的计算demo6
public class demo06 { public static void main(String[] args) { int money=10_0000_0000; System.out.println(money); int year=20; int total=money*year;// ......
类型转换demo05
import com.sun.security.jgss.GSSUtil;public class demo05 { public static void main(String[] args) { int i=130; byte b=(byte) i;//内存溢出 //类型转换 byte(字节）, ......
大型数据库实验八--Flink初级编程实践
 ![](https://img2023.cnblogs.com/blog/2808014/202311/2808... ......
通过Java-Netty实现一个简单的HTML实时聊天——demo
demo效果 初步准备 想要实现聊天就需要用到WebSocket，他是专门用于http进行实时聊天的的协议。因为主要核心在后端开发，所以我去白嫖了个超级简单的界面（就是不会！） 我编写demo时系统环境为Win-11，Java-8 环境依赖 只需要一个netty即可实现需要的功能 <!--netty ......
最新demo版 | 如何0-1开发支付宝小程序之小程序如何上线（四）
支付宝小程序开发 0-1 系列前三期详见： 最新demo版｜如何0-1开发支付宝小程序之前期准备篇（一） 最新demo版 | 如何0-1开发支付宝小程序之如何调试小程序（二） 最新demo版 | 如何0-1开发支付宝小程序之小程序页面功能介绍（三） 那么，今天让我们一起探索一下小程序开发的最后一步 ......
Linux驱动开发笔记（五）：驱动连接用户层与内核层的文件操作集原理和Demo
前言 驱动写好后，用户层使用系统函数调用操作相关驱动从而实现与系统内核的关联，本篇主要就是理解清楚驱动如何让用户编程来实现与内核的交互。 杂项设备文件操作集 cd /usr/src/linux-headers-4.18.0-15 vi include/linux/fs.h 搜索到（vi则直接使用“/ ......
WebRTC demo
HTML版WebRTC，可本地运行。 <!DOCTYPE html> <html> <head> <meta charset="utf-8" /> <title>WebRTC</title> </head> <body> <video autoplay playsinline></video> <d ......
Flink实战(11)-Exactly-Once语义之两阶段提交
0 大纲 [Apache Flink]2017年12月发布的1.4.0版本开始，为流计算引入里程碑特性：TwoPhaseCommitSinkFunction。它提取了两阶段提交协议的通用逻辑，使得通过Flink来构建端到端的Exactly-Once程序成为可能。同时支持： 数据源（source） 和 ......
Vue项目demo
企业级项目目录 api接口模块：发送ajax请求的接口模块 utils工具模块：自己封装的一些工具方法模块 Vant 组件库 第三方组件库：https://vant-contrib.gitee.io/vant/v2/#/zh-CN/ 引入组件 方式一. 自动按需引入组件 (推荐) babel-plu ......
Extjs应用tab页的最简单Demo
<html> <head> <title>Extjs应用tab页的最简单Demo</title> <link rel="stylesheet" type="text/css" href="theme-gray-all.css" /> <script type="text/javascript" sr ......
Flink源码解析(六)——数据分区解析
一、数据分区概念 对分布式计算引擎来说，数据分区的主要作用是将现环节的数据进行切分，交给下游位于不同物理节点上的Task计算。 二、Flink数据分区接口体系 1、顶层接口ChannelSelector (1).setup()方法设置下游算子的通道数量。从该接口中可以看到，算子里的每一个分区器都知道 ......
最新demo版 | 如何0-1开发支付宝小程序之小程序页面功能介绍（三）
前两期讲了小程序开发的准备工作以及前期需要如何调试，今天我们就来介绍下开发一个支付宝小程序页面需要了解哪些信息。 一个小程序页面的整体功能的构成离不开页面展示（AXML）、页面样式（ACSS）以及页面逻辑（JS）这三方面，下面本文将从这三方面具体展开。 一、AXML(组件) AXML 页面一般用来做 ......
flink入门程序
flink入门程序 生成项目 mvn archetype:generate -DarchetypeGroupId=org.apache.flink -DarchetypeArtifactId=flink-quickstart-java -DarchetypeVersion=1.16.4 wordco ......
【干货】Ehome demo工具的详细使用方法
关注小编的都知道，除了日常方案与各类技术难题，小编也会经常分享一些技术干货。今天小编就给大家介绍一下Ehome demo工具的详细使用方法。利用该工具可以测试和调试海康监控设备。 具体步骤如下： 1、选择所需IP； 2、如果是测试本地设备，即配置本地ip； 3、若是测试公网设备，配置公网ip即可。 ......
[Flink] Flink(CDC/SQL)Job在启动时，报“ConnectException: Error reading MySQL variables: Access denied for user 'xxxx '@'xxxx' (using password: YES)”（1个空格引发的"乌龙"）
1 问题描述 1.1 基本信息 所属环境：CN-PT 问题时间：2023-11-21 所属程序: Flink Job(XXXPT_dimDeviceLogEventRi) 作业类型： Flink SQL Job 数据流 : 业务MySQL ==> Flink Job( Flink Cdc Conne ......