public PCollectionTuple expand()

in pipelines/clickstream_analytics_java/src/main/java/com/google/cloud/dataflow/solutions/clickstream_analytics/JsonToTableRows.java [50:54]

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

        public PCollectionTuple expand(PCollection<String> jsonStrings) {
            return jsonStrings.apply(
                    ParDo.of(new ToJsonDoFn())
                            .withOutputTags(SUCCESS_TAG, TupleTagList.of(FAILURE_TAG)));
        }