class ToBeamRecord {

  public static ParDo.SingleOutput<Event, BeamRecord> parDo() {
    return ParDo.of(new DoFn<Event, BeamRecord>() {
      @ProcessElement
      public void processElement(ProcessContext c) {
        BeamRecord beamRecord = INSTANCE.toRecord(c.element());
        c.output(beamRecord);
      }
    });
  }

  private  ToBeamRecord(Map<Class, ModelFieldsAdapter> modelTypeAdapters);

}