流批一体基础知识

概述

Apache Flink是一个面向分布式数据流处理和批量数据处理的开源计算平台，它能够基于同一个Flink运行时（Flink Runtime），提供支持流处理和批处理两种类型应用的功能。

在Flink计算引擎中，提供4个层次API，如下所示：

本阶段我们主要讲解Core APIs这一层，从Flink1.12开始，流批处理统一由DataStream完成。

基于Flink计算引擎，进行流式数据==流计算==处理【DataStream API】使用

官方文档：https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/overview/

Flink开发流式计算程序五个步骤：

1. Obtain an execution environment,

   构建执行环境-env：StreamExecutionEnvironment

2. Load/create the initial data,

   数据源-source：DataStream

3. Specify transformations on this data,

   数据转换：DataStream API（算子，Operator）

4. Specify where to put the results of your computations,

   数据接收器-sink

5. Trigger the program execution

   触发执行-execute

实时效果反馈

1. 以下选项中关于Flink流批一体API描述错误的是？

A 基于DataStream API提供支持流处理和批处理两种类型应用的功能。

B 数据处理核心流程Data Source->Transformations->Data Sink。

C 使用DataStreamAPI执行批处理时不需要调用execute方法触发执行。

答案：

1=>C 也需要触发执行。