Package | Description |
---|---|
org.apache.flink.connector.jdbc.dialect | |
org.apache.flink.connector.jdbc.internal.converter | |
org.apache.flink.connector.jdbc.table |
Modifier and Type | Method and Description |
---|---|
JdbcRowConverter |
PostgresDialect.getRowConverter(RowType rowType) |
JdbcRowConverter |
JdbcDialect.getRowConverter(RowType rowType)
Get converter that convert jdbc object and Flink internal object each other.
|
JdbcRowConverter |
MySQLDialect.getRowConverter(RowType rowType) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJdbcRowConverter
Base class for all converters that convert between JDBC object and Flink internal object.
|
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 |
PostgresRowConverter
Runtime converter that responsible to convert between JDBC object and Flink internal object for
PostgreSQL.
|
Modifier and Type | Method and Description |
---|---|
JdbcRowDataInputFormat.Builder |
JdbcRowDataInputFormat.Builder.setRowConverter(JdbcRowConverter rowConverter) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.