sockettextstream netcat flink demo
callDOMAction demo
Crafted by Genie You callDOMAction demo Genie To create a demo for callDOMAction, we can use the following example: <!DOCTYPE html> <html> <head> <tit ......
Qt+MySql开发笔记：Qt5.9.3的msvc2017x64版本编译MySql8.0.16版本驱动并Demo连接数据库测试
前言 mysql驱动版本msvc2015x32版本调好， mysql的mingw32版本的驱动上一个版本编译并测试好，有些三方库最低支持vs2017，所以只能使用msvc2017x64，基于Qt5.9.3，于是本篇编译mysql驱动的msvc2017x64版本，满足当前的特定需求，这次过程有点费劲， ......
SpringBoot 第一个demo
前奏 最近在面试，有一家公司在谈的时候，发了一份后端笔试题给我，是java的...... 我TMD是个运维诶，你给我一套SRE题不行嘛...... 玛德现在都这么卷了吗，SRE要去卷java啦...... SpringBoot 对于Java的很多东西我并不懂，但是我知道写java的后端都会用到Spr ......
直播平台软件开发，一个简单的Android登录实现demo
直播平台软件开发，一个简单的Android登录实现demo 一、登录活动 package com.example.login; import android.content.Intent;import android.os.Bundle;import android.text.TextUtils;i ......
Sitecore10 Demo演示环境Azure一键部署(Step By Step Guide to installing Sitecore10 in Azure Paas)
本文演示Sitecore XP Single(XP0)在Azure上的一键部署，即“30分钟生成Sitecore演示环境”的一环。 关于XP（即Sitecore Experience Platform） roles的相关介绍移步 XP Single配置主要用来开发和测试： Four Sitecore ......
记录一次springBoot+hibernate+JPA+swagger2+链接人大金仓的项目demo
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.spri ......
vue3+jointjs demo
下面是使用Vue3和JointJS添加元素的示例代码： 1. 安装JointJS ```terminal npm install jointjs --save ``` 2. 创建JointJS图形 ```javascript import { ref, onMounted } from 'vue'; ......
高德地图Demo
第一步先创建高德账号，创建应用获取key和密匙，自行百度。 npm安装 npm i @amap/amap-jsapi-loader --save 引入插件使用,此处是vue3引入，主要使用了位置和天气功能 <template> <div class="page"> <div class="icon" ......
pyqt gui demo
# -*- coding: utf-8 -*- """ @Time : 2023/4/24 10:53 @FileName: gui_demo.py """ import sys from PyQt5.QtWidgets import * from PyQt5.QtCore import * fro ......
【前端可视化】ECharts中国地图+散点图demo
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8" /> <meta http-equiv="X-UA-Compatible" content="IE=edge" /> <meta name="viewport" content ......
ai问答：使使用 Vue3 组合式API 和 TypeScript 父子组件demo
这是一个使用 Vue3 组合式 API 和 TypeScript 的简单父子组件示例 父组件 Parent.vue: <template> <div> <p>{{ msg }}</p> <Child /> </div> </template> <script lang="ts"> import { ......
【flink】重启kafka消费者
public class KafkaConsumerJob { public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment. ......
flink学习路线
1 传统架构 2 大数据架构和流式架构的演变工程 3 flink优势和不足 4 flink应用场景 5 flink基本架构 6 环境准备，运行环境和开发环境配置，建议使用java，兼容性好 7 flink编程模型：flink的数据集类型，编程接口，程序结构和数据类型4个维度进行分析。流式处理和批量计 ......
hyperf3搭建grpc demo
搭建环境如果是linux因为默认版本的gcc是4.8.5编译安装grpc失败，必须升级gcc的版本可以参考《php 安装 grpc 扩展》。 gcc重新编译比较耗时所以还是比较建议用docker Dockerfile FROM php:8.1 # 安装必要的工具和依赖 RUN apt-get upd ......
Flink启动报错：/bin/config.sh: line 32: syntax error near unexpected token
flink启动报错 xxx@ssss:/xxx/flink-1.15.2/bin> sh start-cluster.sh /xxx/flink-1.15.2/bin/config.sh: line 32: syntax error near unexpected token `<' /xxx/fl ......
单机单节点Flink的部署
一、Flink的下载和安装 1、Flink的下载 官方下载网址：https://archive.apache.org/dist/flink/这里选择1.15.2这个版本 2、把Flink上传到主机上 把下载好的文件上传到/opt/software上 3、解压Flink安装包 把Flink解压到/op ......
Flink之基于EventTime的WaterMark
什么是FLink watermark? Flink watermark是一种用于时间和事件处理的机制，它为事件流中的每个事件都分配了一个时间戳，以便将其与其他事件进行排序和分组。Watermark还为每个事件流提供了一个智能定界框架，使Flink能够有效地控制事件流的处理方式。Watermark可以 ......
A simple ROS2demo using fastdds
Statement Here I will do a simple experment about the Publisher/Subscriber model in BOTH FastDDS and ROS2(humble, latest), as well as cross communicat ......
flink 消费多个topic
转：https://www.404bugs.com/details/1081256252897284096 flink 消费多个topic示例： import org.apache.flink.api.common.functions.FlatMapFunction; import org.apac ......
flink taskmanager 初始化失败，报TaskManager initialization failed
【问题现象】 报错1： 报错2： 【定位步骤】 报错1是因为flink写日志的文件目录权限不够。为什么不够呢？因为该环境是admin部署，而flink的用户是自己创建的一个用户999，不是root用户，访问权限报错 --解决办法：在对应扩容脚本中增加日志目录的权限赋值，赋值为777 报错为taskm ......
Qt开发技术：Q3D图表开发笔记（三）：Q3DSurface三维曲面图介绍、Demo以及代码详解
前言 qt提供了q3d进行三维开发，虽然这个框架没有得到大量运用也不是那么成功，性能上也有很大的欠缺，但是普通的点到为止的应用展示还是可以的。 其中就包括华丽绚烂的三维图表，数据量不大的时候是可以使用的。 前面介绍了基础的q3d散点图、柱状图，本篇介绍基础的三维曲面图。 Demo：Q3DSurfac ......
使用obd demo快速部署单副本oceanbase集群（离线）
环境介绍： centos 7.6 可用内存不少于8G 安装目录空间不少于50G（默认安装在当前安装用户的家目录下） 1. 什么是obd？ odb是oceanbase社区版部署工具oceanbase deployer的简称，通过obd可以快速完成oceanbase clusterr的部署。 不传入配置 ......
Flink
Flink 流处理与批处理最大不同在于数据传输方式： 流处理：一条数据被处理完成后序列化到缓存，然后传输到下一个节点处理（一条一条） 批处理：数据处理完成后缓存到内存，缓存写满后持久化硬盘，所有数据处理完成后再传输到下一个节点（一批一批） Flink以固定的缓存块为单位进行网络数据传输，用户可以通过 ......
SchemaRegestry组件原生的类和方法无法实现flink消费kafka的数据动态调整schema的情况--未彻底解决
0、前提知识储备 Conflurent公司的SchemaRegestry组件的基本了解和使用 一、背景： 0.组件版本 flink：1.14 1.链路调整情况 原先链路：oracle-->OGG-->kafka-->flink-->数据库\湖\仓 实现链路：oracle-->OGG-->kafka（ ......
枚举实现方式demo
class Program { static void Main(string[] args) { Console.WriteLine(INSTRUCTION_STATUS.新建); Console.ReadKey(); } } class INSTRUCTION_STATUS { public c ......
构建私有仓库 flink image 镜像
准备flink-*.tar.gz 可以自己编译，或者下载 编译 cd ${flink-root} mvn install -DskipTests # 编译成功后，压缩成tar.gz cd ./flink-dist/target/ tar -cvf flink-1.18-SNAPSHOT-bin.ta ......
obd demo快速部署单副本oceanbase（在线）
资源要求： 可用内存不少于8G 安装目录空间不少于50G（默认安装在当前安装用户的家目录下） 1. 什么是obd？ odb是oceanbase社区版部署工具oceanbase deployer的简称，通过obd可以快速完成oceanbase clusterr的部署。 不传入配置文件的情况下，在单机通 ......
网易云信SDK示例demo下载，运行报错
pod install 后报错 File not found: /Applications/Xcode.app/Contents/Developer/Toolchains/XcodeDefault.xctoolchain/usr/lib/arc/libarclite_iphonesimulator. ......
dbatools demo
break #从PowerShell Gallery 安装dbatools模组 Install-Module dbatools <# 01.查找SQL实例 02.连接SQL实例 03.检查备份 04.检查磁盘空间 05.备份数据库 06.安装欧拉维护工具 07.运行Job 08.测试备份 09.查看 ......