底层flink join
【Java 并发】【九】【AQS】【六】CyclicBarrier栅栏底层机制原理
1 前言 接下来我们来看看CyclicBarrier，也是基于之前讲解的AQS来实现的，建立在AQS体系之上的一个并发工具类。 2 CyclicBarrier是什么 CyclicBarrier，就是一个计数器栅栏，也就是一个计数器开关。比如CyclicBarrier barrier = new Cy ......
【Java 并发】【九】【AQS】【五】CountDownLatch计数器底层机制原理
1 前言 接下来我们来看看CountDownLatch，也是基于之前讲解的AQS来实现的，建立在AQS体系之上的一个并发工具类。 2 CountDownLatch是什么 CountDownLatch类似一个有多道锁的门闩，CountDownLatch在创建的时候就指定好有多少道锁链了。假如有个门闩 ......
深入理解MySQL索引底层数据结构
在日常工作中，我们会遇见一些慢SQL，在分析这些慢SQL时，我们通常会看下SQL的执行计划，验证SQL执行过程中有没有走索引。通常我们会调整一些查询条件，增加必要的索引，SQL执行效率就会提升几个数量级。我们有没有思考过，为什么加了索引就会能提高SQL的查询效率，为什么有时候加了索引SQL执行反而会... ......
线程插队Join
public class test04 { public static void main(String[] args) throws InterruptedException { Q q = new Q(); Thread thread = new Thread(q); for (int i = ......
你绝对没想到的GPT的底层意义
学会说话才是完整的人 有种说法在民间流传已久，在某些非洲部落中，孩子出生后往往会被称作“小人”或者“半个人”，直到他们能够进行语言的交流才被认为是完全的人。这是因为在这些部落中，人们认为人类的本质不仅仅在于生命和生理，还在于社交和文化认同，只有在孩子能够适应社会文化并与他人进行交流之后，才能真正成为 ......
【Java 并发】【九】【AQS】【三】基于AQS的共享锁实现、底层源码深度剖析
1 前言 上一节我们详细讲解了基于AQS实现的互斥锁机制，进行了深入的剖析，包括从acquire入口源码开始，剖析了获取锁失败调用addWaiter方法加入等待队列，知道了Node节点是怎么插入等待队列的；同时还剖析acquireQueue方法的源码，解析了插入等待队列之后的节点什么时候被挂起，什么 ......
【Java 并发】【九】【AQS】【二】基于AQS的互斥锁机制、底层源码深度剖析
1 前言 上一节我们从整体上分析了什么是AQS以及AQS内部的数据结构，那么这节我们就从acquire和release入手，分析一下AQS为独占锁提供的机制：到底是怎么在获取资源失败进入等待队列的？以及释放资源的时候怎么唤醒后继节点的线程竞争锁的？ 2 acquire 方法源码解析 首先我们看一下A ......
MyBatis-Plus 写 Join 联表查询
效果展示 背景 众所周知，Mybatis Plus 封装的 mapper 不支持 join，如果需要支持就必须自己去实现。但是对于大部分的业务场景来说，都需要多表 join，要不然就没必要采用关系型数据库了。 使用方法 仓库地址 https://gitee.com/best_handsome/myb ......
A6--Flink部署
一、版本信息 JDK 1.8 flink 1.16.0 二、部署架构 采用flink-on-yarn架构，无需配置集群。客户端把 Flink 应用提交给 Yarn 的 ResourceManager,Yarn 的 ResourceManager 会向 Yarn 的 NodeManager 申请容器。 ......
FOR ALL ENTRIES IN 与 INNER JOIN 内表
1、区别 FOR ALL ENTRIES IN 与 INNER JOIN 内表，目的都是通过内表找数据库表与之对应的数据，但是有区别。 1.1、写法 FOR ALL ENTRIES IN " @斌将军 SELECT acdoca~rldnr,"总账会计中的分类账 acdoca~rbukrs,"公司代 ......
SQL： Join的用法
在 SQL 中，JOIN 是将两个或多个表中的行连接起来的方法。JOIN 的基本思想是将两个表中的数据按照某些条件进行匹配，然后将匹配的结果合并成一个新的表。 常见的 JOIN 类型有 INNER JOIN、LEFT JOIN、RIGHT JOIN 和 FULL OUTER JOIN。 INNER ......
Flink安装
Flink安装 下载并解压 f_v=1.14.4 mkdir -p /opt/software && cd /opt/software wget https://mirrors.bfsu.edu.cn/apache/flink/flink-${f_v}/flink-${f_v}-bin-scala_ ......
【Java 并发】【synchronized】【一】synchronized底层是怎么通过monitor进行加锁的
1 前言 之前我们说过对象头的信息，这节我们就来看看synchronized是怎么通过monitor进行重量级加锁。 2 内容回顾 我们先来回顾下Mark Word的内容： 当Mark Word的最后两位的锁标志位是10的时候，Mark Word这哥们说自己处于重量级锁的模式，重量级加锁不是它的责任 ......
容器功能 底层注解
一、组件添加 1、@Configuration 原来使用配置文件配置bean <bean id="user" class="com.cmq.boot.bean.User"> <property name="name" value="cencen"/> <property name="age" val ......
flink中配置kafka
Flink 提供了 Apache Kafka 连接器，用于从 Kafka topic 中读取或者向其中写入数据，可提供精确一次的处理语义。 一：简单使用 1.pom <!--Flink Connector KAFKA--> <dependency> <groupId>org.apache.flink ......
Flink与mysql结合
在流式计算中，不是有时候需要和mysql进行结合做一些处理。 1.调用其他方法进行 2.更快的处理 使用guava本地缓存 对msql的操作是new对象过来 private final static RuleService ruleService = new RuleService(); final ......
Spatial Join，空间连接
We learned how to use the Spatial Join tool to attach information from one attribute table to another based on the spatial relationship of the feature ......
投屏Sink端音频底层解码并用OpenSLES进行播放
一、代码分析 在公司项目中，音频解码及播放是把数据传到Java层进行解码播放的，其实这个步骤没有必要，完全可以在底层进行处理。 通过代码发现其实也做了在底层进行解码，那么为啥不直接使用底层解码播放呢，我们可以看看原先代码怎么做的： 代码中通过定义的宏DECODE_AUDIO_IN_JAVA来控制mA ......
你还在手写 join 联表查询？MyBatis-Plus 这样写太香了！
使用方法 安装 Maven <dependency> <groupId>com.github.yulichang</groupId> <artifactId>mybatis-plus-join</artifactId> <version>1.2.4</version> </dependency> G ......
SQL Server – 执行计划和各种 join 方式 (Execution plan & Join Pattern)
What, When, Why? 什么是 Execution Plan? Execution plan 里头包含了 query 执行时的各做 information, 比如 IO 速度, 查找了多少 rows 等等 为什么要看 Execution Plan? 当 query 慢的时候, 可以通过分析 ......
redis网络IO模型底层使用IO多路复用，通过reactor模式实现的，在redis 6.0以前属于单reactor单线程模式
详解redis网络IO模型 前言 "redis是单线程的" 这句话我们耳熟能详。但它有一定的前提，redis整个服务不可能只用到一个线程完成所有工作，它还有持久化、key过期删除、集群管理等其它模块，redis会通过fork子进程或开启额外的线程去处理。所谓的单线程是指从网络连接(accept) - ......
《基于Apache Flink的流处理》Part2
Apache Flink 架构 搭建Flink所需组件 Flink 的搭建需要四个不同组件，它们相互协作，共同执行流式应用。这些组件是：JobManager、ResourceManager、TaskManager 和 Dispatcher。Flink 本身是用 Java 和 Scala 实现的，因此 ......
《基于Apache Flink的流处理》Part1
流处理基础 DataFlow 图 Dataflow 程序描述了数据如何在不同操作之间流动。Dataflow 程序通常表示为有向图。图中顶点称为算子，表示计算；而边表示数据依赖关系。算子是Dataflow 程序的基本功能单元,它们从输入获取数据,对其进行计算,然后产生数据并发往输出以供后续处理。没有输 ......
官方文档 | 【JVM调优体系】「GC底层调优实战」XPocket为终结性能问题而生—开发指南
XPocket 用户文档 XPocket 是PerfMa为终结性能问题而生的开源的插件容器，它是性能领域的乐高，将定位或者解决各种性能问题的常见的Linux命令，JDK工具，知名性能工具等适配成各种XPocket插件，并让它们可以相互联动一键解决特定的性能问题。 目前XPocket插件生态已经实现了 ......
多线程join()方法使用
多线程环境下，如果需要确保某一线程执行完毕后才可继续执行后续的代码，就可以通过使用 join 方法完成这一需求设计。 /** * @author wsy */ public class DemoTest implements Runnable { @Override public void run( ......
决战圣地玛丽乔亚Day44---Redis数据结构的底层实现和高可用Cluster
Redis为什么快？ 前面讲了独有的数据结构+IO模型的选用。 除此之外还有什么因素的加持呢？ 1.内存存储，避免磁盘IO的开销，提高读取速度 2.网络模型，使用Reactor模型，处理大量连接请求，同时保持低延迟和高吞吐 3.单线程处理请求。但是RDB，AOF等场景会用到多线程模式。 Redis数 ......
TIdHTTPWebBrokerBridge替换成mormot底层
目前使用案例是git开源项目horse改动 思路大概为http请求被WebBrokerDispatch函数转发到了WebModule中进行后续处理。 替换如下单元源码即可将horse项目的indy底层改成mormot底层，修改原理来源http://bbs.2ccc.com/topic.asp?top ......
5.join原理及用法
join 用法及原理 Sql查询的基本原理 表查询的分类 单表查询 根据 WHERE条件过滤表中的记录，然后根据SELECT指定的列返回查询结果 两表连接查询 使用ON 条件对两表进行连接形成一张虚拟结果集，然后根据WHERE条件过滤结果集中的记录，再根据SELECT指定的列返回查询结果 多表连接查 ......