hdfs_file()

描述:

打开指定的目录,返回Hdfs文件流。

语法:

hdfs_file(hd, file:cs)

备注:

外部库函数,外部库的使用请参考《外部库使用指南》

返回HDFS文件流,由扩展名决定压缩方式,只能流式写出生成不分段文件,读没有限制。

参数:

hd

hd连接。

file

加载 hadoop文件名。

cs

字符集,支持的字符集是jvm自带的字符集。缺省则为虚拟机默认值。

返回值:

文件对象

示例:

 

A

 

1

=hdfs_open("hdfs://192.168.0.8:9000")

连接hdfs文件系统。

2

=hdfs_file(A1,"/user/stu.txt":"GBK")

读取hdfs文件,返回文件对象。

3

=A2.read@n()

将文件对象的内容读成串返回。

4

=A2.import@t()

从文件对象中读出内容作为记录形成序表返回。

5

=A2.cursor().fetch ()

根据文件对象创建游标,再从游标中获取记录内容。

6

=hdfs_close(A1)

关闭连接。