[ https://issues.apache.org/jira/browse/BEAM-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kyoungha Min closed BEAM-9740. ------------------------------ Fix Version/s: Not applicable Resolution: Won't Fix > User Defined Compression > ------------------------ > > Key: BEAM-9740 > URL: https://issues.apache.org/jira/browse/BEAM-9740 > Project: Beam > Issue Type: Wish > Components: sdk-java-core > Reporter: Kyoungha Min > Priority: Minor > Fix For: Not applicable > > > Some users, including myself, have asked for various compression types > support. > Currently, the `org.apache.beam.sdk.io.Compression` is an enum type, which > cannot be overridden by users. > Split up the interface so that users can feed their own user-defined > ComrpessionFactory. > > {code:java} > public interface CompressionFactory extends Serializable { > ReadableByteChannel readDecompressed(ReadableByteChannel channel) throws > IOException; > WritableByteChannel writeCompressed(WritableByteChannel channel) throws > IOException; > String getSuggestedSuffix(); > boolean isCompressed(String filename); > boolean matches(String filename); > } > {code} > > And the current -- This message was sent by Atlassian Jira (v8.3.4#803005)