Прием CDAP из PubSub

Question

Я пытаюсь загрузить данные из сообщений PubSub в файлы GCS. Простой конвейер: исходник PubSub -> JSON Parser -> приемник GCS.

Так как PubSub принимает только аргумент данных как utf-8, как я могу декодировать его в CDAP? Должен ли я создать собственный плагин, реализующий функцию декодирования, или лучше передать мои данные в виде строки, используя атрибуты в сообщении PuSub вместо "данных"?

Answer 1

Я решил проблему, используя плагин Projector вместо JSON Parser между источником PubSub и приемником GCS. Проектор преобразует атрибут байтового сообщения источника PubSub в строку (простой текст).