Could you share a class declaration of your InboundData class? Is it just a
POJO?
—
Alexey
> On 23 Mar 2023, at 08:16, Juan Cuzmar <jcuz...@protonmail.com> wrote:
>
> Hello all,
>
> I hope this message finds you well. I am currently working with Apache Beam's
> JdbcIO and need some guidance regarding setting a coder for the input data
> without resorting to the deprecated withCoder method. I've been trying to
> resolve this issue and would appreciate any insights or recommendations from
> the community.
>
> Here's a snippet of my code:
>
> .apply("Inserting", JdbcIO.<PubsubMessage, InboundData>readAll()
> .withDataSourceProviderFn(DataSourceProvider.of(dbConfig))
> ...
> .withRowMapper(resultSet -> {
> // Mapping logic here
> }).withOutputParallelization(false)
> ).setCoder(SerializableCoder.of(InboundData.class))
>
> When I run the code, I encounter the following error:
>
>
> java.lang.IllegalStateException: Unable to infer a coder for
> JdbcIO.readAll() transform.
> ...
>
>
> I understand that the withCoder method is marked as deprecated and should be
> avoided. Therefore, I would like to know the recommended way to set the coder
> for JdbcIO, considering the deprecated status of withCoder.
>
> If there are any specific coding practices or conventions that I should
> follow when posting code snippets or emphasizing certain aspects, please let
> me know, and I'll be sure to adhere to them in the future.
>
> Thank you for your time and assistance.
>
> Best regards!
