Cacher is the code snippet organizer for pro developers

PCollectionTuple bqTableRowsTuple  =
  rows.apply(
    "HashMap to TableRow",
     ParDo.of(new HashMapToTableRowFn(bqTableRowsSuccessTag, bqTableRowsFailedTag))
      .withOutputTags(bqTableRowsSuccessTag, TupleTagList.of(bqTableRowsFailedTag))
  );