Github user mtanski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2002#discussion_r76121574
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/compression/InflaterInputStreamFactory.java
---
@@ -23,13 +23,12 @@
import
Github user mtanski commented on the issue:
https://github.com/apache/flink/pull/2002
This has been sitting around for a month. Any chance to merge or clear todo
in order to get this in shape.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user mtanski commented on the issue:
https://github.com/apache/flink/pull/2002
Added support for XZ as well and update the documentation.
Newer versions of commons compression (1.12) add support for snappy and
lzma. But the version included as a (transitive) dependency
Github user mtanski commented on the issue:
https://github.com/apache/flink/pull/2002
Now that 1.1 one is out, is it possible to get this in?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user mtanski commented on the issue:
https://github.com/apache/flink/pull/2002
@StephanEwen would you like me to use the same version as the one being
current include (transitive) or bump it to a recent version that include Snappy?
---
If your project is set up for it, you
Github user mtanski commented on the issue:
https://github.com/apache/flink/pull/2002
I tried changing the name from to InflaterInputStreamFactory ->
DecompressingStreamFactory
But now it will not build because of:
[ERROR] Failed to execute goal
com.github.sio
Github user mtanski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2002#discussion_r81589240
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/compression/InflaterInputStreamFactory.java
---
@@ -23,13 +23,12 @@
import
GitHub user mtanski opened a pull request:
https://github.com/apache/flink/pull/2002
Support for bz2 compression in flink-core
Add support for bz2 compression to flink. Right now this requires using
Hadoop InputFormats.
Doesn't require any extra dependencies as flink
Github user mtanski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2002#discussion_r63755827
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/compression/Bzip2InputStreamFactory.java
---
@@ -0,0 +1,50 @@
+/*
+ * Licensed to
Github user mtanski commented on the pull request:
https://github.com/apache/flink/pull/2002#issuecomment-220115838
My big question is: should I implement the other compressors from apache
commons-io (snappy, xz). And if so should flink apache commons-io for gzip
deflate as well
10 matches
Mail list logo
