public ParsingOutput expand()

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

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

        public ParsingOutput<TaxiEvent> expand(PCollection<PubsubMessage> rides) {

            PCollection<String> ridesAsStrings =
                    rides.apply("Convert to Json String", ParDo.of(new ExtractPayloadDoFn()));

            Schema taxiEventSchema =
                    SchemaUtils.getSchemaForType(rides.getPipeline(), TaxiEvent.class);

            return ridesAsStrings.apply(
                    "Parse from Json String",
                    FromJsonString.<TaxiEvent>builder()
                            .schema(taxiEventSchema)
                            .clz(TaxiEvent.class)
                            .build());
        }