[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--------------------------------------
Description:
* SocketTextStreamFunction (org.apache.flink.streaming.api.functions.source)
* FiniteTestSource (org.apache.flink.streaming.util)
* FromIteratorFunction (org.apache.flink.streaming.api.functions.source)
* Generator in FileSinkProgram (org.apache.flink.connector.file.sink)
* RichSourceFunction (org.apache.flink.streaming.api.functions.source)
* FileMonitoringFunction (org.apache.flink.streaming.api.functions.source)
* FromElementsFunction (org.apache.flink.streaming.api.functions.source)
* PeriodicSourceGenerator in PeriodicStreamingJob
(org.apache.flink.streaming.tests)
* Generator in StreamSQLTestProgram (org.apache.flink.sql.tests)
* ParallelSourceFunction (org.apache.flink.streaming.api.functions.source)
* ExternallyInducedSource (org.apache.flink.streaming.api.checkpoint)
was:
* SocketTextStreamFunction (org.apache.flink.streaming.api.functions.source)
* FiniteTestSource (org.apache.flink.streaming.util)
* FromIteratorFunction (org.apache.flink.streaming.api.functions.source)
* Generator in FileSinkProgram (org.apache.flink.connector.file.sink)
* RichSourceFunction (org.apache.flink.streaming.api.functions.source)
* FileMonitoringFunction (org.apache.flink.streaming.api.functions.source)
* FromElementsFunction (org.apache.flink.streaming.api.functions.source)
* PeriodicSourceGenerator in PeriodicStreamingJob
(org.apache.flink.streaming.tests)
* Generator in StreamSQLTestProgram (org.apache.flink.sql.tests)
* ParallelSourceFunction (org.apache.flink.streaming.api.functions.source)
* ExternallyInducedSource (org.apache.flink.streaming.api.checkpoint)
* in addSource() in StreamExecutionEnvironment
(org.apache.flink.streaming.api.scala)
> Cascade deprecation to classes that directly implement SourceFunction
> ---------------------------------------------------------------------
>
> Key: FLINK-32693
> URL: https://issues.apache.org/jira/browse/FLINK-32693
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Common
> Reporter: Alexander Fedulov
> Assignee: Alexander Fedulov
> Priority: Major
>
> * SocketTextStreamFunction (org.apache.flink.streaming.api.functions.source)
> * FiniteTestSource (org.apache.flink.streaming.util)
> * FromIteratorFunction (org.apache.flink.streaming.api.functions.source)
> * Generator in FileSinkProgram (org.apache.flink.connector.file.sink)
> * RichSourceFunction (org.apache.flink.streaming.api.functions.source)
> * FileMonitoringFunction (org.apache.flink.streaming.api.functions.source)
> * FromElementsFunction (org.apache.flink.streaming.api.functions.source)
> * PeriodicSourceGenerator in PeriodicStreamingJob
> (org.apache.flink.streaming.tests)
> * Generator in StreamSQLTestProgram (org.apache.flink.sql.tests)
> * ParallelSourceFunction (org.apache.flink.streaming.api.functions.source)
> * ExternallyInducedSource (org.apache.flink.streaming.api.checkpoint)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
