process_records

in lib/aws/kclrb/record_processor.rb [159:163]


        def process_records(process_records_input)
          @processor.process_records(process_records_input.records,
                                     process_records_input.checkpointer)
        end