[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexander Fedulov updated FLINK-28227: -------------------------------------- Description: Reimplement * CarSource * SimpleSource * SessionWindowing * IterateExample * with the new Source API. Blocks: was: Reimplement * CarSource * SimpleSource * SessionWindowing * IterateExample * with the new Source API. > Migrate o.a.f.streaming.examples to new Source API > -------------------------------------------------- > > Key: FLINK-28227 > URL: https://issues.apache.org/jira/browse/FLINK-28227 > Project: Flink > Issue Type: Sub-task > Components: Examples > Reporter: Alexander Fedulov > Assignee: Alexander Fedulov > Priority: Major > Labels: pull-request-available > > Reimplement > * CarSource > * SimpleSource > * SessionWindowing > * IterateExample > * > with the new Source API. > Blocks: -- This message was sent by Atlassian Jira (v8.20.10#820010)