You are viewing a plain text version of this content. The canonical link for it is here.

Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/06/04 20:51:06 UTC

[GitHub] [beam] damccorm opened a new issue, #20993: AggregateFn: only accumulator types with default coders are supported.

damccorm opened a new issue, #20993:
URL: https://github.com/apache/beam/issues/20993

   AggregateFn infers the coder for the accumulator from its type [1]. This only works for types with default coders registered [2].
   
   To enable the use custom coders, AggregateFn will need a method to set the accumulator coder. However, the Coder class itself is a part of the Beam core SDK, a dependency we were trying to avoid in org.apache.beam.sdk.extensions.sql.udf.
   
   [1] https://github.com/apache/beam/blob/9418994e11dbede889b508c91261ec2092f2d8a7/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/LazyAggregateCombineFn.java#L88
   
   
   [2] https://github.com/apache/beam/blob/9418994e11dbede889b508c91261ec2092f2d8a7/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java#L106-L143
   
   Imported from Jira [BEAM-12509](https://issues.apache.org/jira/browse/BEAM-12509). Original Jira may contain additional context.
   Reported by: ibzib.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org