public PDone expand()

in order-book-pipeline/src/main/java/com/google/cloud/dataflow/orderbook/FailedBigQueryInsertProcessor.java [39:49]

• 10 lines of code
• 1 McCabe index (conditional complexity)

  public PDone expand(PCollection<BigQueryStorageApiInsertError> input) {
    input.apply("Report BigQuery Insert Errors", ParDo.of(
        new DoFn<BigQueryStorageApiInsertError, Boolean>() {
          @ProcessElement
          public void process(@Element BigQueryStorageApiInsertError error) {
            // In production pipelines logging errors is not recommended. A proper sink should be used instead.
            LOG.error("Failed to insert into " + table + " : " + error);
          }
        }));
    return PDone.in(input.getPipeline());
  }