Data Sink:writerAsText 以文本格式輸出詳解
該方法是將數(shù)據(jù)以文本格式實時的寫入到指定的目錄中,本質(zhì)上使用的是TextOutputFormat格式寫入的。每輸出一個元素,在該內(nèi)容后面同時追加一個換行符,最終以字符的形式寫入到文件中,目錄中的文件名稱是該Sink所在subtask的Index + 1。
該方法還有一個重載的方法,可以額外指定一個枚舉類型的參數(shù)writeMode,默認(rèn)是WriteMode.NO_OVERWRITE,如果指定相同輸出目錄下有相同的名稱文件存在,就會出現(xiàn)異常。如果是WriteMode.OVERWRITE,會將以前的文件覆蓋。
