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 u
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);
What
