Bowen Li created FLINK-9545:
-------------------------------
Summary: Support read file for N times in Flink stream
Key: FLINK-9545
URL: https://issues.apache.org/jira/browse/FLINK-9545
Project: Flink
Issue Type: Improvement
Components: DataStream API
Affects Versions: 1.6.0
Reporter: Bowen Li
Assignee: Bowen Li
Fix For: 1.6.0
we need {{StreamExecutionEnvironment.readFile/readTextFile}} to read each file
for N times, but currently it only supports reading file once.
add support for the feature.
Plan:
add a new processing mode as PROCESSING_N_TIMES, and add additional parameter
{{numTimes}} for {{StreamExecutionEnvironment.readFile/readTextFile}}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
