Uses of Class
com.hazelcast.jet.pipeline.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. bindFn(BiConsumerEx<PreparedStatement,T> bindFn)
Set the function to bind values to aPreparedStatement
created with the query set withupdateQuery(String)
.JdbcSinkBuilder<T>
JdbcSinkBuilder. dataSourceSupplier(SupplierEx<? extends CommonDataSource> dataSourceSupplier)
Sets the supplier ofDataSource
orXADataSource
.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.