https://github.com/apache/flink-training/pull/89
done. pr at here. though in this branch we still be using the old deprecated Source based api. But as shown at https://issues.apache.org/jira/browse/FLINK-28045 , seems no much movement to on really deleting these api for nearly a year, so I think maybe it is already useful. As for the new API, I'm migrating it on another branch. somehow slowly though. As for scala, I don't want to pretend to be interested, nor do I think there be much people really interested in scala. If they really love the so called scala so much, they'd be willing to migrate it by themselves. Xeno Amess <xenoam...@gmail.com> 于2025年7月24日周四 18:27写道： > Half done. > Would finish it this weekend(or if really unluckily, before next weekend > ends) > Wanna ask, if you mind me stay the legacy apis, or wanna migrate to a suit > of new apis. > > import org.apache.flink.streaming.api.functions.sink.legacy.PrintSinkFunction; > import org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction; > import org.apache.flink.streaming.api.functions.source.legacy.SourceFunction; > > if you mean it. >
