Package | Description |
---|---|
org.apache.flink.connector.jdbc.converter | |
org.apache.flink.connector.jdbc.internal.converter |
Modifier and Type | Field and Description |
---|---|
protected AbstractJdbcRowConverter.JdbcDeserializationConverter[] |
AbstractJdbcRowConverter.toInternalConverters |
Modifier and Type | Method and Description |
---|---|
protected AbstractJdbcRowConverter.JdbcDeserializationConverter |
AbstractJdbcRowConverter.createInternalConverter(LogicalType type) |
protected AbstractJdbcRowConverter.JdbcDeserializationConverter |
AbstractJdbcRowConverter.createNullableInternalConverter(LogicalType type)
Create a nullable runtime
AbstractJdbcRowConverter.JdbcDeserializationConverter from given LogicalType . |
protected AbstractJdbcRowConverter.JdbcDeserializationConverter |
AbstractJdbcRowConverter.wrapIntoNullableInternalConverter(AbstractJdbcRowConverter.JdbcDeserializationConverter jdbcDeserializationConverter) |
Modifier and Type | Method and Description |
---|---|
protected AbstractJdbcRowConverter.JdbcDeserializationConverter |
AbstractJdbcRowConverter.wrapIntoNullableInternalConverter(AbstractJdbcRowConverter.JdbcDeserializationConverter jdbcDeserializationConverter) |
Modifier and Type | Method and Description |
---|---|
AbstractJdbcRowConverter.JdbcDeserializationConverter |
PostgresRowConverter.createInternalConverter(LogicalType type) |
AbstractJdbcRowConverter.JdbcDeserializationConverter |
OracleRowConverter.createInternalConverter(LogicalType type) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.