类型系统与反射 JVM会为每个加载到内存的类创建了一个Class对象，而我们可以通过Class对象来获取类中的Field(字段)、Constructor(构造方法)、Meth...
发简信
IP属地：宁夏
-
-
Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark论文概要 该论文是Spark团队在2018年发表的一篇基于Spark引擎之上新构建的一套Streaming api，Structured Streaming项目在2016年就...
-
Realtime Data Processing at Facebook论文概要 "Realtime Data Processing at Facebook"是Facebook 在2016年发表的论文。论文中介绍了Facebook是如何构建分布式...
-
Flink集群部署模式根据集群的生命周期、资源隔离方式和应用程序的main()方法执行位置(client或者JobManager)可以将集群部署模式分为：Flink Session Cluster...
-
-
Flink状态管理源码分析(三)-快照策略快照策略(SnapshotStrategy) Flink的检查点机制是建立在分布式一致快照之上的，从而实现数据处理的exactly-once处理语义。无论是Keyed sta...
-
@谢谢侬侬侬 你以为不知道你谁，兄弟
Druid系统安装与配置
基础环境 Java8或更高版本 Linux、Mac OSX或者其它类Unix操作系统，目前不支持Windows操系统 8GB内存(内存越高越高) 2核虚拟CPU 外部依赖 深...
-
因为zsh没有使用bash的配置，所以需要将bash的配置添加到zsh配置中
安装完oh my zsh后某些命令不能使用
为了改变一下终端默认比较丑的界面，最近装了下oh My zsh这个神器，装完使用一段时间后发现确实很强大，但最近发现有些命令不能用，遂google一通，最后找到解决办法：修改...
-
Flink系统架构简介Flink系统组成 Flink是一个分层系统，从下到上分为：系统部署层、任务运行层、API层以及基于API开发的通用库层(Libraries)。 Flink部署层 Flink...
-
Flink DataStream API详解Flink API介绍 Flink提供了三层API，每层在简洁性和表达性之间进行了不同的权衡。 ProcessFunction是Flink提供的最具表现力的功能接口，它提供了...
-
-
Storm Trident 之 Trident API介绍Trident是什么 Trident是Storm上的高层次抽象，它能够在提供高吞吐量的能力同时(每秒几百万消息)，也提供了有状态的流式处理和低延迟分布式查询的能力。它类似Pi...
-
-
-
java集合框架总结(二)Set Set集合实现框架： Set是一种无序不重复的集合，它最多只允许有一个null元素。Set接口继承Collection接口，因为Set是无序的所以我们可以看到它的接口...
-
Java 集合框架总结(一)集合概述 Java集合框架标准化了Java处理对象组的方式。Java集合框架在JDK1.2版本提出，在JDK1.5版本进行了修改(引入了泛型、自动装箱/拆箱以及for-eac...
-
Java基础语法回顾(二)
异常处理 异常就是运行时的代码序列引起非正常情况。Java提供的异常机制是通过异常对象来描述错误，当引起异常的情况时，就创建一个能够描述该异常的对象，并在引起错误的方法中将其...
-
Java基础语法回顾(一)Java基础语法 Java规范 Java字节码 java程序是以".java"为扩展名，当我们编写完java程序后,要执行程序需要经过两个阶段：编译和运行。 编译器 执行编译...
