- 1. 使用原始流以获得更好的性能
2024年08月06日
一、 Filnk简介和编程模型
Flink使用java语言开发，提供了scala编程的接口。使用java或者scala开发Flink是需要使用jdk8版本，如果使用Maven，maven版本需要使用3.0.4及以上。
Dataflows:
2024年08月06日
要计算数字流上的和，max，min，average等，我们可以将非数字流映射到数值流类型(IntStream，LongStream或DoubleStream)，然后使用专门的方法。
以下代码计算收入的总和。 mapToDouble()方法将 Stream<Employee> 转换为 DoubleStream 。对DoubleStream调用sum()方法。
2024年08月06日
Flink 应用程序结构就是如上图所示：
1、Source: 数据源，Flink 在流处理和批处理上的 source 大概有 4 类：基于本地集合的 source、基于文件的 source、基于网络套接字的 source、自定义的 source。自定义的 source 常见的有 Apache kafka、Amazon Kinesis Streams、RabbitMQ、Twitter Streaming API、Apache NiFi 等，当然你也可以定义自己的 source。
2024年08月06日
概念：Stream是java8提出的一个新的概念，不是输入输出的Stream流，而是一种函数式编程方式在集合类上进行复杂的操作的工具，简言之就是，以内部迭代的方式处理集合数据的操作，内部迭代可以将更多的控制权交给集合类。Stream和Iterator的功能类似，只是Iterator是以外部的形式处理集合数据的操作。
2024年08月06日
java8的并行Stream对开发者非常友好，非常容易实现并行计算。并行Stream底层使用ForkJoinTask实现Stream的并行处理，充分利用cpu的多核能力，Stream的API将底层复杂实现完全屏蔽了，开发者仅需调用一个方法即可实现并行计算，就是这么简单。
2024年08月06日
Java Stream是Java 8引入的一个用于处理集合数据的新抽象。它提供了一种更为便捷、强大且可读性更高的方式来操作集合元素。Stream可以用于串行或并行地对集合进行操作，支持函数式编程的风格。以下是Java Stream的一些常见用法和技巧，每个都附带有相应的代码示例。
2024年08月06日
1.copyProperties() 复制对象参数的方法，当两个对象中的参数有一部分是一致的时候，用这个方法，不需要一个一个get,set参数了。
BeanUtils.copyProperties(传值对象,被传值对象);（这个不会自动转换类型，但是效率高）