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

Class BufferReduceStatementExecutor

java.lang.Object

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

All Implemented Interfaces:

JdbcBatchStatementExecutor<RowData>

public class BufferReduceStatementExecutor
extends Object
implements JdbcBatchStatementExecutor<RowData>

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.

Constructor Summary

Constructors

Constructor and Description
BufferReduceStatementExecutor(JdbcBatchStatementExecutor<RowData> upsertExecutor, JdbcBatchStatementExecutor<RowData> deleteExecutor, java.util.function.Function<RowData,RowData> keyExtractor, java.util.function.Function<RowData,RowData> valueTransform)

Method Summary

Modifier and Type	Method and Description
void	addToBatch(RowData record)
void	closeStatements() Close JDBC related statements.
void	executeBatch() Submits a batch of commands to the database for execution.
void	prepareStatements(Connection connection) Create statements from connection.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.connector.jdbc.internal.executor.JdbcBatchStatementExecutor

keyed, simple

Constructor Detail

BufferReduceStatementExecutor

public BufferReduceStatementExecutor(JdbcBatchStatementExecutor<RowData> upsertExecutor,
                                     JdbcBatchStatementExecutor<RowData> deleteExecutor,
                                     java.util.function.Function<RowData,RowData> keyExtractor,
                                     java.util.function.Function<RowData,RowData> valueTransform)

Method Detail

prepareStatements

public void prepareStatements(Connection connection)
                       throws SQLException

Description copied from interface: JdbcBatchStatementExecutor

Create statements from connection.

Specified by:

prepareStatements in interface JdbcBatchStatementExecutor<RowData>

Throws:

SQLException

addToBatch

public void addToBatch(RowData record)
                throws SQLException

Specified by:

addToBatch in interface JdbcBatchStatementExecutor<RowData>

Throws:

SQLException

executeBatch

public void executeBatch()
                  throws SQLException

Description copied from interface: JdbcBatchStatementExecutor

Submits a batch of commands to the database for execution.

Specified by:

executeBatch in interface JdbcBatchStatementExecutor<RowData>

Throws:

SQLException

closeStatements

public void closeStatements()
                     throws SQLException

Description copied from interface: JdbcBatchStatementExecutor

Close JDBC related statements.

Specified by:

closeStatements in interface JdbcBatchStatementExecutor<RowData>

Throws:

SQLException