Sample Wukong flow

translator.rb

Wukong.processor(:ogify) do

  def process(record)
    emit(record.gsub(/(a\w|e\w|i\w|o\w|u\w)/, 'og'))
  end

end

Wukong.processor(:poify) do

  def process(record)
    emit(record.gsub(/(q|x|z|k|j)/, 'po'))
  end

end

Wukong.processor(:femify) do

  def process(record)
    emit(record.gsub(/(pg|gp|gg|gb|bg|pb|bp|gc|cg)/, 'fem'))
  end

end

Wukong.dataflow(:translator) do

  input(:default, stdin)
  output(:dump, stdout)

  input(:default) > ogify > poify > femify > output(:dump)
end