04_Flink Streaming DataStream

DataStream對象，簡稱ds，做爲流計算編程的核心上下文。提供多種功能java //1:接入數據源express 1：ds由env和SourceFunction產生，完成接入數據源的功能apache //2:數據處理編程 2：filter。實現過濾功能windows 3：map，實現1->1的映射轉換api 4：flatmap，實現拆解字符串等複雜的轉換功能性能優化 5：project，實現

>>阅读原文<<