ParDO with a tag

ParDoWithTAg.java

@ProcessElement
public void processElement(@Element JsonNode> element, OutputReceiver<TableRowWithEvent> out) {
  
  public static final TupleTag<JsonNode> MAIN_OUT = new TupleTag<JsonNode>() {};
  public static final TupleTag<BigQueryProcessError> DEADLETTER_OUT = new TupleTag<BigQueryProcessError>() {};
  
  TableRow convertedRow = new TableRow();

  try {
    
      insertLong(element.get("server_time"), "server_time", convertedRow);
      insertFloat(element.get("screen_dpi"), "screen_dpi", convertedRow);
      
      // more transformation to come
    
      context.output(output);
  
  } catch (Exception e) {
      logger.error("Failed transform "+e.getMessage(),e);
      context.output(DEADLETTER_OUT, new BigQueryProcessError(convertedRow.toString(), e.getMessage(), ERROR_TYPE.BQ_PROCESS, originEvent));
    
  }  

}