flink wordcount demo job
linux 安装bluez并编写小demo运行
之前学了DBus并成功实现简单的通信，现先安装bluez试试，看看能否也可以实现bluez的c语音编程实现广播或者接收等功能 第一步：前往官网下载bluez最新版 http://www.bluez.org/download/. 第二步：下载成功后进行解压 tar xvf bluez-5.66.tar ......
自定义UGUI控件 - 实现一个Text控件Demo
最终效果 就简简单单一个利用Font把文本渲染出来的Demo，文字排版啥的都没没有 using UnityEngine; using UnityEngine.UI; public class MyText : Graphic { public Font m_Font; public string m ......
讯飞离线语音合成新版(Aikit)-android sdk合成 demo（Java版本）
前言：科大讯飞的新版离线语音合成，由于官网demo是kt语言开发的，咱也看不懂kt，搜遍了全网也没看到一个java版的新版离线语音demo，现记录下，留给有缘人参考！！！！！毕竟咱在这上面遇到了不少的坑。如果能留言指正，那就更好了。 ## 第一步： 官网注册账号 》实名认证 》点击语音合成 》离 ......
linux D-bus安装与测试demo
因为linux下通过bluez进行ble开发需要运用到D-bus，但此前对此一窍不通，现开始学习D-bus相关知识。首先便从安装开始 在此过程中参考如下两篇博客 博客1：这里 博客2：这里 首先是进行D-bus各种安装，挨个执行如下指令 sudo apt-get install dbus sudo ......
[scrapy]一个简单的scrapy爬虫demo
# 一个简单的scrapy爬虫demo ## 爬取豆瓣top250的电影名称＋电影口号 使用到持久化流程： * 爬虫文件爬取到数据后，需要将数据封装到items对象中。 * 使用yield关键字将items对象提交给pipelines管道进行持久化操作。 * settings.py配置文件中开启管道 ......
Normalizer_demo
参考：(15条消息) Java之Normalizer(归一化)_java normalizer_oscar999的博客-CSDN博客 (15条消息) 关于Normalizer.normalize()方法的用途_逆光下的轮廓的博客-CSDN博客 全角字符和半角字符的区别 - 知乎 (zhihu.com ......
一文解开主流开源变更数据捕获技术之Flink CDC的入门使用
相比前面介绍maxwell，实时数据采集中最主流技术非Flink CDC莫属，其直接省去中间的消息中间件如kafka，且支持增量采集也支持全量采集；本篇先介绍CDC的技术和分类，进一步了解其特性和支持丰富数据源，最后通过FLink DataStream和SQL两种编程示例解开入门。 ......
React ISR 如何实现 - 最后的 Demo
之前写了两个 `demo` 讲解了如何实现 `SSR` 和 `SSG`，今天再写个 `demo` 说在 `ISR` 如何实现。 ## 什么是 ISR `ISR` 即 `Incremental Static Regeneration` 增量静态再生，是指在 `SSG` 的前提下，可以在收到请求时判定页 ......
Flink任务提交至Yarn的流程分析
# 背景 肯定会有人好奇，我们写的Flink任务代码是如何执行的，本着学习的态度，以flink-yarn的方式，在阅读源码的基础上做一个自己的总结。 # 环境信息 jdk：1.8 scala：2.12 flink：1.13 hadoop:3.0 hadoop相关的环境搭建就不赘述了，参考网上文档即可 ......
InvocationHandler_demo
参考：Java动态代理之InvocationHandler - 知乎 (zhihu.com) (15条消息) java动态代理Proxy.newProxyInstance_一笑而过者也的博客-CSDN博客 (15条消息) Java - 动态代理机制讲解（Proxy.newProxyInstance） ......
【Linux】systemd.timer replace the crontab or at jobs
### systemd 架构 ``` 学习 Systemd 的第一步，就是搞懂"单元"（unit）是什么。 简单说，单元就是 Systemd 的最小功能单位，是单个进程的描述。一个个小的单元互相调用和依赖，组成一个庞大的任务管理系统，这就是 Systemd 的基本思想。 由于 Systemd 要做的 ......
java: Annotation processing is not supported for module cycles....Please ensure that all modules from cycle [ssm-demo-mgt-common,ssm-demo-mgt-task] are excluded from annotation processing
报错内容： java: Annotation processing is not supported for module cycles.Please ensure that all modules from cycle [ssm-demo-mgt-common,ssm-demo-mgt-task] ......
随笔（二十一）『docker 安装 XXL-JOB』
#### 1、拉取镜像 ``` docker pull xuxueli/xxl-job-admin:2.3.1 ``` #### 2、数据库脚本 ``` https://gitee.com/xuxueli0323/xxl-job/blob/2.3.1/doc/db/tables_xxl_job.sq ......
golang入门，基础语法demo（1）
package main import "fmt" func main() { // 声明变量 var a int // 使用 var 关键字声明变量 a，类型为 int a = 1 // 赋值 fmt.Println(a) // 类型推导 // 使用 := 自动推导类型并声明变量 b，其类型为 s ......
Predicate_demo
参考：(15条消息) Java 8 Predicate类基本使用详解_codesWang的博客-CSDN博客 1 package com.hmb; 2 3 import java.util.Arrays; 4 import java.util.List; 5 import java.util.fun ......
聊聊Flink CDC必知必会
CDC是(Change Data Capture变更数据获取)的简称。 核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 ## Flink CDC的设 ......
React SSG - 也写个 Demo 吧
上次写了一个 `SSR` 的 `DEMO`，今天写个小 `Demo` 来从头实现一下 `react` 的 `SSG`，来理解下 `SSG` 是如何实现的。 ## 什么是 SSG `SSG` 即 `Static Site Generation` 静态站点生成，是指将在构建时就提前生成静态 `HTML` ......
PHP用Swoole的WebSocket功能编写聊天室Demo
#### 前提： 1. linux环境下PHP有可用的Swoole扩展。 2. 9501端口可访问。 #### 后端 ```php $value) { if (null $value) { $arr[$key] = ''; } if (is_array($value)) { $arr[$key] = ......
单例模式_demo
参考：(15条消息) 单例模式Demo_zixing08的博客-CSDN博客 单例模式详细解析 - 知乎 (zhihu.com) Singleton.java 1 package com.hmb; 2 3 public class Singleton { 4 private static class ......
xxl-job基本使用
### xxl-job-admin(调度中心)搭建 #### docker arm64架构镜像构建 由于官方没有构建arm64架构的docker镜像，只好自己构建了，下面是详细步骤。 1. 下载源码进行构建，[下载地址](https://github.com/xuxueli/xxl-job/rele ......
Jenkins获取当前job执行的用户名
log="$JENKINS_HOME/jobs/$JOB_NAME/builds/${BUILD_NUMBER}/log" BUILD_USER=$(cat $log |head -n 1|sed -E "s#^.*Started by user##g" |sed -E "s#^.*0m##g" | ......
Flink任务提交流程分析
# 背景说明 在早期的Flink1.9时，为了对Flink任务的进行部署管理，对Flink任务提交的流程进行分析。刚好以前的博客图片失效了，那就用Flink1.13来再读一遍相关源码。 # 任务提交 flink任务提交的起点是flink脚本，以提交至Yarn为例，我们运行wordcount的脚本如下 ......
基于 Flink CDC 构建 MySQL 到 Databend 的 实时数据同步
这篇教程将展示如何基于 Flink CDC 快速构建 MySQL 到 Databend 的实时数据同步。本教程的演示都将在 Flink SQL CLI 中进行，只涉及 SQL，无需一行 Java/Scala 代码，也无需安装 IDE。 假设我们有电子商务业务，商品的数据存储在 MySQL ，我们需要 ......
XXL-job开源框架相关的源码流程解析。
XXL-job框架是一个分布式的定时任务框架。他简单快捷。配置方便。而且用途广泛。所以他的源码非常值得一看。 对于我来说。其中其自写的RPC框架。以及处理发布多个定时任务的高并发处理。是我打开微服务的大门。这是一篇xxl-job源码的解析与流程分析。比较偏口语化。 在这篇随笔中，你能了解到：XXLj ......
DXF解析成运动控制指令DEMO源代码，运动控制软件必备模块。 支持
DXF解析成运动控制指令DEMO源代码，运动控制软件必备模块。支持比例缩放支持按图层解析，各图层可按加工速度、加工参数等分开控制，各图层可选择加工或不加工支持点、直线、圆、圆弧、多段线解析。暂不支持椭圆、样条曲线、文字、填充内容解析。支持任何运动控制平台，接口已预留好，只需增加派生类补充对应平台的指 ......
物联网平台，物联网源码，物联网上位机，物联网DEMO，物联网开发框架。
物联网平台，物联网源码，物联网上位机，物联网DEMO，物联网开发框架。这是一个已经商业化的物联网上位机分离出来的框架，c#语言，含有服务器，客户端，数据库，可以直接运行，系统使用三层设计，层次分明，不同账号可见区域不同。框架已经完成了设备、用户、分组的增删改查，操作日志记录，服务器已经完成和客户端以 ......
add libs to demo project using cmake
``` cmake_minimum_required(VERSION 2.8 FATAL_ERROR) project("demo") set(DEMO_INCLUDE_DIRS "./include") set(DEMO_LIB_DIRS "./lib") message("${DEMO_INCL ......
xxl-job 任务注册
https://www.jianshu.com/p/92f0361dc3d6 官方文档：https://www.xuxueli.com/xxl-job/ 之前和分享了一下对xxl-job的简单理解，这次聊一聊xxl-job任务注册流程和简单的使用方法。 一、XXL-JOB调度数据库表如下： - xx ......
pytest + yaml 框架 -38.新增--start-project命令快速创建项目demo结构
# 前言 新增 `--start-project` 命令， 帮助初学者快速创建项目 demo 结构, 并自动创建几个简单的用例。 # 创建项目demo结构 执行以下命令 ``` pytest --start-project ``` 运行日志 ``` (venv) D:\demo\untitled_s ......
window wsl 无法访问flink webui
[https://blog.csdn.net/weixin_38988171/article/details/126012785](https://blog.csdn.net/weixin_38988171/article/details/126012785) 修改flink配置文件 ``` res ......