You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@orc.apache.org by "William Hyun (Jira)" <ji...@apache.org> on 2022/06/12 21:43:00 UTC
[jira] [Assigned] (ORC-1198) Add stream constructor for PhysicalFsWriter
[ 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)