fix additional row processors to ignore blank rows

lib/etl/processor/check_unique_processor.rb

@@ -24,6 +24,7 @@ def compound_key_constraints
       # Process the row. This implementation will only return a row if it
       # it's key combination has not already been seen.
       def process(row)
+        return row unless row
         key = (keys.collect { |k| row[k] }).join('|')
         unless compound_key_constraints[key]
           compound_key_constraints[key] = 1

lib/etl/processor/copy_field_processor.rb

@@ -9,6 +9,7 @@ module Processor #:nodoc:
     class CopyFieldProcessor < ETL::Processor::RowProcessor
       # Process the given row
       def process(row)
+        return row unless row
         destination = (configuration[:destination] || configuration[:dest])
         source_value = row[configuration[:source]]
         case source_value

lib/etl/processor/hierarchy_exploder_processor.rb

@@ -23,6 +23,7 @@ def initialize(control, configuration={})
 
       # Process the row expanding it into hierarchy values
       def process(row)
+        return row unless row
         rows = []
         target = configuration[:target]
         table = configuration[:table]

lib/etl/processor/rename_processor.rb

@@ -7,6 +7,7 @@ module Processor #:nodoc:
     # * <tt>:dest</tt>: The destination field name
     class RenameProcessor < ETL::Processor::RowProcessor
       def process(row)
+        return row unless row
         source_value = row[configuration[:source]]
         case source_value
         when Numeric

lib/etl/processor/require_non_blank_processor.rb

@@ -18,6 +18,7 @@ def initialize(control, configuration)
 
       # Process the row.
       def process(row)
+        return row unless row
         fields.each { |field| return if row[field].blank? }
         row
       end

lib/etl/processor/sequence_processor.rb

@@ -8,6 +8,7 @@ module Processor #:nodoc:
     # * <tt>:dest</tt>: The destination field name
     class SequenceProcessor < ETL::Processor::RowProcessor
       def process(row)
+        return row unless row
         sequences[configuration[:context]] ||= 0
         row[configuration[:dest]] = sequences[configuration[:context]] += 1
         row

lib/etl/processor/surrogate_key_processor.rb

@@ -36,9 +36,7 @@ def initialize(control, configuration)
       # Add a surrogate key to the row
       def process(row)
         if row
-          #puts "processing row #{row.inspect}"
           @surrogate_key += 1
-          #puts "adding surrogate key to row: #{@surrogate_key}"
           row[destination] = @surrogate_key
           row
         end