Package org.apache.flink.connector.jdbc.internal.executor

Interface Summary

Interface	Description
JdbcBatchStatementExecutor<T>	Executes the given JDBC statement in batch for the accumulated records.

Class Summary

Class	Description
BufferReduceStatementExecutor	Currently, this statement executor is only used for table/sql to buffer insert/update/delete events, and reduce them in buffer before submit to external database.
InsertOrUpdateJdbcExecutor<R,K,V>	JdbcBatchStatementExecutor that provides upsert semantics by updating row if it exists and inserting otherwise.