|
cleaned_table = FOREACH original_528bd071475a011915000003_1 GENERATE flatten(com.trifacta.hadoopdata.wrangler.udf.SplitUDF($0, '()(,)()', 4999, false, 2)) AS (column2:chararray, column3:chararray, column4:chararray, column5:chararray, column6:chararray, column7:chararray, column8:chararray, column9:chararray, column10:chararray, column11:chararray, column12:chararray, column13:chararray, column14:chararray, column15:chararray, column16:chararray, column17:chararray, column18:chararray, column19:chararray, column20:chararray, column21:chararray, column22:chararray, column23:chararray, column24:chararray, column25:chararray, column26:chararray, column27:chararray, column28:chararray, column29:chararray, column30:chararray, column31:char |