public class PostgresRowConverter extends AbstractJdbcRowConverter
fieldTypes, rowType, toExternalConverters, toInternalConverters
Constructor and Description |
---|
PostgresRowConverter(RowType rowType) |
Modifier and Type | Method and Description |
---|---|
String |
converterName() |
org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter |
createInternalConverter(LogicalType type) |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter |
createNullableExternalConverter(LogicalType type)
Create a nullable JDBC f
JdbcSerializationConverter from given sql type. |
createExternalConverter, createNullableInternalConverter, toExternal, toInternal, wrapIntoNullableExternalConverter, wrapIntoNullableInternalConverter
public PostgresRowConverter(RowType rowType)
public String converterName()
converterName
in class AbstractJdbcRowConverter
public org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter createInternalConverter(LogicalType type)
createInternalConverter
in class AbstractJdbcRowConverter
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter createNullableExternalConverter(LogicalType type)
AbstractJdbcRowConverter
JdbcSerializationConverter
from given sql type.createNullableExternalConverter
in class AbstractJdbcRowConverter
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.