Shengnan YU created FLINK-11928:
-----------------------------------

             Summary: 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.7.2, 1.6.3
            Reporter: Shengnan YU


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
(v7.6.3#76005)

Reply via email to