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 incremented. Not sure what the implications are of going over the batch size configured in JdbcExecutionOptions (default 5000). However, JdbcBatchingOutputFormat doesn’t seem like it was designed to be overridden, because it uses some internal classes, such as JdbcExec. Is there a way to do what I want to do?
Thank you, Cecile
