public void processElement()

in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/load/Spanner.java [82:107]

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

        public void processElement(
                @Element TaxiObjects.TaxiEvent e, OutputReceiver<Mutation> receiver) {
            Mutation m =
                    Mutation.newInsertOrUpdateBuilder(tableName)
                            .set("ride_id")
                            .to(e.getRideId())
                            .set("point_idx")
                            .to(e.getPointIdx())
                            .set("latitude")
                            .to(e.getLatitude())
                            .set("longitude")
                            .to(e.getLongitude())
                            .set("timestamp")
                            .to(com.google.cloud.Timestamp.parseTimestamp(e.getTimeStamp()))
                            .set("meter_reading")
                            .to(e.getMeterReading())
                            .set("meter_increment")
                            .to(e.getMeterIncrement())
                            .set("ride_status")
                            .to(e.getRideStatus())
                            .set("passenger_count")
                            .to(e.getPassengerCount())
                            .build();

            receiver.output(m);
        }