Flink：ApacheFlink是一个计算框架和分布式处理引擎，用于对***和有界数据流进行有状态计算。其针对数据流的分布式计算提供了数据分布、数据通信以及容错机制等功能。Flink主要特点：1、高吞吐、低延迟、纯流式架构；2、支持对乱序事件的处理；3、有状态、提供exactly-once计算；4、高度灵活的窗口机制；5、失败恢复、故障转移、水平扩展；6、批处理、流处理统一的APINBI大数据可视
分类：
其他好文 时间：
2020-06-11 21:28:52
阅读次数：
114
准备数据 数据集读入 数据集乱序 生成训练集和测试集 特征和标签配对，每次读入一小撮（batch） 搭建网络 定义神经网络中所有可训练参数 参数优化 嵌套循环迭代，with结构更新参数，显示当前loss 测试效果 计算当前参数前向传播后的准确率，显示当前acc acc/loss可视化 from sk ...
分类：
其他好文 时间：
2020-05-31 12:59:53
阅读次数：
134
题目：在一个大文件中有10G个整数，乱序排列，要求找出中位数（内存有2G限制，不能一次全部加装），请写出算法设计思路。 中位数的定义：对于一个排序好的序列，如果数据有奇数个的话，中位数就取中间的一个；如果有偶数个的话，中位数一般取中间两个数的平均值。 解题： 思路一：堆排序（转换为求前5G大的元素） ...
分类：
其他好文 时间：
2020-05-29 17:33:39
阅读次数：
108
ip协议不可靠，会丢失、出错、乱序 延迟、重复 tcp可靠性是指数据的可靠传递，或故障的可靠通知 tcp为保证可靠性，使用了“带重传的正面确认”技术 1.发送端需要知道接收端有没有收到段，接收端需要返回ack。 2.超时未收到ack就重传，重传会导致段重复，序号可以识别重复的段 3.停等式发一个确认 ...
分类：
其他好文 时间：
2020-05-26 20:05:58
阅读次数：
77
一、Volatile 一段代码引发的思考，下面这段代码，演示了一个使用 volatile 以及没使用volatile 这个关键字，对于变量更新的影响 public class VolatileDemo { public volatile static boolean stop = false; pu ...
分类：
编程语言 时间：
2020-05-23 18:08:59
阅读次数：
48
Flink 框架中支持事件时间、摄入时间和处理时间三种。而当我们在流式计算环境中数据从 Source 产生，再到转换和输出，这个过程由于网络和反压的原因会导致消息乱序。因此，需要有一个机制来解决这个问题，这个特别的机制就是“水位线”。 Flink 的窗口和时间根据窗口数据划分的不同，目前 Flink ...
分类：
其他好文 时间：
2020-05-23 16:25:22
阅读次数：
53
根据该文章整理 https://blog.csdn.net/myxmu/article/details/80350251 解决的问题内存屏障主要解决了单处理器下的乱序问题和多处理器下的内存同步问题。2 为什么会乱序现在的CPU一般采用流水线来执行指令。一个指令的执行被分成：取指、译码、访存、执行、写 ...
分类：
系统相关 时间：
2020-05-14 19:20:42
阅读次数：
75
171. 乱序字符串 中文English 给出一个字符串数组S，找到其中所有的乱序字符串(Anagram)。如果一个字符串是乱序字符串，那么他存在一个字母集合相同，但顺序不同的字符串也在S中。 样例 样例1: 输入:["lint", "intl", "inlt", "code"] 输出:["lint ...
分类：
其他好文 时间：
2020-05-06 09:11:35
阅读次数：
64
最近在学习ios开发，使用OC语言。 遇到需要打乱对象数组的需求，解决方式如下： - (NSArray *) randomArr:(NSArray *)arr {// 对数组乱序 arr = [arr sortedArrayUsingComparator:^NSComparisonResult(Pe ...
分类：
编程语言 时间：
2020-05-04 21:35:03
阅读次数：
81
1.对数组打乱顺序 <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title ...
分类：
编程语言 时间：
2020-04-22 11:38:59
阅读次数：
71
