sockettextstream netcat flink demo
实现一个签名效果demo
直接上代码 <!DOCTYPE html> <html> <head> <title>横屏签名页面</title> <style> canvas { border: 1px solid #000; touch-action: none; } button { margin-top: 10px; } ......
vue demo
要使用此模板，请使用 vue-cli搭建项目。建议使用npm 3+以获得更有效的依赖关系树。 $ npm install -g vue-cli $ vue init webpack my-project $ cd my-project $ npm install $ npm run dev ......
Springboot+ShardingJDBC实现分库分表最简Demo
概述 本文介绍如何使用当前比较成熟的分库分表框架 Sharding-JDBC 实现分库分表，读写分离，以及自定义分库分表算法。 详细 1. Sharding-JDBC 简介 Sharding-Sphere 是一套开源的分布式数据库中间件解决方案组成的生态圈，它由 Sharding-JDBC、Shar ......
Field userClient in com.demo.order.service.OrderService required a bean of type'com.demo.feign.clients.UserClient' that could not be found.
在SpringCloud项目中使用Feign进行远程调用遇到的错误。原因是因为UserClient在com.demo.feign.clients包下面，而order-service的@EnableFeignClientd注解却在com.demo.order包下面，这两个不在同一个包下，无法扫描到Us ......
flink之java.lang.NumberFormatException: For input string错误
场景： 使用flink读取一张hudi表，将数据写入到另外一张hudi表。 错误栈： java.lang.NumberFormatException: For input string: "test_table" at java.lang.NumberFormatException.forInput ......
【小小demo】SpringBoot+Layui登录
easy-login 基于layui 注册、登录简单实现，并他通过拦截器拦截未登录请求。 项目地址文章末尾 登录拦截器 SystemInterceptor preHandle在 Controller 之前执行，因此拦截器的功能主要就是在这个部分实现： 检查 session 中是否有user对象存在； ......
flink中的Keyed State
Keyed state是指在Flink中与一个特定key相关联的状态。在Flink中，数据被分区并按key分组。当数据流被分区和分组后，每个key都有一个对应的状态，这就是Keyed state。它可以用于计算窗口、聚合操作和连续查询等。Keyed state通常用于在流处理中跟踪关键得分、计数或其 ......
flink的事件时间、摄取时间、处理时间
在Flink中，事件时间、摄取时间和处理时间是用于处理流数据的三种时间概念。这三种时间概念分别反映了不同程序处理的时间特征。下面分别介绍它们的定义及区别： 事件时间（Event Time）: 事件时间是指事件在数据源端实际发生的时间，通常信息保存在事件数据的元数据或者是数据内容中。事件时间允许Fli ......
demo
在微服务中，整合Spring Security功能。将系统模块（涵盖用户、菜单等功能的模块）与Spring Security进行分离，使Spring Security作为一个单独的依赖存在，使用自动配置的方式配置进使用该依赖的模块当中。 处理流程 sequenceDiagram participan ......
lambda表达式运用 ----demo
点击查看代码 public class test { public static void main(String[] args) { List<User> list = new ArrayList<>(); list.add(new User(21L, "张三")); list.add(new U ......
Flink创建Hudi的Sink动态表
工厂类 HoodieTableFactory 提供的创建动态表接口 createDynamicTableSource 和 createDynamicTableSink，对应的源码文件为：https://github.com/apache/hudi/blob/master/hudi-flink-dat ......
Hudi的Flink配置项（1）
名词 FallbackKeys 备选 keys，可理解为别名，当指定的 key 不存在是，则找备选 keys，在这里指配置项的名字。 相关源码 FlinkOptions // https://github.com/apache/hudi/blob/master/hudi-flink-datasour ......
启动flink显示ERROR: JAVA_HOME is not set and could not be found.
问题： JAVA_HOME存在，但启动flink时出现ERROR: JAVA_HOME is not set and could not be found. 原因： 环境变量加载顺序不对 # /etc/profile.d/hadoop.sh # ... export HADOOP_CLASSPATH ......
【小小Demo】在线聊天小🌰子
easy-chat 一个简单的即时通讯demo。 环境 jdk1.8 idea maven springboot 2.1.1.RELEASE websocket 项目启动 修改maven设置 打开IDEA 设置：File>Setting>Build,Exec... 如下图所示 启动 找到启动类，鼠标 ......
【小小Demo】网页视频通话
工程名 video-call 一个简单的 音视频通话 demo，包含：视频、麦克风、屏幕共享操作。 项目环境 jdk1.8 idea maven springboot 2.1.1.RELEASE websocket thymeleaf 项目启动 修改maven设置 打开IDEA 设置：File>Se ......
flink Connecting to remote task manager 'localhost/127.0.0.1:44489
问题： 启动集群后，执行任务时失败： Caused by: org.apache.flink.runtime.io.network.partition.consumer.PartitionConnectionException: Connection for partition 47d4a41224 ......
Flink Cdc MySQL 整库同步到 StarRocks
这段时间开始调研使用 StarRocks 做准实时数据仓库：flink cdc 实时同步数据到 StarRocks，然后在 StarRocks 中做分层计算，直接把 StarRocks 中的 ADS 层提供给 BI 查询。架构如下： 由于用到的表比较多，不能用 Flink SQL 给每个表都做个 C ......
Flink 1.17 自定义 MySQL Catalog
Catalog 类型 以下内容来自官网： Hive Catalog 支持Flink 元数据的持久化存储，以前一直用 Hive Catalog 存，偶尔需要用的时候把 Hive Catalog 开启（需启动 hive metastore 和 hiveserver2，还要启动 Hadoop），大部分时候 ......
js postMessage demo
npm i http-server -g http-server -p 8881 http://localhost:8881/ main.html <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta http-eq ......
【新鲜出炉的个人项目】基于 Flink 的商品推荐系统
Recs FlinkCommodityRecommendationSystem(基于 Flink 的商品推荐系统) 1. 前言 系统取名为 Recs，灵感源于 Recommendation System。logo 使用在线 logo 网站制作。作者开发该项目，是为了学习 Flink 以及相关大数据中 ......
# vue 使用 threejs 实现实景看房效果 demo
vue 使用 threejs 实现实景看房效果 demo 关于这个 threejs 实现 VR 看房效果也超级简单，只需要提供一个思路的话就可以了其实，首先需要一个房间结构的贴图，这个贴图网上有，当然找个合适的也不好找，我找了一上午在别人的 demo 里面扣了一张出来，代码都是一样的，稍微说一下思路 ......
自动驾驶图像全景分隔，基于HRnetSegmentation从训练工程到tensorRT工程部署Demo闭环一套，包含训练工程及?
自动驾驶图像全景分隔，基于HRnetSegmentation从训练工程到tensorRT工程部署Demo闭环一套，包含训练工程及部署工程，和环境的配置说明，已在实际项目中使用。大厂自动驾驶工程师沉淀实实在在的工作经验总结资料是一线自动驾驶工程师辛苦工作的结果。ID:3150671806789047 ......
自动驾驶图像分类，基于HRnet从训练工程到tensorRT工程部署Demo闭环一套，包含训练工程及部署工程，和环境?
自动驾驶图像分类，基于HRnet从训练工程到tensorRT工程部署Demo闭环一套，包含训练工程及部署工程，和环境的配置说明，已在实际项目中使用。大厂自动驾驶工程师沉淀资料是一线自动驾驶工程师辛苦工作的结果ID:5150672485127196 ......
自动驾驶车道线检测，基于LaneLine Detect从训练工程到tensorRT工程部署Demo闭环一套，包含训练工程及部署?
自动驾驶车道线检测，基于LaneLine Detect从训练工程到tensorRT工程部署Demo闭环一套，包含训练工程及部署工程，和环境的配置说明，已在实际项目中使用。大厂自动驾驶工程师沉淀实实在在的工作经验总结资料是一线自动驾驶工程师辛苦工作的结果ID:7950671420904511 ......
flink平台项目-cnblog
# flink平台项目 目录 架构 以前架构 现在架构的说明 CDH&集群规模 人员配备 开发周期 为什么用flinkcdc 项目好处 千表入湖工具 flink操作hive flink集成hive的步骤 flinksql 数据源为kafka flink读写sql有两种模式 Temporal Joi ......
python自动下载pdf文件—可分布下载=.= 一个demo
代码如下： import io import requests def download_pdf(save_path,pdf_name,pdf_url): send_headers = { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64 ......
Spring Security 一个小 Demo
参考教程 主要参考了 Spring Security最简单全面教程（带Demo） 问题解决 遇到了 javax.servlet.ServletException: Circular view path 的问题，访问 http://localhost:8080/login 时一直 404。 Thyme ......
twisted some demo
from twisted.internet import defer, reactor from twisted.web.client import getPage def response(*args, **kwargs): print('返回页面内容') def callback(*args, ......
帮我实现一个chrome扩展，使用debugger 自动输入demo当前页的文本框中
Crafted by Genie You 帮我实现一个chrome扩展，使用debugger 自动输入demo当前页的文本框中 Genie 好的，首先我们需要创建一个Chrome扩展程序，并在清单文件中添加相应权限。 创建一个新目录，并在其中创建以下文件： manifest.json popup.h ......