org.apache.flink.connector.jdbc.internal.converter

Class MySQLRowConverter

java.lang.Object

org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter

org.apache.flink.connector.jdbc.internal.converter.MySQLRowConverter

All Implemented Interfaces:

Serializable, JdbcRowConverter

public class MySQLRowConverter
extends AbstractJdbcRowConverter

Runtime converter that responsible to convert between JDBC object and Flink internal object for MySQL.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter

fieldTypes, rowType, toExternalConverters, toInternalConverters

Constructor Summary

Constructors

Constructor and Description
MySQLRowConverter(RowType rowType)

Method Summary

Modifier and Type	Method and Description
String	converterName()

Methods inherited from class org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter

createExternalConverter, createInternalConverter, createNullableExternalConverter, createNullableInternalConverter, toExternal, toInternal, wrapIntoNullableExternalConverter, wrapIntoNullableInternalConverter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MySQLRowConverter

public MySQLRowConverter(RowType rowType)

Method Detail

converterName

public String converterName()

Specified by:

converterName in class AbstractJdbcRowConverter