<s> """<STR_LIT>""" <EOL> from pycascading . helpers import * <EOL> def main ( ) : <EOL> flow = Flow ( ) <EOL> input = flow . source ( Hfs ( TextLine ( ) , '<STR_LIT>' ) ) <EOL> out_folder = '<STR_LIT>' <EOL> @ udf ( produces = '<STR_LIT>' ) <EOL> def decorated_udf ( tuple ) : <EOL> for word in tuple . get ( '<STR_LIT>' ) . split ( ) : <EOL> yield [ word ] <EOL> def undecorated_udf ( tuple ) : <EOL> for word in tuple . get ( '<STR_LIT>' ) . split ( ) : <EOL> yield [ word ] <EOL> input | map_replace ( decorated_udf ) | flow . tsv_sink ( out_folder + '<STR_LIT>' ) <EOL> input | map_replace ( undecorated_udf ) | flow . tsv_sink ( out_folder + '<STR_LIT>' ) <EOL> input | map_replace ( <NUM_LIT:1> , undecorated_udf ) | flow . tsv_sink ( out_folder + '<STR_LIT>' ) <EOL> input | map_replace ( undecorated_udf , '<STR_LIT>' ) | flow . tsv_sink ( out_folder + '<STR_LIT>' ) <EOL> input | map_add ( decorated_udf ) | flow . tsv_sink ( out_folder + '<STR_LIT>' ) <EOL> input | map_add ( <NUM_LIT:1> , undecorated_udf , '<STR_LIT>' ) | flow . tsv_sink ( out_folder + '<STR_LIT>' ) <EOL> flow . run ( num_reducers = <NUM_LIT:1> ) </s>
