Flink实战学习（八）Flink开发如何获取执行环境
我们在写flink的kob代码的时候，大家心理应该都有印象，第一步就是需要去获取一个flink的执行环境。例如在之前的代码里面我们是直接用的如下代码：StreamExecutionEnvironment e...
Rae
Flink实战学习（七）Flink编程API对应的maven依赖关系
目前我们编写flink程序有很多种实现方式，有java的，有scala的，有python的等等，这里我们介绍下针对于java方面，如果涉及到flink编程，那么哪些api对应使用哪些maven依赖呢？一、flink的...
Flink实战学习（六）分析Flink的整体架构
在前面几篇文章里面，我们介绍了flink的几种API操作数据，在这些简单的案例里面，我们可以看到flink的一些基础功能模块及实现效果。这篇文章我们剖析下flink的整体架构。不多说，先来一张flink的整体架构图...
Flink实战学习（五）如何生成flink的任务执行计划图
在flink里面，我们编写了job之后，我们有时候需要了解下flink到底怎么执行的这个job。在原生的代码里面，我们写的代码量很少，很难看得出来具体的执行过程。所以在这里flink官方提供了一个可以直接可视化生成f...
Flink实战学习（三）使用Table API处理无界数据流
前两篇我们介绍了使用DataSet和DataStream api操作flink的数据流，这篇文章我们介绍下使用Table API 操作flink的无界数据流。这里的Table API操作flink的无界数据流其实方式...
Flink实战学习（一）使用DataSet API处理有界数据流
最近处于学习复盘的阶段，因此准备写一系列关于flink的实战相关的文章。今天介绍下第一篇，在flink中使用DataSet API处理有界数据流。学习下基础知识1、DataSet API是flink里面做批量计算的一...
实战elasticsearch手动创建mapping
在elasticsearch中，虽然在索引数据的时候，elasticsearch会自动为我们创建mapping，但是我们在真实环境查询的时候，不一定能满足我们想要的需求，因此这里我们手动的创建一下mapping，并且...
实战elasticsearch手动创建/更新/删除索引
这篇文章我们演示下如何手动创建/更新/删除elasticsearch索引。一、创建索引这里我们创建一个叫做test的索引，副本数量是0，分片数量是10.put /test{ ...
