Package | Description |
---|---|
org.apache.flink.connector.jdbc.internal.converter | |
org.apache.flink.connector.jdbc.statement |
Modifier and Type | Method and Description |
---|---|
FieldNamedPreparedStatement |
JdbcRowConverter.toExternal(RowData rowData,
FieldNamedPreparedStatement statement)
Convert data retrieved from Flink internal RowData to JDBC Object.
|
FieldNamedPreparedStatement |
AbstractJdbcRowConverter.toExternal(RowData rowData,
FieldNamedPreparedStatement statement) |
Modifier and Type | Method and Description |
---|---|
FieldNamedPreparedStatement |
JdbcRowConverter.toExternal(RowData rowData,
FieldNamedPreparedStatement statement)
Convert data retrieved from Flink internal RowData to JDBC Object.
|
FieldNamedPreparedStatement |
AbstractJdbcRowConverter.toExternal(RowData rowData,
FieldNamedPreparedStatement statement) |
Modifier and Type | Class and Description |
---|---|
class |
FieldNamedPreparedStatementImpl
Simple implementation of
FieldNamedPreparedStatement . |
Modifier and Type | Method and Description |
---|---|
FieldNamedPreparedStatement |
StatementFactory.createStatement(Connection connection)
Creates
FieldNamedPreparedStatement with the given Connection . |
static FieldNamedPreparedStatement |
FieldNamedPreparedStatementImpl.prepareStatement(Connection connection,
String sql,
String[] fieldNames) |
static FieldNamedPreparedStatement |
FieldNamedPreparedStatement.prepareStatement(Connection connection,
String sql,
String[] fieldNames)
Creates a
NamedPreparedStatement object for sending parameterized SQL statements
to the database. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.