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)

关闭连接