发表于 | 分类于
字数统计: 2.5k | 阅读时长 ≈ 11
[TOC] 一、Transformations 分类Flink 的 Transformations 操作主要用于将一个和多个 DataStream 按需转换成新的 DataStream。它主要分为以下三类： DataStream Transformations：进行数据流相关转换操作； Physi ...
阅读全文 »

发表于 | 分类于
字数统计: 986 | 阅读时长 ≈ 3
[TOC] CheckPoints为了使 Flink 的状态具有良好的容错性，Flink 提供了检查点机制 (CheckPoints) 。通过检查点机制，Flink 定期在数据流上生成 checkpoint barrier ，当某个算子收到 barrier 时，即会基于当前状态生成一份快照，然后再 ...
阅读全文 »

发表于 | 分类于
字数统计: 2k | 阅读时长 ≈ 8
[toc] 一、内置 Data SourceFlink Data Source 用于定义 Flink 程序的数据来源，Flink 官方提供了多种数据获取方法，用于帮助开发者简单快速地构建输入流，具体如下： 1.1 基于文件构建1. readTextFile(path)：按照 TextInputFor ...
阅读全文 »

发表于 | 分类于
字数统计: 1.6k | 阅读时长 ≈ 6
[toc] 一、Data Sinks在使用 Flink 进行数据处理时，数据经 Data Source 流入，然后通过系列 Transformations 的转化，最终可以通过 Sink 将计算结果进行输出，Flink Data Sinks 就是用于定义数据流最终的输出位置。Flink 提供了几个 ...
阅读全文 »

发表于 | 分类于
字数统计: 2.2k | 阅读时长 ≈ 8
[TOC] 一、Flink 简介简单来说，Flink 是一个分布式的流处理框架，它能够对有界和无界的数据流进行高效的处理。Flink 的核心是流处理，当然它也能支持批处理，Flink 将批处理看成是流处理的一种特殊情况，即数据流是有明确界限的。这和 Spark Streaming 的思想是完全相反 ...
阅读全文 »

发表于 | 分类于
字数统计: 3.1k | 阅读时长 ≈ 11
[TOC] Java基础java中Object类中有哪些方法，他们的作用分别是什么？ java中的多态的含义？ java常用的会抛出哪些异常类型？ 代理模式的API 集合 HashMap多线程下会有什么问题？ 基本数据类型 装箱拆箱？（-128到127） 说说String、StringBuilder ...
阅读全文 »

发表于 | 分类于
字数统计: 3.7k | 阅读时长 ≈ 16
[TOC] 一、题目描述建立三个线程A、B、C，A线程打印10次字母A，B线程打印10次字母B,C线程打印10次字母C，但是要求三个线程同时运行，并且实现交替打印，即按照ABCABCABC的顺序打印。 二、Synchronized同步法1、基本思路使用同步块和wait、notify的方法控制三个线程 ...
阅读全文 »

发表于 | 分类于
字数统计: 315 | 阅读时长 ≈ 1
CPU 32 64位啥意思，内存最小单位，CPU如何寻址 计算机中的位数指的是CPU一次能处理的最大位数 内存是由很多个内存单元组成的，每个内存单元占8个bit位（1字节），也就是说内存中有多少个内存单元就意味着可以存储多少个字节，下面是一个只有两个内存单元的内存概念图： 计算机有哪些存储设备，c ...
阅读全文 »

发表于 | 分类于
字数统计: 908 | 阅读时长 ≈ 3
[TOC] 前置知识聚簇索引：将数据存储与索引放到了一块，索引结构的叶子节点保存了行数据 非聚簇索引：将数据与索引分开存储，索引结构的叶子节点指向了数据对应的位置 Mysql Btree 索引结构 如果是聚簇索引，那么索引的叶节点保存了索引值以及数据data。 Page 页：是Innodb存储的最 ...
阅读全文 »

发表于 | 分类于
字数统计: 244 | 阅读时长 ≈ 1
工厂简单工厂在创建一个对象时不向客户暴露内部细节，并提供一个创建对象的通用接口。一个工厂生产多种产品 工厂每种工厂生产不同的产品 抽象工厂抽象工厂模式创建的是对象家族，也就是很多对象而不是一个对象，并且这些对象是相关的，也就是说必须一起创建出来。而工厂方法模式只是用于创建一个对象，这和抽象工厂模式有 ...
阅读全文 »