Uses of Class
com.hazelcast.jet.pipeline.JdbcSinkBuilder

Packages that use JdbcSinkBuilder

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of JdbcSinkBuilder in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return JdbcSinkBuilder

Modifier and Type	Method	Description
JdbcSinkBuilder<T>	JdbcSinkBuilder.batchLimit(int batchLimit)	Sets the batch size limit for the sink.
JdbcSinkBuilder<T>	JdbcSinkBuilder.bindFn(BiConsumerEx<PreparedStatement,T> bindFn)	Set the function to bind values to a PreparedStatement created with the query set with updateQuery(String).
JdbcSinkBuilder<T>	JdbcSinkBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef)	Sets the reference to the configured data connection of DataConnectionRef from which the instance of the DataSource will be retrieved.
JdbcSinkBuilder<T>	JdbcSinkBuilder.dataSourceSupplier(SupplierEx<? extends CommonDataSource> dataSourceSupplier)	Sets the supplier of DataSource or XADataSource.
JdbcSinkBuilder<T>	JdbcSinkBuilder.exactlyOnce(boolean enabled)	Sets whether the exactly-once mode is enabled for the sink.
static <T> JdbcSinkBuilder<T>	Sinks.jdbcBuilder()	Returns a builder to build a sink that connects to a JDBC database, prepares an SQL statement and executes it for each item.
JdbcSinkBuilder<T>	JdbcSinkBuilder.jdbcUrl(String connectionUrl)	Sets the connection URL for the target database.
JdbcSinkBuilder<T>	JdbcSinkBuilder.updateQuery(String updateQuery)	The query to execute for each item.