Rae 第66页

在flink开发中，如果我们想要去重的话，也会使用到distinct函数，这个distinct函数和sql是一个效果，下面我们用代码演示一下，完整代码示例如下：package org.example; import ...

Rae /flink系列 /2023-08-08 /0 评论 /655 阅读

在flink的开发中，还有一个比较常用的函数就是reduce函数，这个reduce函数是一个聚合函数，他就是mapreduce的思想，map是拆分转换，reduce就是聚合转换。在使用reduce的时候，接收到的ke...

Rae /flink系列 /2023-08-08 /0 评论 /826 阅读

本文的话，我们介绍dataset数据集转换常用的project函数。在开发中，有时候我们会给定一个数据集，例如：张三 16 李四 17 王五 18这个数据集代表的含义是用户的姓名和年龄，但是此时我们有这样一个需求，我...

Rae /flink系列 /2023-08-08 /0 评论 /734 阅读

产品经理如何理解电力现货交易？

前段时间有个群里讨论电力市场化的意义，顺带翻出了去年这篇《产品经理如何理解电力交易市场化？》。最近对电力现货市场交易接触越多，发现去年这篇只限于电力市场化概念化的理解，为此本篇探讨下对于电力现货交易的理解。现货交易参...

Rae /职场感悟 /2023-08-07 /0 评论 /748 阅读

本文的话，我们再介绍下FilterFunction。这里的FilterFunction主要是用于过滤数据的，当匹配的条件为true的话，就会保留数据，匹配条件为false的话，就会丢掉数据。实现FilterFunct...

Rae /flink系列 /2023-08-04 /0 评论 /862 阅读

在前面《Flink应用开发系列（十三）数据集转换之MapFunction》我们介绍了mapfunction，本文的话我们再介绍下这个mappartitionFunction。这里的mappartition和map是差...

Rae /flink系列 /2023-08-04 /0 评论 /838 阅读

上一篇文章《Flink应用开发系列（十三）数据集转换之MapFunction》我们介绍了mapfunction，本文的话我们介绍flatmapfunction。mapfunction对数据转换是1对1的，本文的fla...

Rae /flink系列 /2023-08-04 /0 评论 /820 阅读

相信大家跟着前面的应用开发系列的文章进行充分的自行编码之后，对于flink应用开发都比较熟悉了。本文我们介绍下数据集转换中的mapfunction。mapfunction主要应用于map函数，这里我们可以通过mapf...

Rae /flink系列 /2023-08-04 /0 评论 /1092 阅读

在实际的flink开发中，我们还会涉及到自定义一些参数，然后把这些参数的值传递给某些方法，这样子在这些方法里面就可以获取到对应配置的自定义参数了。在日常的java开发中，我们经常会涉及到使用构造函数向某个类函数传递参...

Rae /flink系列 /2023-08-04 /0 评论 /634 阅读