flink sql是flink 中的一个重要模块，同时我们也知道flink sql的解析是基于calcite实现的。那么，当我们在使用flink的时候，如何使用calcite来对sql进行解析呢？ 首先，如果使用了flink-table-planner，则不能再引入calcite。由于flink-table-planner中已经包含了calcite代码，如果再引入calcite的jar包，则会引起冲突。所以，直接使用flink-table-planner中的calcite即可。 那么这里最主要的就是如何获得 org.apache.calcite.sql.parser.Config 对象，通过对...

通过二进制安装Containerd 操作系统为Ubuntu 20.04，本教程使用官方二进制包进行安装演示。 安装Containerd 从地址https://containerd.io/downloads/中选择Binaries (.tar.gz)进行下载（containerd-<VERSION>-<OS>-<ARCH>.tar.gz）。 解压缩文件到目录/usr/local/： tar zxvf containerd-1.6.28-linux-amd64.tar.gz -C /usr/local/ 下载系统脚本，使其可以随系统启动 下载地址为https://raw.githubusercon...

gpt-4o-audio-preview的核心功能包括三大方面:首先，它能够根据文本生成自然流畅的语音响应，为语音助手和虚拟客服等应用提供了强大支持。其次，该模型具备分析音频输入的情感、语调和音调的能力，这一特性在情感计算和用户体验分析领域具有广阔应用前景。最后，它支持语音到语音的互动，音频既可以作为输入也可以作为输出，为全方位的语音交互系统奠定了基础。 本文使用pyaudio模拟语音输入和朗读实现语音聊天、打断和function call功能 gpt-4o-realtime-preview为了实现打断，使用的是websocket协议，不是http协议 引入必要的包 import asynci...

基于 pnpm 搭建 monorepo 工程目录结构 💡 Tips：现代的前端工程越来越多的都会选择 Monorepo 的方式进行开发，比如 Vue、React 等知名开源项目都采用的 Monorepo 的方式进行管理。 我们选择创建自己的Vue3组件库的时候可以参考Vue3的经典组件库 Element-plus 作为参考，一个monorepo模式的项目目录为以下模式。 ├── packages | ├── pkg1 | | ├── package.json | ├── pkg2 | | ├── package.json ├── package.json # 为 a...

ZeroMQ（也拼写为 ØMQ、0MQ 或 ZMQ）是一个高性能异步消息网络库，旨在用于分布式或并发程序中。它提供了一个消息队列，但不同于其他的面向消息的中间件，ZeroMQ 系统可以在没有专用的消息代理节点的情况下运行。 ZeroMQ支持多种通信模式，例如发布/订阅、请求/回复、客户端/服务器等，且也支持多种传输方式，例如TCP、进程内、进程间、广播、WebSocket 等。 ZeroMQ支持多种流行的编程语言集成使用。 Socket API Sockets是一套网络编程的API，它并不是某种协议，它是基于TCP/IP的标准网络API，通常称作"套接字"，Socket处于网络协议的传输层。Z...

在业务系统中，我们经常会需要记录用户的操作记录，从而方便对用户的行为进行审计。得益于java aop和对注解的支持，我们大多数方案是通过注解的扫描，然后通过aop的方式对操作行为进行拦截并进行记录。大方向上个这个基本是一致的，但是如何实现就看各个团队自己的方案了，针对这个情况，我们抽象出一个统一的解决方案，以期能在基础层面满足大多数场景的要求。 设计思路 注解类 首先，我们要明确，行为审计要记录的是什么？基本可以抽象为XX在XX时候做了XX事情，剩下的就是对这个事情的详细描述，例如操作对象的具体信息，对象前后的变化等。但是，对于不同的资源对象，又需要不同的处理方法，可能是去查询对应的表，或者根...

在使用Spring @Cacheable注解的时候，出现unless属性不生效的情况。经过漫长的排查，发现是因为两个注解使用了同样的key。 记录下处理结果，为遇到类似问题的时候提供一个排查方向。

环境 ES8.15 实现思路 1、把图片转换成向量 import numpy as np from tensorflow.keras.applications.resnet50 import ResNet50, preprocess_input from tensorflow.keras.preprocessing import image def image_process(img_path): """ 图片处理 :param str img_path: 图片路径 :return: <class 'PIL.Image.Image'> """ i...

假设你已经设置好ssh的配置，并且已经添加到GitHub的账号中，突然ssh的22端口报错ssh: connect to host github.com port 22:，可以参考以下解决方案。 如果你在控制台使用ssh的方式clone项目的时候突然出现以下报错: **ssh: connect to host github.com port 22: Connection refused fatal: Could not read from remote repository.** 出现这个错误可能是因为 SSH 端口（22）被公司的防火墙或网络策略阻止。可以尝试以下解决方案： 检查一下自己的s...

前言 Kotlin Multiplatform (KMP) 是 JetBrains 构建的开源技术，允许跨多个平台共享代码，同时保留了原生编程的优势。 支持的平台包括 iOS、Android、Desktop、Web 等。 随着 Kotlin Multiplatform 的日趋稳定，全球各地的开发团队都可以在生产环境中利用它的强大功能。在 5 月的 Google I/O 2024 大会上，Google 宣布正式支持使用 Kotlin Multiplatform 跨 Android 和 iOS 共享业务逻辑。 环境配置 参考链接：https://www.jetbrains.com/help/kot...