在Flink的官网写着:Stateful Computations over Data Streams。 基于状态计算的数据流。 在流式计算中,希望做一些聚合分析等。那么就需要保存当前日志的状态,以备与后来的日志做比较。 在Flink中每个操作都会有状态的保存无论是source、sink还是oper ...
分类:
其他好文 时间:
2020-05-26 12:38:24
阅读次数:
87
写在前面 先说点题外话:不少读者工作几年后,仍然在使用Java7之前版本的方法,对于Java8版本的新特性,甚至是Java7的新特性几乎没有接触过。真心想对这些读者说:你真的需要了解下Java8甚至以后版本的新特性了。 今天,一名读者出去面试,面试官问他:说说Java8中创建Stream流有哪几种方 ...
分类:
编程语言 时间:
2020-05-26 01:09:12
阅读次数:
69
What is the difference between sed and awk sed is a stream editor. It works with streams of characters on a per-line basis. It has a primitive program ...
分类:
其他好文 时间:
2020-05-24 11:34:00
阅读次数:
81
http://php.net/manual/zh/wrappers.php.php php:// — 访问各个输入/输出流(I/O streams) 说明 ¶ PHP 提供了一些杂项输入/输出(IO)流,允许访问 PHP 的输入输出流、标准输入输出和错误描述符, 内存中、磁盘备份的临时文件流以及可以 ...
分类:
Web程序 时间:
2020-05-24 09:45:02
阅读次数:
62
环境描述:测试环境LNMP因为后端是php编写,所以在nginx配置文件里upstreamcommon{server127.0.0.1:9000;server127.0.0.1:9001;server127.0.0.1:9002;}客户端发现两个接口一个一直再报502,一个再报502和500.然后就开始排查开发模式的DBUG发现的确存在500现象,但是没有产生502的问题。然后就怕查到nginx错
分类:
其他好文 时间:
2020-05-21 09:46:44
阅读次数:
56
Flink 的核心语义和架构模型我们在讲解 Flink 程序的编程模型之前,先来了解一下 Flink 中的 Streams、State、Time 等核心概念和基础语义,以及 Flink 提供的不同层级的 API。 Flink 核心概念Streams(流),流分为有界流和无界流。有界流指的是有固定大小 ...
分类:
其他好文 时间:
2020-05-13 20:23:42
阅读次数:
58
随着 JDK 1.8 Streams API 的发布,使得 HashMap 拥有了更多的遍历的方式,但应该选择那种遍历方式?反而成了一个问题。 本文先从 HashMap 的遍历方法讲起,然后再从性能、原理以及安全性等方面,来分析 HashMap 各种遍历方式的优势与不足,本文主要内容如下图所示: 这 ...
分类:
其他好文 时间:
2020-05-04 17:17:22
阅读次数:
42
[toc] Iterator to list的三种方法 简介 集合的变量少不了使用Iterator,从集合Iterator非常简单,直接调用Iterator方法就可以了。 那么如何从Iterator反过来生成List呢?今天教大家三个方法。 使用while 最简单最基本的逻辑就是使用while来遍历 ...
分类:
其他好文 时间:
2020-04-30 09:32:26
阅读次数:
51
随着 JDK 1.8 Streams API 的发布,使得 HashMap 拥有了更多的遍历的方式,但应该选择那种遍历方式?反而成了一个问题。 本文 先从 HashMap 的遍历方法讲起,然后再从性能、原理以及安全性等方面,来分析 HashMap 各种遍历方式的优势与不足 ,本文主要内容如下图所示: ...
分类:
其他好文 时间:
2020-04-29 18:24:53
阅读次数:
59
1、排序 import lombok.Data; import java.util.*; import java.util.stream.Collectors; public class StreamStudy { public static void main(String[] args) { U ...
分类:
其他好文 时间:
2020-04-27 13:08:32
阅读次数:
77