It's unfortunate we need to catch `IOException` here and rethrow. We could potentially define this as a `Contextual.Fn` directly (whose `apply` method declares `throws Exception`) instead of a `SimpleFunction` or `SerialiableFunction` (whose apply methods do not declare exceptions).
It's not clear to me why we allow `Contextual.Fn` to throw checked exceptions but not the other types. It may be worth considering adding `throws Exception` to SimpleFunction and SerialiableFunction. [ Full content available at: https://github.com/apache/beam/pull/6518 ] This message was relayed via gitbox.apache.org for [email protected]
