Class: Clusta::Transforms::EdgesToDegrees::Mapper

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

Instance Method Summary collapse

Instance Method Details

#process(edge, *record) ⇒ Object



14
15
16
# File 'lib/clusta/transforms/edges_to_degrees.rb', line 14

def process edge, *record
  edge.degrees.each { |degree| emit(degree) }
end