flinksql
Flink SQL 是 Apache Flink 项目中的一个重要组成部分，它允许开发者使用标准的 SQL 语言来处理流数据和批处理数据。Flink SQL 提供了一种声明式的编程范式，使得用户能够以一种简洁、高效且易于理解的方式来表达复杂的数据处理逻辑。
### 背景
Flink SQL 的设计初衷是为了简化实时计算模型，降低用户使用实时计算的门槛【1】。随着数据流处理需求的日益增长，传统的编程模型（如使用 Datastream API）虽然灵活，但存在一定的使用门槛，且难以优化和调试【1】。因此，Flink SQL 作为一种更接近传统数据库查询语言的接口，应运而生，它使得开发者可以更加专注于业务逻辑，而无需深入底层的数据处理细节。
### 核心特性
- **流批一体**：Flink SQL 支持流处理和批处理的统一，这意味着同一套 SQL 语句可以同时处理实时数据流和静态数据集【2】【3】。
- **易于理解和使用**：Flink SQL 遵循 ANSI SQL 标准，使得有 SQL 背景的开发者能够快速上手【1】【2】。
- **自动优化**：Flink SQL 内置了查询优化器，能够自动为 SQL 语句生成最优的执行计划【1】。
- **丰富的算子和函数**：Flink SQL 提供了丰富的算子（如 select、join、group by 等）和内置函数，支持复杂的数据处理和分析任务【5】。
### 编程模型
Flink SQL 的编程模型包括三个主要部分：Source Operator、Query Operators 和 Sink Operator【5】。
- **Source Operator**：用于抽象外部数据源，如 Kafka、文件系统等【5】。
相关文章：
flinksql
Flink SQL 是 Apache Flink 项目中的一个重要组成部分，它允许开发者使用标准的 SQL 语言来处理流数据和批处理数据。Flink SQL 提供了一种声明式的编程范式，使得用户能够以一种简洁、高效且易于理解的方式来表达复杂的数据处理逻辑。 ### 背景 Flink SQL 的设计初衷是为了简…...
Dockerfile中 CMD和ENTRYPOINT的区别
在 Dockerfile 中，CMD 和 ENTRYPOINT 都用于指定容器启动时要执行的命令。它们之间的主要区别是： - CMD 用于定义容器启动时要执行的命令和参数，它设置的值可以被 Dockerfile 中的后续指令覆盖，包括在运行容器时传递的参数。如果…...
【TC3xx芯片】TC3xx芯片的总线内存保护
前言 广义上的内存保护，包括<<【TC3xx芯片】TC3xx芯片MPU介绍>>一文介绍的MPU(常规狭义上的内存保护)，<<【TC3xx芯片】TC3xx芯片的Endinit功能详解>>一文中介绍的寄存器的EndInit保护，<<【TC3xx芯片】TC3xx芯片ACCEN寄存器保护详解>>一…...
抖音小店选品必经五个阶段，看你到哪一步了，直接决定店铺爆单率
大家好，我是电商笨笨熊 新手选品必经的阶段就是迷茫期，不知道怎么选品，在哪里选品，选择什么样的品； 而有些玩家也会在进入店铺后疯狂选品，但是上架的商品没有销量； 而这些都是每个玩家都要经…...
ML在骨科手术术前、书中、术后方法应用综述【含数据集】
达芬奇V手术机器人 近年来，人工智能(AI)彻底改变了人们的生活。人工智能早就在外科领域取得了突破性进展。然而，人工智能在骨科中的应用研究尚处于探索阶段。 本文综述了近年来深度学习和机器学习应用于骨科图像检测的最新成果，描述了其贡献、优势和不足。以及未来每项研究…...
vue3-video-play 在安卓上正常播放，在ios上不能播放，问题解决
1.ios上autoplay需要静音，在播放后再打开声音 <vue3videoPlay v-if"!isComponent" v-bind"options" :playsinline"playsinline"></vue3videoPlay>let playsinline computed(() > {if (props.isComponent) {return}o…...
【C++类和对象】上篇
💞💞 前言 hello hello~ ，这里是大耳朵土土垚~💖💖 ，欢迎大家点赞🥳🥳关注💥💥收藏🌹🌹🌹 💥个人主页&#x…...
微信订阅号环境搭建及开发者工具下载
目录 一、注册订阅号 1.1 选择注册 2.2 选择订阅号注册 1.3 登录进入主页面 编辑 1.4 可以进行自定义菜单 1.5 我们重点关注公众平台测试账号 编辑 1.6 自定义一个域名 1.7 用自己的微信扫描这个二维码 编辑 1.8 点击修改，并自定义个域名 二、开发…...
Failed to resolve ‘bss.myhuaweicloud.com‘ ([Errno -2] Name or service not know
Failed to resolve ‘bss.myhuaweicloud.com’ ([Errno -2] Name or service not know 解決方案： 修改/etc/resolv.conf文件来指定DNS服务器，例如添加Google的公共DNS服务器： nameserver 8.8.8.8 nameserver 8.8.4.4...
大厂基础面试题（之二）
Q1：flex布局 Flex布局容器属性包括： flex-direction: 定义主轴的方向，决定flex容器中的子元素的排列方式 flex-wrap：设置子元素是否换行 flex-flow：是flex-direction和flex-wrap的简写形式，用于设置容器的排…...
swiftui macOS实现加载本地html文件
import SwiftUI import WebKitstruct ContentView: View {var body: some View {VStack {Text("测试")HTMLView(htmlFileName: "localfile") // 假设你的本地 HTML 文件名为 index.html.frame(minWidth: 100, minHeight: 100) // 设置 HTMLView 的最小尺寸…...
科技云报道：大模型加持后，数字人“更像人”了吗？
科技云报道原创。 北京冬奥运AI 虚拟人手语主播、杭州亚运会数字人点火、新华社数字记者、数字航天员小诤…当随着越来越多数字人出现在人们生活中，整个数字人行业也朝着多元化且广泛的应用方向发展，快速拓展到不同行业、不同场景。 面向C端࿰…...
轻松驾驭时间流：MYSQL日期与时间函数的实用技巧
🌈 个人主页：danci_🔥 系列专栏：《MYSQL应用》💪🏻 制定明确可量化的目标，坚持默默的做事。 轻松驾驭时间流：MYSQL日期与时间函数的实用技巧 MYSQL日期时间函数是数据库操作中不可…...
如何在极狐GitLab 使用Docker 仓库功能
本文作者：徐晓伟 GitLab 是一个全球知名的一体化 DevOps 平台，很多人都通过私有化部署 GitLab 来进行源代码托管。极狐GitLab 是 GitLab 在中国的发行版，专门为中国程序员服务。可以一键式部署极狐GitLab。 本文主要讲述了如何在[极狐GitLab…...
streamlit 大模型前段界面
结合 langchain 一起使用的工具，可以显示 web 界面 pip install streamlit duckduckgo-search 运行命令 streamlit run D:\Python_project\NLP\大模型学习\test.py import os from dotenv import load_dotenv from langchain_community.llms import Tongyi load…...
K8s 命令行工具
文章目录 K8s 命令行工具kubectl 工具在任意节点使用kubectl方式创建对象命令显示和查找资源更新资源修补资源编辑资源Scale 资源删除资源查看pod信息节点相关操作 K8s 命令行工具 在搭建集群的时候，我们通过yum 下载了kubeadm kubelet kubectl 三个命令行工具&…...
优先级队列
优先级队列的基本使用 模拟实现上面的接口函数，优先级队列不是队列，而是类似一个堆一样的东西，我们先来试试它的接口函数是怎么个样子的。 需要包含的头文件是queue。 #include<iostream> #include<queue> using namespace std;…...
gitlab使用
个人笔记（整理不易，有帮助，收藏点赞评论，爱你们！！！你的支持是我写作的动力） 笔记目录：学习笔记目录_pytest和unittest、airtest_weixin_42717928的博客-CSDN博客 个人随笔…...
ppt技巧：如何将Word文档大纲中导入到幻灯片中？
在PowerPoint中，将Word文档的大纲导入到新的幻灯片是一种非常实用的技巧。以下是详细的步骤： 首先，需要打开PowerPoint软件并打开原始的幻灯片文件。 在PowerPoint的顶部【开始】菜单栏中，找到并点击“新建幻灯片”按钮࿰…...
0.开篇：SSM+Spring Boot导学
1. 为什么要使用框架 Spring是一个轻量级Java开发框架，最早有Rod Johnson创建，目的是为了解决企业级应用开发的业务逻辑层和其他各层的耦合问题。 几乎当下所有企业级JavaEE开发都离不开SSM（Spring SpringMVC MyBatis）Spring B…...
条件运算符
C中的三目运算符（也称条件运算符，英文：ternary operator）是一种简洁的条件选择语句，语法如下： 条件表达式 ? 表达式1 : 表达式2• 如果“条件表达式”为true，则整个表达式的结果为“表达式1”…...
Java - Mysql数据类型对应
Mysql数据类型java数据类型备注整型INT/INTEGERint / java.lang.Integer–BIGINTlong/java.lang.Long–––浮点型FLOATfloat/java.lang.FloatDOUBLEdouble/java.lang.Double–DECIMAL/NUMERICjava.math.BigDecimal字符串型CHARjava.lang.String固定长度字符串VARCHARjava.lang…...
剑指offer20_链表中环的入口节点
链表中环的入口节点 给定一个链表，若其中包含环，则输出环的入口节点。 若其中不包含环，则输出null。 数据范围 节点 val 值取值范围 [ 1 , 1000 ] [1,1000] [1,1000]。 节点 val 值各不相同。 链表长度 [ 0 , 500 ] [0,500] [0,500]。 …...
高等数学（下）题型笔记（八）空间解析几何与向量代数
目录 0 前言 1 向量的点乘 1.1 基本公式 1.2 例题 2 向量的叉乘 2.1 基础知识 2.2 例题 3 空间平面方程 3.1 基础知识 3.2 例题 4 空间直线方程 4.1 基础知识 4.2 例题 5 旋转曲面及其方程 5.1 基础知识 5.2 例题 6 空间曲面的法线与切平面 6.1 基础知识 6.2…...
数据库分批入库
今天在工作中，遇到一个问题，就是分批查询的时候，由于批次过大导致出现了一些问题，一下是问题描述和解决方案： 示例： // 假设已有数据列表 dataList 和 PreparedStatement pstmt int batchSize 1000; // …...
IoT/HCIP实验-3/LiteOS操作系统内核实验(任务、内存、信号量、CMSIS..)
文章目录 概述HelloWorld 工程C/C配置编译器主配置Makefile脚本烧录器主配置运行结果程序调用栈 任务管理实验实验结果osal 系统适配层osal_task_create 其他实验实验源码内存管理实验互斥锁实验信号量实验 CMISIS接口实验还是得JlINKCMSIS 简介LiteOS->CMSIS任务间消息交互…...
用机器学习破解新能源领域的“弃风”难题
音乐发烧友深有体会，玩音乐的本质就是玩电网。火电声音偏暖，水电偏冷，风电偏空旷。至于太阳能发的电，则略显朦胧和单薄。 不知你是否有感觉，近两年家里的音响声音越来越冷，听起来越来越单薄？ —…...
探索Selenium：自动化测试的神奇钥匙
目录 一、Selenium 是什么1.1 定义与概念1.2 发展历程1.3 功能概述 二、Selenium 工作原理剖析2.1 架构组成2.2 工作流程2.3 通信机制 三、Selenium 的优势3.1 跨浏览器与平台支持3.2 丰富的语言支持3.3 强大的社区支持 四、Selenium 的应用场景4.1 Web 应用自动化测试4.2 数据…...
API网关Kong的鉴权与限流：高并发场景下的核心实践
🔥「炎码工坊」技术弹药已装填！ 点击关注 → 解锁工业级干货【工具实测|项目避坑|源码燃烧指南】 引言 在微服务架构中，API网关承担着流量调度、安全防护和协议转换的核心职责。作为云原生时代的代表性网关，Kong凭借其插件化架构…...
Linux中《基础IO》详细介绍
目录 理解"文件"狭义理解广义理解文件操作的归类认知系统角度文件类别 回顾C文件接口打开文件写文件读文件稍作修改，实现简单cat命令 输出信息到显示器，你有哪些方法stdin & stdout & stderr打开文件的方式 系统⽂件I/O⼀种传递标志位…...