У меня есть два вопроса, связанных с проблемами кодера, с которыми я сталкиваюсь в своем конвейере потока данных.

Как мне настроить кодер для моих пользовательских типов данных? Класс состоит всего из трех элементов - двух двойных и другого параметризованного свойства. Я попытался аннотировать тип с помощью SerializableCoder, но я все еще получаю сообщение об ошибке "com.google.cloud.dataflow.sdk.coders.CannotProvideCoderException: не удается предоставить кодер на основе значения с интерфейсом класса java.util.Set: No CoderFactory не был зарегистрирован для класса. " Набор фактически содержит параметризованный пользовательский тип данных - поэтому я предполагаю, что проблема заключается в пользовательском типе данных. Я не мог найти достаточно документации / примеров о том, как сделать это правильно. Пожалуйста, укажите мне правильное место, если оно доступно.Даже без пользовательского типа данных всякий раз, когда я пытаюсь переключиться на параметризованную версию функций Transform, это приводит к ошибкам кодера. В частности, внутри сложного преобразования, которое параметризовано, ParDo работает с параметризованными типами, но когда я применяю Combine.PerKey к результирующей PCollection после ParDo, это приводит к CoderNotFoundException.

Любая помощь по этим двум пунктам будет полезна, так как я как-то застрял на этом некоторое время.