[ 
https://issues.apache.org/jira/browse/BEAM-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Kyoungha Min updated BEAM-9325:
-------------------------------
    Description: 
I wish the following methods get overriden for performance reason. Im using 
custom version as it is too slow, but it would be nice to use already existing 
solution. 

org.apache.beam.sdk.util.UnownedInput/OutputStream currently do not override 
`read(byte[], int, int)` and `write(byte[], int, int)` and as a result, it is 
reading and writing 1 byte at a time. 

 

  was:
I wish the following methods get overriden for performance reason. Im using 
custom version as it is too slow, but it would be nice to use already existing 
solution. 

org.apache.beam.sdk.util.UnownedInput/OutputStream currently do not override 
`read(byte[], int, int)` and `write(byte[], int, int)` and as a result, it is 
reading and writing 1 byte at a time. 

The throughput is too low (it is slower than writing to my HDD), and I believe 
it was not intended.

 


> UnownedInput/OutputStream not overriding array method.
> ------------------------------------------------------
>
>                 Key: BEAM-9325
>                 URL: https://issues.apache.org/jira/browse/BEAM-9325
>             Project: Beam
>          Issue Type: Wish
>          Components: sdk-java-core
>            Reporter: Kyoungha Min
>            Priority: Minor
>   Original Estimate: 1m
>  Remaining Estimate: 1m
>
> I wish the following methods get overriden for performance reason. Im using 
> custom version as it is too slow, but it would be nice to use already 
> existing solution. 
> org.apache.beam.sdk.util.UnownedInput/OutputStream currently do not override 
> `read(byte[], int, int)` and `write(byte[], int, int)` and as a result, it is 
> reading and writing 1 byte at a time. 
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to