Contents

module ETL
  module Control
    class FileSource < Source
      attr_accessor :skip_lines
      def initialize(control, configuration, definition)
        super
        configure
      end
      # Returns each row from the source
      def each
        @parser.each { |row| yield row }
      end
      
      private
      def configure
        @parser = ETL::Parser::Parser.class_for_name(@configuration[:parser]).new(self)
        @skip_lines = @configuration[:skip_lines] ||= 0
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
activewarehouse-etl-0.4.0	lib/etl/control/source/file_source.rb