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

Class OracleRowConverter

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, JdbcRowConverter

public class OracleRowConverter
extends AbstractJdbcRowConverter

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

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter

AbstractJdbcRowConverter.JdbcDeserializationConverter, AbstractJdbcRowConverter.JdbcSerializationConverter

Field Summary

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

fieldTypes, rowType, toExternalConverters, toInternalConverters

Constructor Summary

Constructors

Constructor and Description
OracleRowConverter(RowType rowType)

Method Summary

Modifier and Type	Method and Description
String	converterName()
AbstractJdbcRowConverter.JdbcDeserializationConverter	createInternalConverter(LogicalType type)

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

createExternalConverter, 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

OracleRowConverter

public OracleRowConverter(RowType rowType)

Method Detail

createInternalConverter

public AbstractJdbcRowConverter.JdbcDeserializationConverter createInternalConverter(LogicalType type)

Overrides:

createInternalConverter in class AbstractJdbcRowConverter

converterName

public String converterName()

Specified by:

converterName in class AbstractJdbcRowConverter