Hi Fanbin,
One approach would be to ingest the field as a VARCHAR / String and
implement a Scalar UDF to convert it into a nested tuple.
The UDF could use the code of the flink-json module.
AFAIK, there is some work on the way to add built-in JSON functions.
Best, Fabian
Am Do., 24. Okt. 2019
Looks like SnowflakeColumnMetadata treats VARIANT as VARCHAR
case VARIANT:
colType = Types.VARCHAR;
extColTypeName = "VARIANT";
break;
and SnowflakeResultSet just return the string of the field
switch(type)
{
case Types.VARCHAR:
case Types.CHAR:
return getString(columnIndex);
Hi there,
Flink Version: 1.8.1
JDBC driver: net.snowflake.client.jdbc.SnowflakeDriver
Here is the code snippet:
val rowTypeInfo = new RowTypeInfo(
Array[TypeInformation[_]](
new RowTypeInfo(
Array[TypeInformation[_]](BasicTypeInfo.STRING_TYPE_INFO,
