Nevermind! I realized I was just misreading the code. I can override the class.
JdbcExec is just a generic, duh 😊
Thank you,
Cecile
From: Cecile Kim
Date: Monday, February 1, 2021 at 2:01 PM
To: user@flink.apache.org
Subject: Custom JdbcSink?
Hi,
I would like to override the JdbcSink, so
Hi,
I would like to override the JdbcSink, so that, given one record, it adds N
insert SQL statements to the batch, where N is equal to a length computed by
the given record. To do this, I need to override
JdbcBatchingOutputFormat.writeRecord(), so that I can adjust how batchCount is
increment
