public PCollectionRowTuple expand()

in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/transform/TaxiEventProcessor.java [174:188]

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

        public PCollectionRowTuple expand(PCollection<String> input) {

            PCollection<String> sanitized =
                    input.apply("Sanitize JSON", ParDo.of(new SanitizeJson(this.schema)));

            JsonToRow.ParseResult parseResult =
                    sanitized.apply(
                            "Parse JSON",
                            JsonToRow.withExceptionReporting(this.schema).withExtendedErrorInfo());

            PCollection<Row> results = parseResult.getResults();
            PCollection<Row> errors = parseResult.getFailedToParseLines();

            return PCollectionRowTuple.of(RESULTS_TAG, results).and(ERRORS_TAG, errors);
        }