@jay, In that example, just one column idx with one row. Ideally I would like patch the daft to remove new lines if you can point me where in the code. I guess it would break JSONL but it would be fast for me :)
I did get a workaround
df1 = daft.from_glob_path("<s3://p/d-**.json.gz>")
df1 = df1.with_column("data", df1["path"].url.download(max_connections=8))
df1 = df1.with_column("output", df1["data"].apply(lambda data: process_file(data), return_dtype=daft.DataType.python()))
and in process file I read file, ungzip and parse json and convert to pandas and then collect to daft. I still have to measure speed of this.
We did found that pyarrow read_json has a parsing option newlines_in_values but it is not working as desired yet.
Thank you for your help!