1 2 3 4 | > cat filecsv.csv Tom,man,23,student Alice,female,35,teacher Ben, male,33,police |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | jaql> read(del(location='file:///xvdc/gaoyunhe/develop/filecsv.csv')); [ [ "Tom", "man", "23", "student" ], [ "Alice", "female", "35", "teacher" ], [ "Ben", "male", "33", "police" ] ] |
1 2 3 4 5 | > cat filecsv.csv Tom,man,23,student Alice,female,35,teacher Ben,male,33,polic Bob,18,student |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | jaql> read(del(location='file:///xvdc/gaoyunhe/develop/filecsv.csv', schema=schema{name: string, sex: string, age: long, occupation:string})); encountered an exception during the evaluation of a statement java.lang.reflect.UndeclaredThrowableException originating expression ends at <stdin> (line: 2, column: 136) java.lang.RuntimeException: Wrong number of fields on input at position 43 [ { "name": "Tom", "sex": "man", "age": 23, "occupation": "student" }, { "name": "Alice", "sex": "female", "age": 35, "occupation": "teacher" } |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 | jaql> read(lines('file:///xvdc/gaoyunhe/develop/filecsv.csv')) -> transform catch (delToJson($), { errThresh: 3}, $ ) -> filter count($) == 4 -> transform { name: $[0], sex: $[1], age: $[2], occupation: $[3] }; [ { "name": "Tom", "sex": "man", "age": "23", "occupation": "student" }, { "name": "Alice", "sex": "female", "age": "35", "occupation": "teacher" }, { "name": "Ben", "sex": "male", "age": "33", "occupation": "police" } ] |
欢迎光临 电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/) | Powered by Discuz! 7.0.0 |