Class: QueueryClient::DataFileBundle

Inherits:
Object
  • Object
show all
Defined in:
lib/queuery_client/data_file_bundle.rb

Direct Known Subclasses

S3DataFileBundle, UrlDataFileBundle

Instance Method Summary collapse

Instance Method Details

#each_row(&block) ⇒ Object Also known as: each

abstract data_files
DataFile
abstract manifest_file

ManifestFile

abstract def has_manifest?



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/queuery_client/data_file_bundle.rb', line 11

def each_row(&block)
  return enum_for(:each_row) if !block_given?

  data_files.each do |file|
    if file.data_object?
      file.each_row do |row|
        if has_manifest?
          yield RedshiftDataType.type_cast(row, manifest_file)
        else
          yield row
        end
      end
    end
  end

  self
end