sockettextstream netcat flink demo
flink的源码编译方法
1、下载flink源码 2、修改整数限制numUnapprovedLicenses 改成100(在pom.xml文件) 3、执行编译命令 ./mvnw clean package -DskipTests 4、如果只想名义子工程 拷贝根目录的mvnw执行脚本到对应子目录，然后再执行./mvnw cle ......
junit_demo
参考：JUnit5单元测试框架的使用教程与简单实例_junit5使用_pan_junbiao的博客-CSDN博客 Junit单元测试例子demo_twentyfour4ever的博客-CSDN博客 目录结构 pom.xml <project xmlns="http://maven.apache.or ......
Flink 1.12.2样例
### pom.xml ```xml sample-project org.myproject.bigdata 1.0-SNAPSHOT 4.0.0 JavaFlink-112 1.8 1.8 1.12.2 UTF-8 org.apache.flink flink-java ${flink.vers ......
pdfjs-dist v2.11.338写个react demo
app.jsx ```jsx import './App.css' import * as pdfjs from "pdfjs-dist"; import "pdfjs-dist/web/pdf_viewer.css"; import { useEffect, useRef, useState } ......
flask接收json，开启服务demo
# demo ```python from flask import Flask, render_template, request, jsonify app = Flask(__name__) @app.route('/', methods=['GET', 'POST']) def index() ......
NSQ demo
Docker docker pull nsqio/nsq nsqd nsqd 是接收、队列和向客户端传递消息的守护进程。它可以独立运行，但通常在具有nsqlookupd实例的集群中进行配置（这种情况下，他将会发布主题和频道以便发现） 配置及api:https://nsq.io/componen ......
hibernate_demo
参考：ORM hibernate入门Demo(无敌详细版) - Old-凯 - 博客园 (cnblogs.com) hmb.xml:Hibernate框架之hbm.xml映射文件（详解）_hibernate映射文件详解_hestyle的博客-CSDN博客 新建testdb数据库，创建tb_users ......
FastApi-1-结合sql 增/查demo
[TOC](目录) # FastAPI学习记录 fastapi已经学习有一段时间，今天抽时间简单整理下。 **官网介绍：** FastAPI 是一个用于构建 API 的现代、快速（高性能）的 web 框架，使用 Python 3.6+ 并基于标准的 Python 类型提示。 - 快速：可与 Node ......
tk的一个布局demo
# 效果  # 代码 ```python import tkinter as tk from tkinter im ......
python监控redis demo
下载aioredis 为了提升性能我们使用一部redis ```python pip install aioredis ``` demo: ```python import asyncio import aioredis # 每隔10s获取redis信息 async def monitor_redi ......
大数据Flink学习圣经：一本书实现大数据Flink自由
文章很长，且持续更新，建议收藏起来，慢慢读！[**疯狂创客圈总目录 博客园版**](https://www.cnblogs.com/crazymakercircle/p/9904544.html) 为您奉上珍贵的学习资源 ： 免费赠送 :[**《尼恩Java面试宝典》**](https://www. ......
适老化demo
html <!doctype html><html lang="en"> <head> <meta charset="UTF-8"> <title>鼠标移入视频播放，鼠标移出播放停止，恢复到原来状态</title> <style> * { margin: 0; padding: 0; } .vide ......
阿里EasyExcel快速导出demo
引入阿里easyExcel依赖 ``` com.alibaba easyexcel 2.2.6 org.ehcache ehcache ``` 自定义的阿里easyexcel拦截器方法 ``` import com.alibaba.excel.write.handler.SheetWriteHand ......
15种实时uv实现方案系列(附源码)之一：Flink基于set实时uv统计
UVStatMultiPlans（GitHub）项目持续收集各种高性能实时uv实现方案并对各种实现方案的优缺点进行对比分析！ #### 需求描述 统计每分钟用户每个页面的uv访问量。 #### Kafka数据格式 ``` {"userId":"c61b801e-22e7-4238-8f67-9096 ......
Flink and Kafka Streams: a Comparison and Guideline for Users
This blog post is written jointly by Stephan Ewen, CTO of data Artisans, and Neha Narkhede, CTO of Confluent. Stephan Ewen is PMC member of Apache Fli ......
excel 输出demo（outputstream 转inputstr）
protected void responseExcel(HSSFWorkbook workbook) throws IOException { ByteArrayOutputStream os = new ByteArrayOutputStream(); try { workbook.write( ......
开源XL-LightHouse与Flink、ClickHouse之类技术相比有什么优势
Flink是一款非常优秀的流式计算框架，而ClickHouse是一款非常优秀的OLAP类引擎，它们是各自所处领域的佼佼者，这一点是毋庸置疑的。Flink除了各种流式计算场景外也必然可以用于流式统计，ClickHouse同样也可以用于流式统计，但我不认为它们是优秀的流式统计工具。XL-Lighthou ......
django乐观锁、悲观锁商品秒杀简单demo
### 悲观锁 总是假设最坏的情况，每次去拿数据的时候都认为别人会修改，所以每次在拿数据的时候都会上锁，这样别人想拿这个数据就会阻塞直到它拿到锁（共享资源每次只给一个线程使用，其它线程阻塞，用完后再把资源转让给其它线程）。传统的关系型数据库里边就用到了很多这种锁机制，比如行锁，表锁等，读锁，写锁等， ......
Apache Flink目录遍历漏洞复现CVE-2020-17519
# Apache Flink目录遍历漏洞复现CVE-2020-17519 ## 前置知识 `Apache Flink:` > Apache Flink 是一个框架和分布式处理引擎，用于在*无边界和有边界*数据流上进行有状态的计算。Flink 能在所有常见集群环境中运行，并能以内存速度和任意规模进行计 ......
quarkus数据库篇之一：比官方demo更简单的基础操作
《quarkus数据库篇》系列的开篇，编码实战最基础的数据库增删改查，数据库用的是PostgreSQL，在官方demo基础上进一步精简，极速入门quarkus数据库操作 ......
seata学习-简单demo入门
## 概述 学习一个框架，我喜欢从demo中了解该框架所能达到的效果再进行深入地学习。本篇文章将会介绍 seata 的一个入门使用 demo ,作为使用 seata 的入门学习文章。 ## 使用案例 首先到github 中下载一个 RM 的运行服务，本例中使用的是 ： https://github. ......
Mybatis配置文件的空白模板和联系demo所用到的依赖
核心配置文件模板 <?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "https://mybatis.org/dtd/mybatis- ......
pyspark小demo
```python # # py_pyspark_demo2.py # py_learn # # Created by Z. Steve on 2023/8/13 10:55. # import json # 1. 导入库 from pyspark import SparkConf, SparkCo ......
中电金信：技术实践｜Flink多线程实现异构集群的动态负载均衡
导语：Apache Flink是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。本文主要从实际案例入手并结合作者的实践经验，向各位读者分享当应用场景中异构集群无法做到负载均衡时，如何通过Flink的自定义多线程来实现异构集群的动态负载均衡。 ● 1. 前言 ● 2. 出现的问题与解决 ......
Aidlux demo演示
aidlux demo展示：  #### ......
JSON WEB TOKEN - 简单的token认证方式 - 告别session和cookie - Java Demo
JWT简介 jwt非常适合前后分离 和 分布式的应用 不必在服务端存储session,本地也不用存储cookie 直接存两段信息即可 localStorage["jwt"] = jwt; // token localStorage["name"] = json.name; // token中加密的某 ......
微服务实战demo(1.5.17.RELEASE&Edgware.SR5)
一、注册中心（使用eureka） 1.依赖： <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </depende ......
pyspark小demo2
```python # # py_pyspark_demo2.py # py_learn # # Created by Z. Steve on 2023/8/13 10:55. # import json # 1. 导入库 from pyspark import SparkConf, SparkCo ......
zookeeper_demo
参考：全网最详细的zookeeper实战教程，看完你就知道有多值 - 知乎 (zhihu.com) ZooKeeper入门，看这篇就够了！ - 知乎 (zhihu.com) windows安装zk：windows环境下安装zookeeper教程详解（单机版）_风轩雨墨的博客-CSDN博客 zk的wa ......