You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by kk...@apache.org on 2020/03/10 11:46:24 UTC

[flink] branch master updated (6f19fd2 -> 33c6d4b)

This is an automated email from the ASF dual-hosted git repository.

kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 6f19fd2  [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work (#11342)
     add 79de2ea  [FLINK-16371][fs-connector] Make CompressWriterFactory serializable
     add 33c6d4b  [FLINK-16371][fs-connector] Add ITCase

No new revisions were added by this update.

Summary of changes:
 .../formats/compress/CompressWriterFactory.java    | 98 +++++++++++++++++-----
 .../writers/HadoopCompressionBulkWriter.java       | 30 +++----
 .../compress/writers/NoCompressionBulkWriter.java  | 10 ++-
 .../compress/CompressWriterFactoryTest.java        | 80 +++++++++++-------
 .../compress/CompressionFactoryITCase.java}        | 78 ++++++++---------
 .../formats/compress/CustomCompressionCodec.java}  | 16 ++--
 6 files changed, 188 insertions(+), 124 deletions(-)
 copy flink-formats/{flink-sequence-file/src/test/java/org/apache/flink/formats/sequencefile/SequenceStreamingFileSinkITCase.java => flink-compress/src/test/java/org/apache/flink/formats/compress/CompressionFactoryITCase.java} (55%)
 copy flink-formats/flink-compress/src/{main/java/org/apache/flink/formats/compress/CompressWriters.java => test/java/org/apache/flink/formats/compress/CustomCompressionCodec.java} (68%)