Source
Flink Source
Read More
Source
env.readTextFile
env.socketTextStream
env.fromCollection
Connector