Modifier and Type | Class and Description |
---|---|
class |
AbstractJdbcRowConverter
Base class for all converters that convert between JDBC object and Flink internal object.
|
Modifier and Type | Method and Description |
---|---|
JdbcRowConverter |
JdbcDialect.getRowConverter(RowType rowType)
Get converter that convert jdbc object and Flink internal object each other.
|
Modifier and Type | Method and Description |
---|---|
JdbcRowConverter |
MySqlDialect.getRowConverter(RowType rowType) |
Modifier and Type | Method and Description |
---|---|
JdbcRowConverter |
PostgresDialect.getRowConverter(RowType rowType) |
Modifier and Type | Class and Description |
---|---|
class |
DerbyRowConverter
Runtime converter that responsible to convert between JDBC object and Flink internal object for
Derby.
|
class |
MySQLRowConverter
Runtime converter that responsible to convert between JDBC object and Flink internal object for
MySQL.
|
class |
OracleRowConverter
Runtime converter that responsible to convert between JDBC object and Flink internal object for
Oracle.
|
class |
PostgresRowConverter
Runtime converter that responsible to convert between JDBC object and Flink internal object for
PostgreSQL.
|
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.
|
Modifier and Type | Method and Description |
---|---|
JdbcRowDataInputFormat.Builder |
JdbcRowDataInputFormat.Builder.setRowConverter(JdbcRowConverter rowConverter) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.