iterators库的ireadLines()返回的迭代器不能工作于unz()返回的Connection上？

是 否 +2 论坛币

k人 参与回答

经管之家送您一份

应届毕业生专属福利!

求职就业群

赵安豆老师微信：zhaoandou666

经管之家联合CDA

送您一个全额奖学金名额~ !

立即领取

感谢您参与论坛问题回答

经管之家送您两个论坛币！

+2 论坛币

执行如下代码，原本的意愿是从压缩文件中读取大个头的文本文件，考虑到RAM一次只读取一条，保留感兴趣的内容以便后继计算，但是执行nextElem()后只能返回第一行，和直接从文本文件返回的ireadLines是有区别的，这是为什么呢？或者有没有其它方法或库作为顶替的解决方案？

1. > library(iterators)
   
2. > con<-unz(description='daily_VOCS_1994.zip',filename='daily_VOCS_1994.csv')
   
3. > it<-ireadLines(con)
   
4. > nextElem(it)
   
5. [1] "\"State Code\",\"County Code\",\"Site Num\",\"Parameter Code\",\"POC\",\"Latitude\",\"Longitude\",\"Datum\",\"Parameter Name\",\"Sample Duration\",\"Pollutant Standard\",\"Date Local\",\"Units of Measure\",\"Event Type\",\"Observation Count\",\"Observation Percent\",\"Arithmetic Mean\",\"1st Max Value\",\"1st Max Hour\",\"AQI\",\"Method Name\",\"Local Site Name\",\"Address\",\"State Name\",\"County Name\",\"City Name\",\"CBSA Name\",\"Date of Last Change\""
   
6. > nextElem(it)
   
7. [1] "\"State Code\",\"County Code\",\"Site Num\",\"Parameter Code\",\"POC\",\"Latitude\",\"Longitude\",\"Datum\",\"Parameter Name\",\"Sample Duration\",\"Pollutant Standard\",\"Date Local\",\"Units of Measure\",\"Event Type\",\"Observation Count\",\"Observation Percent\",\"Arithmetic Mean\",\"1st Max Value\",\"1st Max Hour\",\"AQI\",\"Method Name\",\"Local Site Name\",\"Address\",\"State Name\",\"County Name\",\"City Name\",\"CBSA Name\",\"Date of Last Change\""
   
8. >

复制代码

扫码加我 拉你入群

请注明：姓名-公司-职位

以便审核进群资格，未注明则拒绝

分享0 收藏0 回帖

关键词：connection Connect Lines ITER READ 解决方案 文本文件 library 压缩文件

没空去挖源代码，不能沉了，顶上去~

1. Rconnection attribute_hidden
   
2. R_newunz(const char *description, const char *const mode)
   
3. {
   
4.     Rconnection new;
   
5.     new = (Rconnection) malloc(sizeof(struct Rconn));
   
6.     if(!new) error(_("allocation of 'unz' connection failed"));
   
7.     new->class = (char *) malloc(strlen("unz") + 1);
   
8.     if(!new->class) {
   
9.         free(new);
   
10.         error(_("allocation of 'unz' connection failed"));
    
11.     }
    
12.     strcpy(new->class, "unz");
    
13.     new->description = (char *) malloc(strlen(description) + 1);
    
14.     if(!new->description) {
    
15.         free(new->class); free(new);
    
16.         error(_("allocation of 'unz' connection failed"));
    
17.     }
    
18.     init_con(new, description, CE_NATIVE, mode);
    
19. 
    
20.     new->canseek = TRUE;
    
21.     new->open = &unz_open;
    
22.     new->close = &unz_close;
    
23.     new->vfprintf = &null_vfprintf;
    
24.     new->fgetc_internal = &unz_fgetc_internal;
    
25.     new->fgetc = &dummy_fgetc;
    
26.     new->seek = &null_seek; //好暴力，不支持seek，readLines没法工作，之上的ireadLines也就没法工作了
    
27.     new->fflush = &null_fflush;
    
28.     new->read = &unz_read;
    
29.     new->write = &null_write;
    
30.     new->private = (void *) malloc(sizeof(struct unzconn));
    
31.     if(!new->private) {
    
32.         free(new->description); free(new->class); free(new);
    
33.         error(_("allocation of 'unz' connection failed"));
    
34.     }
    
35.     return new;
    
36. }

复制代码

不知道有没什么替代方案，csv文件的压缩率非常的大，几十MB的包解出来得好几GB~