Flink Source

Read More

Source

• env.readTextFile
• env.socketTextStream
• env.fromCollection
• Connector