jia liu created ORC-1198: ---------------------------- Summary: 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
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)