sockettextstream netcat flink demo
在flink-1.17中测试执行流处理版本的单词计数程序时，出现"Exception in thread "Thread-5" java.lang.IllegalStateException: T
场景描述 采用 单作业模式提交作业后发现报错了 报错内容 Exception in thread “Thread-5” java.lang.IllegalStateException: Trying to access closed classloader. Please check if you ......
GPT之路(七) LangChain AI编成框架入门的第一个demo
环境：Python 3.11.4， LangChain 0.0.270 1.Langchain 简介 1.1 Python Langchain官方文档 大型语言模型（LLM）正在成为一种具有变革性的技术，使开发人员能够构建以前无法实现的应用程序。然而，仅仅依靠LLM还不足以创建一个真正强大的应用程序 ......
chatgpt使用python写一段二分查找的demo
以下是一个Python实现的简单二分查找算法的代码示例： def binary_search(arr, target): left, right = 0, len(arr) - 1 while left <= right: mid = (left + right) // 2 # 找到中间元素的索引 ......
mupdf实用操作demo，C++操作PDF文件
前文： 最近有个项目，需要读写PDF，本来想着挺简单的，读写PDF有那么多的库可以使用，唰唰的就完成了。 忘记了我写C++的，还是在国产系统上开发的。 所以一般的东西还不好使，因为项目需要在多个架构的电脑上使用，所以必须要开源，还要支持读写才行。 找了很多个PDF库（libharu、mupdf、pd ......
[Flink] Flink Demo Job : WordCount
# 1 序言 + 本文章是博主正式入门学习、实践大数据流批一体数据处理的Flink框架的第1篇文章，本文是根据参考文章做完实验后的过程总结、技术总结。  实时计算（Flink）_企业版产品简介_全栈云平台_企业版 (aliyun.com) ......
RK3568开发笔记（七）：在宿主机ubuntu上搭建Qt交叉编译开发环境，编译一个Demo，目标板运行Demo测试
前言 在之前的博文中已经搭建好了一个比较完善的ubuntu宿主机，都很完善了但是发现没有Qt交叉编译开发环境，所以还需要搭建一套Qt交叉编译开发环境。 补充说明 本篇是基于《RK3568开发笔记（三）：RK3568虚拟机基础环境搭建之更新源、安装网络工具、串口调试、网络连接、文件传输、安装vscod ......
LiteDB Demo 简单封装
自己学习写了个Demo,简单封装了一下,有需要的可以拿去玩玩gitee地址 LiteDB 是一个 .NET 开发的小型快速轻量级的 NoSQL 嵌入式数据库，特性：无服务器 NoSQL 文档存储简单的 API，类似于 MongoDB单个 DLL（小于 450kb）中的.NET 4.5 / NETSt ......
从 Flink 1.17 开始，flink 发行版本不再包含 flink-connector-jdbc, link-connector-jdbc 成为独立的项目，与 flink 主版本解耦
github地址如下：apache/flink-connector-jdbc: Apache flink (github.com) Flink 1.17 自定义 MySQL Catalog - Flink菜鸟 - 博客园 (cnblogs.com) ......
word_demo
 点击查看代码 ``` using Aspose.Words; using Aspose.Words.Ta ......
django curd demo
Update View refers to a view (logic) to update a particular instance of a table from the database with some extra details. It is used to update entrie ......
Flink使用
# 环境 ## 版本 flink-1.16.0-bin-scala_2.12.gz ## 复制jar `flink-sql-connector-mysql-cdc-2.3.0.jar`：监听MySQL数据变更。 `flink-sql-connector-tidb-cdc-2.3.0.jar`：监听t ......
FLink
java.util.concurrent.TimeoutException: Invocation of [RemoteRpcInvocation(TaskExecutorGateway.requestSlot(SlotID, JobID, AllocationID, ResourceProfile ......
Flink SQL基本语法
在 flink sql 中，对表名、字段名、函数名等是严格区分大小写的，为了兼容 hive 等其他仓库，建议建表时，表名和字段名都采用下划线连接单词的方式，以避免大小写问题。 比如 hive ，是不区分大小写的，所有大写字母最终都会被系统转化为小写字母，此时使用 flink sql 去读写 hive ......
SpringBoot项目报java.lang.IllegalStateException: Cannot load configuration class: com.imooc.demo.DemoApplication
报错摘要： java.lang.IllegalStateException: Cannot load configuration class: com.imooc.demo.DemoApplication， Caused by: java.lang.ExceptionInInitializerErr ......
二分法demo
# 1.python实现 ```python from math import floor arr = [1, 2, 3, 4, 5, 6, 8, 9, 10, 11] left = 0 right = len(arr)-1 res = 7 while (left res): right = mid ......
网页聊天框demo
## 效果图  ## css 代码 ``` body { background-color: gray; } .ch ......
vue组件切换_demo
项目参考：36_动态组件_哔哩哔哩_bilibili 项目结构： App.vue <template> <component :is="Component"></component> <button @click="switchHandle">switch Component</button> </ ......
vue3入门_demo
新建项目参考：Vue vscode 创建 vue 项目流程【超详细】_vue vscode 创建 vue 项目流程【超详细】_怎么用vscode写vue_一颗不甘坠落的流_一颗不甘坠落的流星的博客-CSDN博客 项目结构： App.vue <template> <Main></Main> </tem ......
一个CSS动画的demo
.lineBarDis { height: 8px; background-image: linear-gradient(to right, #011c72 0%, #c7ced2 100%); animation: myAnimation 1.5s infinite; /* 设置动画为2秒钟的时间 ......
拖拽demo
<!DOCTYPE html><html> <head> <meta charset="utf-8"> <title></title> <script src="js/echarts.5.4.3.js"></script> </head> <body> <div id="main" draggabl ......
sqlsugar 增删改查 demo
1.sqlsugar 增删改查 demo entity query: var getAll = db.Queryable().ToList(); var getAll2 = db.Queryable().Select(x => x.CreateTime.Date).ToList(); var get ......
Flink SQL 数据类型
Flink SQL 为用户提供了一系列丰富的原始数据类型。 数据类型 | Apache Flink https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/ 翻译 搜索 复制 ......
Flink-读Kafka写Hive表
1. 目标 使用Flink读取Kafka数据并实时写入Hive表。 2. 环境配置 EMR环境：Hadoop 3.3.3, Hive 3.1.3, Flink 1.16.0 根据官网描述： https://nightlies.apache.org/flink/flink-docs-release-1 ......
Flink的3中API
DataStream/DataSet/Table API是Apache Flink提供的三种不同的API，用于处理不同类型的数据和实现不同的计算模型。 1. DataStream API：DataStream API是基于流式数据的API，用于处理连续不断到达的数据流。它适用于实时数据处理和流式计算 ......
c#在MVC Api（.net framework）当中使用Swagger，以及Demo下载
Demo下载地址。 主要的步骤就是创建项目，通过nuget 添加Swashbuckle包，然后在SwaggerConfig当中进行相关的配置。 具体的步骤，可以参考下面的链接： https://www.cnblogs.com/94pm/p/8046580.html https://blog.csdn ......
flink用户自定义连接器(http连接器)
1、Flink用户自定义连接器（Table API Connectors）学习总结_flink自定义连接器_董可伦的博客-CSDN博客 2、官网介绍： https://nightlies.apache.org/flink/flink-docs-release-1.17/zh/docs/dev/tab ......