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

Question

Согласно документации Apache Beam, я могу найти кодеры для конкретных типов данных, а также пользовательские кодеры. Это обеспечивает возможность создания пользовательских кодеров путем регистрации в реестре кода. Но я хотел бы знать, есть ли какой-либо кодер, доступный для POJO/bean. Например, что такое кодер для PCollection

Answer 1

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

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

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