flink wordcount demo job
odoo pdf 打印任务后台运行,pdf保存在附件中, 借助queue_job模块实现后台打印
## 用户故事: 在打印大批量pdf 文件时会有较长事件的等待, 而且容易中断 ## 原因 中断原因, 有内存及超时限制,wkhtmltopdf工具比较吃内存 ## 解决方案: 内存限制的问题可以分批处理,比如每次只处理50条记录 ## 代码示例,使用按钮触发的打印功能: ```py # model ......
大数据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 ......
xxl-job
# docker ```bash docker run -e PARAMS=" --server.port=9110 --spring.datasource.url=jdbc:mysql://localhost:3306/xxl_job?useUnicode=true&characterEncodi ......
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 ......
从零开始实现放置游戏（十七）——完结篇（附DEMO地址）
大家好，时隔2年多，我来填坑啦！ 之前用的技术、设计思路都不成熟，所以直接干掉重做了。 由于从头教学实在太啰嗦，精力也有限，咱们还是直接上源码吧。 DEMO地址： http://212.129.154.59:5173/ （大家快看呀，服务器11月底就要过期了） 源码地址： 由于之前网盘过期了，文件全 ......
史上最全Flink面试题，高薪必备，大数据面试宝典
文章很长，且持续更新，建议收藏起来，慢慢读！[**疯狂创客圈总目录 博客园版**](https://www.cnblogs.com/crazymakercircle/p/9904544.html) 为您奉上珍贵的学习资源 ： 免费赠送 :[**《尼恩Java面试宝典》**](https://www. ......
flink-cdc同步mysql数据到elasticsearch
1，什么是cdc CDC是（Change Data Capture 变更数据获取）的简称。核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 2，fli ......
prometheus简易推送demo
public static void main(String[] args) throws Exception { InetAddress ia = InetAddress.getLocalHost(); Map<String,String> map = new HashMap<>(); map.p ......
LVGL Demo测试
准备移植好lvgl的工程 一、修改 lv_port_disp.c1、使能 lv_port_disp.c修改头晚间包含 lv_port_disp_template改为lv_port_disp 编译报错和警告，没有定义水平MY_DISP_HOR_RES、垂直分辨率MY_DISP_VER_RES和 最大水 ......
LVGL8.1运行demo
前言 LVGL能实现非常简约美观的UI界面，比如上面这张动图就是LVGL的官方demo，前面移植好显示和触摸后，就可以尝试跑一下lv_demo。 有时间还可以研究一下demo是怎么实现的。 一、移植前准备 硬件（带触摸屏幕的STM32F407VE核心板） 移植好LVGL-8.1显示和触摸的Keil工 ......
Google官方Demo
Google官方渠道获取的示例和Demo： Android官方示例： Google提供了一个名为"android/sunflower"的GitHub存储库，其中包含一个示例应用程序，用于演示如何使用Android最佳实践、Jetpack组件和现代开发技术。这个应用程序名为Sunflower，是一个植 ......
Flink源码解析(二)——Flink流计算应用执行环境解析
在Flink应用执行过程中会涉及到3个主要的执行环境变量，分别为StreamExecutionEnvironment、Environment、RuntimeContext。它们的作用层次、作用时机、作用范围各不相同。3种环境对象的关系如下图: 下面分别介绍3种环境对象的细节信息。 一、StreamE ......