Package | Description |
---|---|
org.apache.flink.connector.jdbc.internal.executor |
Constructor and Description |
---|
TableInsertOrUpdateStatementExecutor(StatementFactory existStmtFactory,
StatementFactory insertStmtFactory,
StatementFactory updateStmtFactory,
JdbcRowConverter existSetter,
JdbcRowConverter insertSetter,
JdbcRowConverter updateSetter,
java.util.function.Function<RowData,RowData> keyExtractor) |
TableSimpleStatementExecutor(StatementFactory stmtFactory,
JdbcRowConverter converter)
Keep in mind object reuse: if it's on then key extractor may be required to return new
object.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.