Package | Description |
---|---|
org.apache.flink.connector.jdbc.internal | |
org.apache.flink.connector.jdbc.internal.executor |
Modifier and Type | Class and Description |
---|---|
class |
JdbcBatchingOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>>
A JDBC outputFormat that supports batching records before writing records to database.
|
static interface |
JdbcBatchingOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>>
A factory for creating
JdbcBatchStatementExecutor instance. |
Modifier and Type | Method and Description |
---|---|
JdbcBatchingOutputFormat<Tuple2<Boolean,Row>,Row,JdbcBatchStatementExecutor<Row>> |
JdbcBatchingOutputFormat.Builder.build()
Finalizes the configuration and checks validity.
|
Modifier and Type | Class and Description |
---|---|
class |
BufferReduceStatementExecutor
Currently, this statement executor is only used for table/sql to buffer insert/update/delete
events, and reduce them in buffer before submit to external database.
|
class |
InsertOrUpdateJdbcExecutor<R,K,V>
JdbcBatchStatementExecutor that provides upsert semantics by updating row if it exists
and inserting otherwise. |
Modifier and Type | Method and Description |
---|---|
static <T,K> JdbcBatchStatementExecutor<T> |
JdbcBatchStatementExecutor.keyed(String sql,
java.util.function.Function<T,K> keyExtractor,
JdbcStatementBuilder<K> statementBuilder) |
static <T,V> JdbcBatchStatementExecutor<T> |
JdbcBatchStatementExecutor.simple(String sql,
JdbcStatementBuilder<V> paramSetter,
java.util.function.Function<T,V> valueTransformer) |
Constructor and Description |
---|
BufferReduceStatementExecutor(JdbcBatchStatementExecutor<RowData> upsertExecutor,
JdbcBatchStatementExecutor<RowData> deleteExecutor,
java.util.function.Function<RowData,RowData> keyExtractor,
java.util.function.Function<RowData,RowData> valueTransform) |
BufferReduceStatementExecutor(JdbcBatchStatementExecutor<RowData> upsertExecutor,
JdbcBatchStatementExecutor<RowData> deleteExecutor,
java.util.function.Function<RowData,RowData> keyExtractor,
java.util.function.Function<RowData,RowData> valueTransform) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.