public void processElement()

in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/transform/RowToError.java [60:72]

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

        public void processElement(
                @FieldAccess("line") String inputData,
                @FieldAccess("err") String errorMessage,
                @Timestamp Instant timestamp,
                OutputReceiver<Row> out) {

            out.output(
                    Row.withSchema(errorMessageSchema)
                            .withFieldValue("input_data", inputData)
                            .withFieldValue("error_message", errorMessage)
                            .withFieldValue("timestamp", timestamp)
                            .build());
        }