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