[
https://issues.apache.org/jira/browse/FLINK-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14532519#comment-14532519
]
ASF GitHub Bot commented on FLINK-1980:
---------------------------------------
GitHub user sekruse opened a pull request:
https://github.com/apache/flink/pull/658
[FLINK-1980] allowing users to decorate input streams
* add a decorateInputStream() method as hook in FileInputFormat
* provide a InputStreamFSInputWrapper to conveniently wrap InputStreams
* base existing .deflate file support on these changes
* add a test to verify the decoration
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sekruse/flink FLINK-1980
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/658.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #658
----
commit 981b832963230ec64b29100d317175b5e1192288
Author: Sebastian Kruse <[email protected]>
Date: 2015-05-07T11:34:12Z
[FLINK-1980] allowing users to decorate input streams
* add a decorateInputStream() method as hook in FileInputFormat
* provide a InputStreamFSInputWrapper to conveniently wrap InputStreams
* base existing .deflate file support on these changes
* add a test to verify the decoration
----
> Allowing users to decorate input streams
> ----------------------------------------
>
> Key: FLINK-1980
> URL: https://issues.apache.org/jira/browse/FLINK-1980
> Project: Flink
> Issue Type: New Feature
> Components: Core
> Reporter: Sebastian Kruse
> Assignee: Sebastian Kruse
> Priority: Minor
>
> Users may have to do unforeseeable operations on file input streams before
> they can be used by the actual input format logic, e.g., exotic compression
> formats or preambles such as byte order marks. Therefore, it would be useful
> to provide the user with a hook to decorate input streams in order to handle
> such issues.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
