Class: Clusta::Transforms::EdgesToNeighborhoods::Mapper

Inherits:

Wukong::Streamer::StructStreamer

• Object
• Wukong::Streamer::StructStreamer
• Clusta::Transforms::EdgesToNeighborhoods::Mapper

Defined in:

lib/clusta/transforms/edges_to_neighborhoods.rb

Instance Method Summary

• #process(edge, *record) ⇒ Object

Instance Method Details

#process(edge, *record) ⇒ Object

# File 'lib/clusta/transforms/edges_to_neighborhoods.rb', line 14

def process edge, *record
  emit edge
  emit edge.reversed unless edge.directed?
end