кодер по умолчанию для объекта pojo в Apache Beam

Если ваш POJO определен в вашем проекте, взгляните на DefaultSchema. Этот пример делает именно то, что вы хотите, регистрируя схему (которая неявно регистрирует кодировщик) путем проверки методов, совместимых с JavaBean:

@DefaultSchema(JavaBeanSchema.class)
class MyClass {
  public String getFoo();
  void setFoo(String foo);
        ....
}

Обратите внимание, что кодировщики предназначены для элементов коллекции, поэтому кодировщика для PCollection нет. Скорее, PCollection может иметь набор кодировщиков, определяющий, как отдельные элементы сериализуются и десериализуются.

Спасибо за эту информацию, у меня есть сценарий. Предположим, у меня есть PCollection ‹bean› (здесь bean-компонент — это класс pojo). когда я пытался реализовать преобразование ParDo в этой коллекции PCollection, я получаю ошибку кодировщика (ошибка — Невозможно получить кодировщик, используйте метод setcoder). Согласно документации Apache Beam, существуют специальные кодеры для int, void, strng, avro. Поэтому мне интересно, какой кодер мне нужно реализовать в этом сценарии. — person code tutorial; 23.02.2019

Если у вас есть контроль над определением bean и вы аннотируете @DefaultSchema(JavaBeanSchema.class), а bean не имеет параметров типа, то Beam должен иметь достаточно информации, чтобы сделать вывод о кодировщике; ошибка кодера, о которой вы упомянули, должна исчезнуть. В противном случае вы можете преобразовать ваш объект в более простой тип, чтобы получить что-то вроде PCollection ‹Map‹ String, String ››, или реализовать явный подкласс Coder для вашего типа и передать экземпляр этого класса кодера в setCoder. — person code tutorial; 25.02.2019