I think something like `combineInputCoders.get(i).or(registry.getOutputCoder(extractInputFns.get(i), dataCoder))` should work.
Also, I believe this logic should be changed, it would be clearer if the coders was not a list of optionals, but a list of coders, and the registry was consulted before this instead of adding `Optional.absent()`. The end goal is not to have optionals but use the values from registry instead when no coder is passed. Similar to how `CombineFnUtil.toFnWithContext(globalCombineFn)` is called. [ Full content available at: https://github.com/apache/beam/pull/6318 ] This message was relayed via gitbox.apache.org for [email protected]
