[FLINK-11928] Create a Compression string writer for flink-connectors-filesystem

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 1.6.3, 1.7.2
• Component/s: Connectors / FileSystem
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Shengnan YU
• Created: 15/Mar/19 08:32
• Updated: 06/Aug/20 14:36
• Resolved: 06/Aug/20 14:36

Description

Flink does not provided a API for writer compressed string text file to filesystem. I have implemented a simple CompressionStringWriter can compressed the stream and write to the FS. The default writing is to call toString() method for element and separate them by newline. Extending this class and override write() method can make custom writting.

Issue Links

• links to: GitHub Pull Request #7991