Class: Humboldt::Reducer::TypeConversionEnumerator

Inherits:
Enumerator
  • Object
show all
Defined in:
lib/humboldt/reducer.rb

Instance Method Summary collapse

Constructor Details

#initialize(*args) ⇒ TypeConversionEnumerator

Returns a new instance of TypeConversionEnumerator.



16
17
18
 
# File 'lib/humboldt/reducer.rb', line 16

def initialize(*args)
  @value_converter, @hadoop_iterator = args
end

Instance Method Details

#each ⇒ Object 



20
21
22
23
24
25
 
# File 'lib/humboldt/reducer.rb', line 20

def each
  while @hadoop_iterator.has_next
    @value_converter.hadoop = @hadoop_iterator.next
    yield @value_converter.ruby
  end
end

#next ⇒ Object

Raises:

  • (StopIteration) 


27
28
29
30
31
 
# File 'lib/humboldt/reducer.rb', line 27

def next
  raise StopIteration unless @hadoop_iterator.has_next
  @value_converter.hadoop = @hadoop_iterator.next
  @value_converter.ruby
end