小編給大家分享一下Apache Flink 1.6.0有哪些改進(jìn)，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！
Apache Flink 1.6.0 重要更新主要包含以下幾點：
Flink 的狀態(tài)支持是使 Flink 在實現(xiàn)各種用例方面如此通用和強大的關(guān)鍵特性之一。為了使其更加容易使用，社區(qū)為其添加了 TTL 的原生支持(FLINK-9510, FLINK-9938)，此功能允許在狀態(tài)過期之后能夠清理狀態(tài)。在 Flink 1.6.0 中，定時器狀態(tài)現(xiàn)在可以脫離出系統(tǒng)，而直接將其存放在 RocksDB 中（FLINK-9485）。最后，定時器的刪除也得到顯著提升(FLINK-9423)。
在 Flink 1.5.0 中，我們重新設(shè)計了 Flink 分布式架構(gòu)，以增加對資源彈性和不同部署方案的支持，同時容器的集成得到進(jìn)一步的提升。而在 Flink 1.6.0 中，對這里面一些沒完成的進(jìn)行了完善：所有的外部通信（包括作業(yè)提交）現(xiàn)在都是基于 HTTP/REST 的（FLINK-9280），這大大簡化了容器（container）的設(shè)置（FLINK-9280）。Flink 1.6.0 還引入了容器入口點（container entrypoint），可以輕松引導(dǎo)容器化作業(yè)集群（FLINK-9488）。
流式 SQL 是最具有潛力的功能之一，因為它使 Flink 更易于訪問。在 Apache Flink 1.6.0 中，社區(qū)進(jìn)一步改進(jìn)了 SQL CLI（FLINK-8863），使得針對大量數(shù)據(jù)源執(zhí)行流式處理和批處理查詢變得輕而易舉（FLINK-8861）。此外，完整的 Avro 支持可以無縫地讀取任何 Avro 數(shù)據(jù)（FLINK-9444）。最后，社區(qū)強化了 Flink 的 CEP 庫(FLINK-9418)。
在最新的 Flink 版本中，我們添加了一個新的 StreamingFileSink（FLINK-9750），它將 BucketingSink 作為標(biāo)準(zhǔn)文件接收器。同時增加了對 ElasticSearch 6.x 的支持（FLINK-7386），并對 AvroDeserializationSchemas 做了修改，使得我們更加容易地攝取 Avro 數(shù)據(jù)（FLINK-9338）。
其他新功能以及提升
支持狀態(tài) TTL (FLINK-9510, FLINK-9938)
基于 RocksDB 的可擴(kuò)展計時器(FLINK-9485)
更快刪除定時器（FLINK-9423），顯著提升定時器的刪除。
添加了作業(yè)集群容器入口點（FLINK-9488）：Flink 1.6.0 還引入了容器入口點（container entrypoint），可以輕松引導(dǎo)容器化作業(yè)集群（FLINK-9488）。
Fully RESTified Job Submission（FLINK-9280）
SQL 客戶端 CLI 支持用戶定義函數(shù)（FLINK-8863）
SQL 客戶端 CLI 支持批處理查詢（FLINK-8861）
SQL 客戶端 CLI 支持 INSERT INTO 語句（FLINK-8858）
統(tǒng)一表接收器（Table Sinks）和格式（FLINK-8866，F(xiàn)LINK-8558）
新的 Kafka Table Sink（FLINK-9846）
Full SQL Avro Support (FLINK-9444)
提高了 SQL 和 Table API 的表達(dá)能力（FLINK-5878, FLINK-8688, FLINK-6810）
以上是“Apache Flink 1.6.0有哪些改進(jìn)”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)-成都網(wǎng)站建設(shè)公司行業(yè)資訊頻道！
重慶分公司
重慶分公司
