[ https://issues.apache.org/jira/browse/BEAM-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kyoungha Min updated BEAM-9332: ------------------------------- Description: It would be nice to see Beam using custom ByteArrayInput/OutputStream without synchronization. It currently uses `ThreadLocal`, so using thread-safe stream seems unnecessary. And all streams should never be access by more than 1 thread from the start anyway. Simply getting rid of the synchronized keyword will speed up about ~500 times for single byte access. Something like org.apache.beam.sdk.util.VarInt will get significant benefit from it. was:It would be nice to see Beam using custom ByteArrayInput/OutputStream without synchronization. It currently uses `ThreadLocal`, so using thread-safe stream seems unnecessary. And all streams should never be access by more than 1 thread from the start anyway. > To use ByteArrayOutput/InputStream without synchronization > ---------------------------------------------------------- > > Key: BEAM-9332 > URL: https://issues.apache.org/jira/browse/BEAM-9332 > Project: Beam > Issue Type: Wish > Components: sdk-java-core > Reporter: Kyoungha Min > Priority: Minor > > It would be nice to see Beam using custom ByteArrayInput/OutputStream without > synchronization. It currently uses `ThreadLocal`, so using thread-safe stream > seems unnecessary. And all streams should never be access by more than 1 > thread from the start anyway. > Simply getting rid of the synchronized keyword will speed up about ~500 times > for single byte access. Something like org.apache.beam.sdk.util.VarInt will > get significant benefit from it. -- This message was sent by Atlassian Jira (v8.3.4#803005)