sockettextstream netcat flink demo
尝试写一个SpringBoot的demo
在Spring官网使用脚手架： https://start.spring.io/ 选择3项依赖： 编写代码： 启动运行应用： 启动了8080端口 访问： http://localhost:8080/hyc 健康检查： http://localhost:8080/actuator/health ......
flink初识
一、flink：apache开源的一款流处理框架，其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和流水线方式执行任意流数据程序，Flink的流水线运行时系统可以执行批处理和流处理程序。此外，Flink的运行时本身也支持迭代算法的执行。 二、Flink是一个计算框架和分布 ......
wpf小说阅读器 ----wpf练习demo
1.登录窗口布局 <Grid> <Grid.ColumnDefinitions> <ColumnDefinition/> <ColumnDefinition Width="2*"/> </Grid.ColumnDefinitions> <Border > <Border.Background> <I ......
locust ——环境安装&demo
一、locust 最优环境 1、python 3.6.x 2、pip install locustio==0.13.5. 为最优，退而求其次是0.14.6 3、浏览器，chrom 4、下载 locustio 的时候，会有三个依赖包，检查一下依赖包的版本，如下图所示 ......
Flink DataStream API
Flink 的 DataSet 和 DataStream 的 API，并模拟了实时计算的场景。 说好的流批一体呢 现状 Flink 很重要的一个特点是“流批一体”，然而事实上 Flink 并没有完全做到所谓的“流批一体”，即编写一套代码，可以同时支持流式计算场景和批量计算的场景。目前截止 1.10 ......
Flink
[官网](https://flink.apache.org/ "官网") ``` https://flink.apache.org/ ``` ##### 下载安装包 ``` https://flink.apache.org/downloads.html https://dlcdn.apache.or ......
JAVA调用ABAP RFC接口-DEMO
package com.swift.oa; import com.sap.conn.jco.*; /** * @Author: Wriprin * @Date: 2022/11/25 17:20 * @Version 1.0 */ public class GetMaraInfo { public ......
Cipher_demo
参考：Java使用Cipher类实现加密，包括DES，DES3，AES和RSA加密 - 蔡昭凯 - 博客园 (cnblogs.com) Main.java 1 package com.hmb; 2 3 import javax.crypto.*; 4 import javax.crypto.spec ......
js 作用域 demo
var a=1; console.log(a); if(true){ console.log(a); a = 5; function a(){}; function b(){}; a = 0; console.log(a); }; console.log(a); console.log(b); ......
Flink 核心技术与实战
你将获得 熟练掌握 Flink SQL 接口的原理与操作方法； 深入理解 Flink DataStream API 的实践原理； 全面剖析 Flink Runtime 的设计与实现机制； 完整构建一个实时推荐数据流系统。 课程介绍目前大部分公司的大数据处理工作，使用的还是离线处理技术，但未来，流式计 ......
虚拟机安装Flink步骤
1、先下载一个flink ,下载地址：https://flink.apache.org/downloads.html#apache-flink-172 2、通过xshell的FTP复制到虚拟机文件夹/usr/flink下 3、执行命令解压：tar -zxvf flink-1.15.0-bin-sca ......
【前端教程02】js拖拽布局demo
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <meta http-equiv ......
electron react 简单demo
##1 使用cra 创建 项目 `npx create-react-app center-tools` ##2 安装依赖 ` yarn add electron electron-builder cross-env wait-on concurrently --dev` ` yarn add ele ......
Flink的JobManger-Dispatcher执行流程
# 背景 通过命令行向Flink集群提交任务，都经过哪些环节，中间的调用关系是什么。 这里以Yarn模式为例，通过Flink任务提交至Yarn集群，由Yarn的AM开始执行Flink代码作为入口，尝试进行分析。 Flink里的代码调用关系比较复杂，这里只列了部分关键点，太过于琐碎的代码就没有具体深入 ......
记录--写一个高德地图巡航功能的小DEMO
这里给大家分享我在网上总结出来的一些知识，希望对大家有所帮助 风格设置 加载地图 使用AMapLoader.load加载地图，从 控制台 申请一个属于自己的key import AMapLoader from '@amap/amap-jsapi-loader'; ... const AMap = a ......
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） ......
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] ......
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` ......