[
https://issues.apache.org/jira/browse/ORC-1198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjoon Hyun resolved ORC-1198.
--------------------------------
Fix Version/s: 1.8.0
1.7.5
Resolution: Fixed
Issue resolved by pull request 1153
[https://github.com/apache/orc/pull/1153]
> Add stream constructor for PhysicalFsWriter
> -------------------------------------------
>
> Key: ORC-1198
> URL: https://issues.apache.org/jira/browse/ORC-1198
> Project: ORC
> Issue Type: Improvement
> Components: Java
> Reporter: jia liu
> Priority: Minor
> Fix For: 1.8.0, 1.7.5
>
>
> PhysicalFsWriter implementation works on the basis of a Path, but Flink's
> bulk writer based on stream.
> In order to integrate with flink more elegantly, I think a constructor with
> stream parameter should be added to PhysicalFsWriter, as follows:
> {code:java}
> public PhysicalFsWriter(FSDataOutputStream stream, OrcFile.WriterOptions
> opts, WriterEncryptionVariant[] encryption){...}
> {code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
