Source

Flink Source

Read More

Source

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