org.apache.flink.connector.jdbc

Interface JdbcStatementBuilder<T>

Type Parameters:

T - type of payload in StreamRecord

All Superinterfaces:

BiConsumerWithException<PreparedStatement,T,SQLException>, Serializable

@PublicEvolving
public interface JdbcStatementBuilder<T>
extends BiConsumerWithException<PreparedStatement,T,SQLException>, Serializable

Sets PreparedStatement parameters to use in JDBC Sink based on a specific type of StreamRecord.

See Also:

JdbcBatchStatementExecutor

Method Summary

Methods inherited from interface org.apache.flink.util.function.BiConsumerWithException

accept, unchecked