Contents

class EmailSuffix

  def do!(connection, forklift)
    forklift.logger.log "collecting email suffixes..."

    suffixes = {}
    connection.read("select email from users"){|data|
      data.each do |row|
        part = row[:email].split('@').last
        suffixes[part] = 0 if suffixes[part].nil?
        suffixes[part] = suffixes[part] + 1
      end
    }

    suffixes.each do |suffix, count|
      forklift.logger.log " > #{suffix}: #{count}" if count > 5
    end
  end

end

Version data entries

26 entries across 26 versions & 1 rubygems

Version	Path
forklift_etl-1.2.2	example/transformations/email_suffix.rb
forklift_etl-1.2.1	example/transformations/email_suffix.rb
forklift_etl-1.2.0	example/transformations/email_suffix.rb
forklift_etl-1.1.12	example/transformations/email_suffix.rb
forklift_etl-1.1.11	example/transformations/email_suffix.rb
forklift_etl-1.1.10	example/transformations/email_suffix.rb
forklift_etl-1.1.9	example/transformations/email_suffix.rb
forklift_etl-1.1.8	example/transformations/email_suffix.rb
forklift_etl-1.1.7	example/transformations/email_suffix.rb
forklift_etl-1.1.6	example/transformations/email_suffix.rb
forklift_etl-1.1.5	example/transformations/email_suffix.rb
forklift_etl-1.1.4	example/transformations/email_suffix.rb
forklift_etl-1.1.3	example/transformations/email_suffix.rb
forklift_etl-1.1.2	example/transformations/email_suffix.rb
forklift_etl-1.1.0	example/transformations/email_suffix.rb
forklift_etl-1.0.19	example/transformations/email_suffix.rb
forklift_etl-1.0.18	example/transformations/email_suffix.rb
forklift_etl-1.0.17	example/transformations/email_suffix.rb
forklift_etl-1.0.16	example/transformations/email_suffix.rb
forklift_etl-1.0.15	example/transformations/email_suffix.rb