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
相关文章
相关标签/搜索