sandboxws
1/19/2019 - 7:03 PM

with_output_tags.java

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