作者:禪與計(jì)算機(jī)程序設(shè)計(jì)藝術(shù)
https://nightlies.apache.org/flink/flink-docs-master/docs/concepts/flink-architecture/
1. 簡(jiǎn)介
Apache Flink 是一個(gè)框架和分布式處理引擎,用于在無邊界和有邊界數(shù)據(jù)流上進(jìn)行有狀態(tài)的計(jì)算。Flink 能在所有常見集群環(huán)境中運(yùn)行,并能以內(nèi)存速度和任意規(guī)模進(jìn)行計(jì)算。
在企業(yè)級(jí)生產(chǎn)環(huán)境中,由于各種各樣的原因,通常會(huì)要求對(duì)一些組件的參數(shù)進(jìn)行定制化設(shè)置,或者需要加載外部配置文件來控制一些組件的行為。目前,Apache Flink 提供了基于配置文件的動(dòng)態(tài)參數(shù)配置方式,能夠靈活地調(diào)整組件運(yùn)行時(shí)的參數(shù)。除了參數(shù)配置外,F(xiàn)link 還支持通過 Java API 的形式加載外部模型,例如 TensorFlow、PyTorch 和 Scikit-learn 模型。然而,這些模型并不像普通參數(shù)一樣可以直接在配置文件中進(jìn)行配置,因此需要額外的代碼邏輯才能完成配置。本文將介紹如何通過 Java API 來加載外部模型,以及 Flink 中參數(shù)配置的詳細(xì)流程。文章來源:http://www.zghlxwxcb.cn/news/detail-686204.html
2.基本概念術(shù)語說明
Apache Flink
Apache Flink 是建立在 Hadoop MapReduce 框架之上的一個(gè)開源流處文章來源地址http://www.zghlxwxcb.cn/news/detail-686204.html
到了這里,關(guān)于Flink中的自定義參數(shù)與模型配置的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!