JdbcIO.write获得失败的结果

问题描述

我正在使用Apache Beam将我的Kafka事件写入数据库。我正在使用下面的代码编写事件。当数据格式正确时，会将数据写入数据库。但是，如果数据中缺少任何必需的列，则管道将失败。

我可以将错误作为单独的集合吗？然后，我可以分别处理这些错误。

 PCollection<Row> transformToRow = // kafkaRead events and then transformed to Row

 PDone expand = JdbcIO.<Row>write()
    .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create("driverClass","connectionString")
        .withUsername("username")
        .withPassword("password"))
    .withTable("table_name")
    .expand(transformToRow);

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）