Details
-
New Feature
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
-
None
Description
In JdbcIO.read(), a Coder is required to handle the serialize/deserialize of input record similar as below example. It's better to leverage Coders defined in CoderRegistry.
.withCoder(KvCoder.of(BigEndianIntegerCoder.of(), StringUtf8Coder.of()))
Attachments
Issue Links
- is related to
-
BEAM-960 JdbcIO should infer coder when possible (such as via RowMapper)
-
- Resolved
-