@PublicEvolving public interface JdbcRowConverter extends Serializable
RowData
.Modifier and Type | Method and Description |
---|---|
FieldNamedPreparedStatement |
toExternal(RowData rowData,
FieldNamedPreparedStatement statement)
Convert data retrieved from Flink internal RowData to JDBC Object.
|
RowData |
toInternal(ResultSet resultSet)
|
RowData toInternal(ResultSet resultSet) throws SQLException
resultSet
- ResultSet from JDBCSQLException
FieldNamedPreparedStatement toExternal(RowData rowData, FieldNamedPreparedStatement statement) throws SQLException
rowData
- The given internal RowData
.statement
- The statement to be filled.SQLException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.