Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
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.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.