Package | Description |
---|---|
org.apache.flink.connector.jdbc.internal | |
org.apache.flink.connector.jdbc.internal.executor | |
org.apache.flink.connector.jdbc.xa |
Provides exactly-once JDBC sink implementation using Java XA transactions API (JTA).
|
Modifier and Type | Class and Description |
---|---|
class |
JdbcOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>>
A JDBC outputFormat that supports batching records before writing records to database.
|
static interface |
JdbcOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>>
A factory for creating
JdbcBatchStatementExecutor instance. |
Modifier and Type | Method and Description |
---|---|
JdbcOutputFormat<Tuple2<Boolean,Row>,Row,JdbcBatchStatementExecutor<Row>> |
JdbcOutputFormat.Builder.build()
Finalizes the configuration and checks validity.
|
Modifier and Type | Class and Description |
---|---|
class |
InsertOrUpdateJdbcExecutor<R,K,V>
Deprecated.
This has been replaced with
TableInsertOrUpdateStatementExecutor |
class |
TableBufferedStatementExecutor
Currently, this statement executor is only used for table/sql to buffer records, because the
Statement.executeBatch() may fail and clear buffered records, so we have to
buffer the records and replay the records when retrying TableBufferedStatementExecutor.executeBatch() . |
class |
TableBufferReducedStatementExecutor
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 |
TableInsertOrUpdateStatementExecutor
JdbcBatchStatementExecutor that provides upsert semantics by updating row if it exists
and inserting otherwise. |
class |
TableSimpleStatementExecutor
A
JdbcBatchStatementExecutor that simply adds the records into batches of PreparedStatement and doesn't buffer records in memory. |
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 |
---|
TableBufferedStatementExecutor(JdbcBatchStatementExecutor<RowData> statementExecutor,
java.util.function.Function<RowData,RowData> valueTransform) |
TableBufferReducedStatementExecutor(JdbcBatchStatementExecutor<RowData> upsertExecutor,
JdbcBatchStatementExecutor<RowData> deleteExecutor,
java.util.function.Function<RowData,RowData> keyExtractor,
java.util.function.Function<RowData,RowData> valueTransform) |
TableBufferReducedStatementExecutor(JdbcBatchStatementExecutor<RowData> upsertExecutor,
JdbcBatchStatementExecutor<RowData> deleteExecutor,
java.util.function.Function<RowData,RowData> keyExtractor,
java.util.function.Function<RowData,RowData> valueTransform) |
Constructor and Description |
---|
JdbcXaSinkFunction(JdbcOutputFormat<T,T,JdbcBatchStatementExecutor<T>> outputFormat,
XaFacade xaFacade,
XidGenerator xidGenerator,
org.apache.flink.connector.jdbc.xa.XaSinkStateHandler stateHandler,
JdbcExactlyOnceOptions options,
org.apache.flink.connector.jdbc.xa.XaGroupOps xaGroupOps)
Creates a
JdbcXaSinkFunction . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.