[
https://issues.apache.org/jira/browse/ORC-1198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
William Hyun reassigned ORC-1198:
---------------------------------
Assignee: jia liu
> Add stream constructor for PhysicalFsWriter
> -------------------------------------------
>
> Key: ORC-1198
> URL: https://issues.apache.org/jira/browse/ORC-1198
> Project: ORC
> Issue Type: Improvement
> Components: Java
> Affects Versions: 1.7.4
> Reporter: jia liu
> Assignee: 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)