[BEAM-11091] HadoopFormatIO should allow to specify coders

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Affects Version/s: 2.24.0
• Fix Version/s: 2.26.0
• Component/s: io-java-hadoop-format
• Assignee: Jozef Vilcek
• Reporter: Jozef Vilcek
• Created: 21/Oct/20 19:44
• Updated: 21/Dec/20 07:20
• Resolved: 21/Dec/20 07:20

Description

HadoopFormatIO does allow only to pass in type descriptors for key and value and those are then resolved to Coder via CoderRegistry.

We did find this restrictive after https://issues.apache.org/jira/browse/BEAM-9569
which makes it impossible to emit Row out of the source.

Easy solution I see can be to allow set Coder directly and bypass the resolution against registry in that case.

Issue Links

• links to: GitHub Pull Request #13166