You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "João Boto (Jira)" <ji...@apache.org> on 2020/02/12 21:05:00 UTC
[jira] [Commented] (FLINK-11928) Create a Compression string writer
for flink-connectors-filesystem
[ https://issues.apache.org/jira/browse/FLINK-11928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035709#comment-17035709 ]
João Boto commented on FLINK-11928:
-----------------------------------
this is resolved on this issue: [https://github.com/apache/flink/commit/959cf62a219270ed936f5c1ce04bc38c1f456092]
> 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
(v8.3.4#803005)