Method: Fairy::CFilter#create_and_add_node

Defined in:
lib/fairy/master/c-filter.rb

#create_and_add_node(ntask, mapper, opts = {}) ⇒ Object 



235
236
237
238
239
240
241
242
243
 
# File 'lib/fairy/master/c-filter.rb', line 235

def create_and_add_node(ntask, mapper, opts={})
  node = create_node(ntask) {|node|
	if opts[:init_njob]
	  opts[:init_njob].call(node)
	end
	mapper.bind_input(node)
  }
  node
end