Я выполняю задание потоковой передачи, где я получаю данные пользовательского типа.Мне нужно загрузить эти данные в таблицу, уже имеющуюся в базе данных greenplum / postgress, с соответствующими типами.
Для этого я написал собственный ForEachWritter.Я уже создал типы данных в Greenplum и создал таблицу с этим типом.Запрос на вставку, который я запускаю на Greenplum, выглядит следующим образом:
INSERT INTO test.test11(col1, col2, col3, col4) VALUES
(('s','s','s',23,'s','s','s','s','s','s','s','s'), 3, 'ds', array[null]::test.composite1[])
Здесь col1 - составной тип, а col4 - составной тип массива.Этот запрос выполняется на greenplum, но когда я запускаю его через spark, он не может сказать неверный оператор вставки.