首页 > 其他分享 >Flink的3中API

Flink的3中API

时间:2023-08-29 16:57:08浏览次数:30  
标签:DataStream 批处理 Flink DataSet API Table

DataStream/DataSet/Table API是Apache Flink提供的三种不同的API,用于处理不同类型的数据和实现不同的计算模型。

1. DataStream API:DataStream API是基于流式数据的API,用于处理连续不断到达的数据流。它适用于实时数据处理和流式计算场景。DataStream API提供了丰富的操作符和函数,可以进行数据转换、过滤、聚合、窗口操作等。

2. DataSet API:DataSet API是基于批处理的API,用于处理有限的、静态的数据集。它适用于离线数据处理和批处理计算场景。DataSet API提供了类似于关系型数据库的操作符,可以进行数据的转换、筛选、分组、连接等。

3. Table API:Table API是一种声明式的API,提供了类似于SQL的语法,用于处理结构化数据。它可以在DataStream和DataSet之上进行操作,使得流处理和批处理之间的转换更加方便。Table API提供了丰富的表达式、函数和操作符,可以进行数据查询、过滤、聚合、连接等。 这三种API在功能和使用方式上有所区别,可以根据具体的场景和需求选择合适的API进行开发和使用。

标签:DataStream,批处理,Flink,DataSet,API,Table
From: https://www.cnblogs.com/zjb480/p/17665296.html

相关文章

  • 要调用API接口获取商品数据,首先需要了解该API的文档和规范
    要调用API接口获取商品数据,首先需要了解该API的文档和规范。大多数API都需要使用API密钥进行身份验证,因此您需要先注册API提供商,并从他们那里获取API密钥。以下是一些通用的步骤:注册API提供商并获取API密钥在开始使用任何API之前,您需要先注册API提供商,并从他们那里获取API密钥。请......
  • RESTful API规范,序列化,Django Rest_Framework
    一.RESTfulAPI规范REST全称是RepresentationalStateTransfer,中文意思是表述(编者注:通常译为表征性状态转移)。它首次出现在2000年RoyFielding的博士论文中。RESTful是一种定义WebAPI接口的设计风格,尤其适用于前后端分离的应用模式中。这种风格的理念认为后端开发任......
  • FastAPI.3
    FastApi3一、怎么理解FastAPI应用程序运行产生的日志(fastapi_demo)PSD:\ProgramFiles\fastapi_demo>uvicornmain:app--reloadINFO:Willwatchforchangesinthesedirectories:['D:\\ProgramFiles\\fastapi_demo']#FastAPI将监视的文件夹,以便在文件更改时重......
  • 一个程序员眼中的API调用(淘宝/天猫/1688/拼多多API)
    在程序员眼中,API调用是一种重要的编程概 念,它允许开发人员通过预先定义好的接口和规范,调用其他应用程序或服务的功能。API调用是现代软件开发中不可或缺的一部分,它使得开发人员能够快速构建出复杂的应用程序,同时避免了重复开发常见的功能模块。 以下是一个程序员眼中API调......
  • Swagger3 (OpenAPI3)自定义参数对象渲染设置ModelConverter
    Swagger2设置方法以SpringDataJPA里的分页参数Pageable为例,在使用Swagger2的时候,可以通过自定义AlternateTypeRule,修改参数对象的参数渲染;如下/***分页参数实体类参数转换,让swagger显示正常的传参**@paramresolver*@return*/@BeanpublicAlternateTy......
  • ArcGIS Javascript sdk中API keys 的说明
    ArcGISJavascriptsdk中APIkeys的说明关于ArcGIS的APIkey具体使用ArcGIS有那些底图用到了APIkeys,那些没有用到可以参考下面表格,最新改动请参考官网BasemapsforusewithAPIkeysUseofthesebasemapsrequiresanArcGISDevelopersubscription.Tolearnmoreabout......
  • sqlite3C语言api
    安装sqliteapt-getinstallsqlite3进入和退出sqlite3//进入sqlite3,内容保存至内存,退出后内容会丢失sqlite3<表名>//保存到文件中,例sqlite3student.exit//退出sqlite3,‘.'不能少创建表#以学生表为例createtablestudent(idinteger,nametext,ageinteger......
  • .NET API 中的 FromRoute、FromQuery、FromBody 用法
    原文链接:https://www.cnblogs.com/ysmc/p/17663663.html最近技术交流群里,还有不少小伙伴不知道 FromRoute、FromQuery、FromBody这几个特性是怎么使用的,也不清楚它们之间的区别在哪里,特意写下这个文章,希望可以帮助到迷茫的小伙伴。在API开发过程中,我们先要确定我们的接口......
  • Windows服务作为Web API的服务端
    将Windows服务作为WebAPI的服务端,需要实现一个WebAPI控制器,并将其集成到Windows服务中。以下是一些基本步骤:在您的Windows服务项目中创建一个新的WebAPI控制器。您可以使用VisualStudio的类库模板来创建一个空的WebAPI项目,然后将控制器添加到该项目中。实现WebAPI控制器......
  • 实验3:媒体API之口述校史
    一、实验目标掌握视频API的操作方法;掌握如何发送随机颜色的弹幕。二、实验步骤根据实验手册上的网址,下载视频播放图标,图片如下。进入微信开发者工具,创建一个新项目videoDemo。在根目录下的app.json中定义导航栏标题和背景颜色,如下图所示。根据实验文档,页面设......