кодер по умолчанию для объекта 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 может иметь набор кодеров, определяющий, как отдельные элементы сериализуются и десериализуются.