Flink中什麼是富函式

2021-10-23 08:08:19 字數 646 閱讀 9355

許多時候我們需要在函式處理第一條記錄之前就進行一些初始話工作或是取得函式執行時相關的上下文資訊。

我定義了乙個map運算元,現在我如果要在map運算元在處理第一條記錄之前,就想取得該函式執行時的相關資訊,和進行一些初始話工作。那麼**就應當類似於如下方式:

**.map(x=> 定義乙個富函式)

在使用富函式的時候,我們可以對函式的生命週期實現兩個額外的方法:

close():

舉例:我想要在使用map運算元處理計算的時候,連線資料庫,這個連線的**只會執行一次,後續不會再執行,就可以利用富函式的初始話方法來進行定義.

這裡我以flatmap富函式舉例:

class

flatmap_rich

extends

richflatmapfunction

//建立初始話函式,例如建立和外部系統的連線

override def flatmap(in

: in,out:collector)(

):unit =

//做一些操作

override def close : unit =

//做一些清理工作,例如關閉和外部系統的連線

}

什麼是函式

從數學到程式設計,了解什麼是函式!函式 function 的定義通常分為傳統定義和近代定義,函式的兩個定義本質是相同的,只是敘述概念的出發點不同,傳統定義是從運動變化的觀點出發,而近代定義是從集合 對映的觀點出發。函式的近代定義是給定乙個數集a,假設其中的元素為x,對a中的元素x施加對應法則f,記作...

什麼是函式?

1 函式是乙個可以多次使用的功能 塊,乙個封閉的 空間 它可以在 裡隨意呼叫。利用函式的封裝可以減少重複 的開發,提高 的利用率。函式可以傳參,利用函式內預先定義的內容對傳入的不同資料引數進行處理。2 函式也是物件,也可以為值,它可以存在於變數,陣列和物件之中。3 函式可以當參傳遞給函式,並且由函式...

什麼是函式

在7.1章的學習中,作者挑戰了不引用相應的標頭檔案而呼叫函式。一開始,我自然是不知道如何運作的,只能把三個流程打出來,才慢慢認識到作者在幹什麼以及函式的本質 這個函式十分簡單,只要呼叫了標頭檔案string.h,就可以便捷的使用strcmp函式,比較大小。但如果沒有這個標頭檔案呢?在這裡插入描述 在...