João Boto commented on FLINK-11928:

this is resolved on this issue: 

> Create a Compression string writer for flink-connectors-filesystem
> ------------------------------------------------------------------
>                 Key: FLINK-11928
>                 URL: https://issues.apache.org/jira/browse/FLINK-11928
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / FileSystem
>    Affects Versions: 1.6.3, 1.7.2
>            Reporter: Shengnan YU
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
> 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.

This message was sent by Atlassian Jira

Reply via email to