02_Flink Streaming SourceFunction

env對象的addSource(SourceFunction)。須要傳入一個SourceFunction對象。這個對象做爲接入數據源的接口java package com.alibaba.flink.train.streaming; import org.apache.flink.configuration.Configuration; import org.apache.flink.strea
相關文章
相關標籤/搜索