当前位置： 首页 > news >正文

Flink-间隔联结

news 2026/2/11 2:08:09
  1. 间隔联结只支持事件时间
  2. 间隔联结如果遇到迟到数据，则会关联不上，比如来了一个5秒的数据，它可以关联前2秒的数据，后3秒的数据，就是可以关联3秒到8秒的数据，然后又来了一个6秒的数据，可以关联4秒到9秒的数据，那么3秒的数据，就永远不会被关联到了，就可以删除了，然后又来了一个迟到数据，比如4秒的数据，可以关联2秒到7秒的数据，但是3秒的数据已经被删除了，所以就关联不上了。对于这种情况，解决办法就是，使用回撤流，比如left join，left join可以设置状态过期时间，这个时间是系统时间，比如我们设置过期时间是5分钟，那么A流的3秒的数据，可以和B流的4秒(迟到数据)的数据关联上，就解决了这个问题。

相关文章：

Flink-间隔联结

间隔联结只支持事件时间间隔联结如果遇到迟到数据，则会关联不上，比如来了一个5秒的数据，它可以关联前2秒的数据，后3秒的数据，就是可以关联3秒到8秒的数据，然后又来了一个6秒的数据，可以关联4秒到…...

编程日记 2023/8/10 19:40:33

redis的持久化

第一章、redis的持久化 1.1）持久化概述 ①持久化可以理解为将数据存储到一个不会丢失的地方，Redis 的数据存储在内存中，电脑关闭数据就会丢失，所以放在内存中的数据不是持久化的，而放在磁盘就算是一种持久化。 ②为…...

编程日记 2023/8/10 19:39:31

藏语翻译器：多功能翻译软件

这是是一款能够将藏语翻译成其他语言或将其他语言翻译成藏语的软件。该软件能够识别并翻译藏语中的常用词汇和短语，并且支持多种常见语言的翻译，例如英语、汉语、法语、德语等等。此外，藏语翻译器还具有简单易用的用户界面，方便用…...

编程日记 2023/8/10 19:38:28

Java课题笔记~ JavaWeb概述/开发基础

JavaWeb概述/开发基础 1.XML基础 （1）XML概述 （2）XML语法 （3）DTD约束 （4）Schema约束（XML Schema 比 DTD 更强大） 2.Web基础知识 Web是一个分布式的超媒…...

编程日记 2023/8/10 19:37:27

【解放ipad生产力】如何在平板上使用免费IDE工具完成项目开发

我的博客即将同步至腾讯云开发者社区，邀请大家一同入驻：https://cloud.tencent.com/developer/support-plan?invite_code3o19zyy2pneoo 前言 很多人应该会像我一样吧，有时候身边没电脑突然要写项目，发现自己的平板没有一点作用&…...

编程日记 2023/8/10 19:36:24

IDEA快捷键总结

切换窗口 Alt（1-9） Alt1 打开或者关闭左侧project Alt4 Run窗口 Alt5 Debug窗口 Alt7 类结构窗口 生成构造函数、get、set等方法 Altinsert 快速生成输出语句 Soutenter键 运行程序 chtlshiftf10 运行程序 shiftf9 debug方式运行程序 代码…...

编程日记 2023/8/10 19:35:21

OpenJDK Maven 编译出错： package jdk.nashorn.internal.runtime.logging does not exist

前言 OpenJDK 1.8.0Maven 3.8.5TencentOS Server 3.1 错误信息 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.1:compile (default-compile) on project tour-common: Compilation failure: Compilation failure: [ERROR] /opt/tour-c…...

编程日记 2023/8/10 19:34:20

.Net Framework请求外部Api

要在.NET Framework 4.5中进行外部API的POST请求，你可以使用HttpClient类。 1. Post请求 using System; using System.Net.Http; using System.Threading.Tasks;class Program {static async Task Main(string[] args){// 创建一个HttpClient实例using (HttpClien…...

编程日记 2023/8/10 19:33:18

线程池工作原理深入解析

目录 1. 线程正常的生命周期 2. 为什么要用线程池？ 3. 线程池的核心原理 4. 怎样创建线程池？ 5.线程池的代码实现 6. ThreadPoolExecutor 源码分析 7. ThreadPoolExecutor 工作原理展示（重点） 1. 线程正常的生命周期 我们知…...

编程日记 2023/8/10 19:32:17

chatGPT小白快速入门课程大纲

以下是关于ChatGPT的培训课程大纲,分为7部分,我们会在后续写一个系列的相关文章: 1. 介绍 ChatGPT是什么?ChatGPT是由谁开发的?ChatGPT是一个什么样的语言模型? 2. 功能与特点 ChatGPT可以做什么?ChatGPT有哪些特点?ChatGPT与传统语言模型的区别? 3. 使用方法 如何…...

编程日记 2023/8/10 19:31:16

网络编程——多路复用——epoll机制

理解 epoll：高效的 Linux I/O 多路复用机制 在网络编程中，处理多个并发连接是一个常见的挑战。传统的方式通常使用阻塞式 I/O 或者多线程/多进程来处理并发连接，但这些方法都存在一些性能和资源管理的问题。为了解决这些问题，Lin…...

编程日记 2023/8/10 19:30:15

chapter14：springboot与安全

Spring Boot与安全视频 Spring Security, shiro等安全框架。主要功能是”认证“和”授权“，或者说是访问控制。 认证（Authentication）是建立在一个声明主体的过程（一个主体一般指用户，设备或一些可以在你的应用程序中…...

编程日记 2023/8/10 19:29:12

Linux初识网络基础

目录 网络发展 认识“协议 ” 网络协议 OSI七层模型： TCP/IP五层（或四层）模型 网络传输基本流程 网络传输流程图： 数据包封装和封用 网络中的地址 认识IP地址： 认识MAC地址： 网络发展 1.独立…...

编程日记 2023/8/10 19:28:11

vue3+ts 动态导入多文件组件

1、在components文件夹中新建index.ts文件（components文件夹下为创建的组件） // index.ts const modules import.meta.globEager("./*.vue"); //参数为组件路径 let componentsOpts {}const getCaption (obj, str, z: boolean) > {let…...

编程日记 2023/8/10 19:27:10

补充122836356

ul {margin-bottom: 20px;& > li {margin-bottom: 0;} }等效于ul {margin-bottom: 20px; }ul > li {margin-bottom: 0; }CSS中的&代表的什么 如源码： ul{ margin-bottom: 20px; & >li { margin-bottom: 0; } } & 表示嵌套的上一级 这是s…...

编程日记 2023/8/10 19:26:09

记录 pl-table 表格头部文字抖动的问题

本文记录一个实际开发中 pl-table 的问题，项目比较老，vue还是2.x版本。pl-table 是基于 el-table 改造过来的表格展示组件，已经停止更新。 问题描述 当 data 内数据动态改变时，pl-table 的表头部分，列的文字会左右抖动…...

编程日记 2023/8/10 19:25:08

Vite 创建 Vue项目之后，eslint 错误提示的处理

使用 npm create vuelatest创建 vue 项目（TS）之后，出现了一些 eslint 错误提示，显然，不是代码真实的错误，而是提示搞错了。 vuejs/create-vue: 🛠️ The recommended way to start a Vite-pow…...

编程日记 2023/8/10 19:24:07

FFmpeg 硬编码VideoToolBox流程

介绍 FFmpeg已经提供对 VideoToolBox 的编解码支持；主要涉及到的文件有videotoolbox.c、videotoolbox.h、videotoolboxenc.c、ffmepg_videotoolbox.c。在编译 FFmpeg 源码时，想要支持VideoToolBox，在 configure 时，需要–enable-…...

编程日记 2023/8/10 19:23:05

恒盛策略：内盘是买入还是卖出？

内盘，又称成交明细，是指交易所实时发布的每一笔成交价格、交易时刻、成交量等具体数据。关于股民来说，每天重视内盘数据已成为必修课。可是，当看到内盘数据时，很多人都会困惑，到底内盘是买入还是卖出呢&…...

编程日记 2023/8/10 19:22:01

安装Lombok--Lombok的常用注解说明及使用方法

😀前言 本篇博文是关于Lombok的基本介绍和基本使用，希望能够帮助到您😊 🏠个人主页：晨犀主页 🧑个人简介：大家好，我是晨犀，希望我的文章可以帮助到大家，您的满…...

编程日记 2023/8/10 19:21:00

Vim 调用外部命令学习笔记

Vim 外部命令集成完全指南 文章目录 Vim 外部命令集成完全指南核心概念理解命令语法解析语法对比 常用外部命令详解文本排序与去重文本筛选与搜索高级 grep 搜索技巧文本替换与编辑字符处理高级文本处理编程语言处理其他实用命令 范围操作示例指定行范围处理复合命令示例 实用技…...

编程新知 2025/11/16 8:24:16

生成xcframework

打包 XCFramework 的方法 XCFramework 是苹果推出的一种多平台二进制分发格式，可以包含多个架构和平台的代码。打包 XCFramework 通常用于分发库或框架。 使用 Xcode 命令行工具打包 通过 xcodebuild 命令可以打包 XCFramework。确保项目已经配置好需要支持的平台…...

编程新知 2025/10/5 2:30:38

进程地址空间（比特课总结）

一、进程地址空间 1. 环境变量 1 ）⽤户级环境变量与系统级环境变量 全局属性：环境变量具有全局属性，会被⼦进程继承。例如当bash启动⼦进程时，环 境变量会⾃动传递给⼦进程。 本地变量限制：本地变量只在当前进程(ba…...

编程新知 2025/11/15 6:48:52

JVM垃圾回收机制全解析

Java虚拟机（JVM）中的垃圾收集器（Garbage Collector，简称GC）是用于自动管理内存的机制。它负责识别和清除不再被程序使用的对象，从而释放内存空间，避免内存泄漏和内存溢出等问题。垃圾收集器在Ja…...

编程新知 2026/1/9 14:53:35

大模型多显卡多服务器并行计算方法与实践指南

一、分布式训练概述 大规模语言模型的训练通常需要分布式计算技术，以解决单机资源不足的问题。分布式训练主要分为两种模式： 数据并行：将数据分片到不同设备，每个设备拥有完整的模型副本 模型并行：将模型分割到不同设备，每个设备处理部分模型计算 现代大模型训练通常结合…...

编程新知 2025/12/10 20:45:02

OPENCV形态学基础之二腐蚀

一.腐蚀的原理 (图1) 数学表达式：dst(x,y) erode(src(x,y)) min(x,y)src(xx,yy) 腐蚀也是图像形态学的基本功能之一，腐蚀跟膨胀属于反向操作，膨胀是把图像图像变大，而腐蚀就是把图像变小。腐蚀后的图像变小变暗淡。 腐蚀…...

编程新知 2026/2/8 22:00:17

视觉slam十四讲实践部分记录——ch2、ch3

ch2 一、使用g++编译.cpp为可执行文件并运行(P30) g++ helloSLAM.cpp ./a.out运行 二、使用cmake编译 mkdir build cd build cmake .. makeCMakeCache.txt 文件仍然指向旧的目录。这表明在源代码目录中可能还存在旧的 CMakeCache.txt 文件，或者在构建过程中仍然引用了旧的路…...

编程新知 2026/2/6 15:56:54

【VLNs篇】07：NavRL—在动态环境中学习安全飞行

项目内容论文标题NavRL: 在动态环境中学习安全飞行 (NavRL: Learning Safe Flight in Dynamic Environments)核心问题解决无人机在包含静态和动态障碍物的复杂环境中进行安全、高效自主导航的挑战，克服传统方法和现有强化学习方法的局限性。核心算法基于近端策略优化…...

编程新知 2026/2/7 4:16:41

C++：多态机制详解

目录 一. 多态的概念 1.静态多态（编译时多态） 二.动态多态的定义及实现 1.多态的构成条件 2.虚函数 3.虚函数的重写/覆盖 4.虚函数重写的一些其他问题 1）.协变 2）.析构函数的重写 5.override 和 final关键字 1&#…...

编程新知 2026/1/25 13:32:52

如何应对敏捷转型中的团队阻力

应对敏捷转型中的团队阻力需要明确沟通敏捷转型目的、提升团队参与感、提供充分的培训与支持、逐步推进敏捷实践、建立清晰的奖励和反馈机制。其中，明确沟通敏捷转型目的尤为关键，团队成员只有清晰理解转型背后的原因和利益，才能降低对变化的…...

编程新知 2026/2/4 16:04:15