Class: Clusta::Transforms::NeighborhoodsToDegreePairs::Mapper

Inherits:
Wukong::Streamer::StructStreamer
  • Object
show all
Defined in:
lib/clusta/transforms/neighborhoods_to_degree_pairs.rb

Instance Method Summary collapse

Instance Method Details

#process(neighborhood, *record) ⇒ Object 



16
17
18
 
# File 'lib/clusta/transforms/neighborhoods_to_degree_pairs.rb', line 16

def process neighborhood, *record
  neighborhood.reversed_degree_pairs.each { |degree_pair| emit(degree_pair) }
end