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 and 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.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.