java访问hfs服务_HFS的JAVA API_MapReduce服务 MRS_开发指南(适用于2.x及之前)_HBase应用开发_更多信息_华为云...
发布日期:2021-08-20 01:25:26 浏览次数:3 分类:技术文章

本文共 2006 字,大约阅读时间需要 6 分钟。

接口介绍

主要类说明:

接口org.apache.hadoop.hbase.filestream.client.FSTableInterface常用接口说明:

方法

说明

void put(FSPut fsPut)

向HFS表中插入数据

void put(List fsPuts)

向HFS表中批量插入数据

FSResult get(FSGet fsGet)

从HFS表中读取数据

FSResult[] get(List fsGets)

从HFS表中读取多行数据

void delete(FSDelete fsDelete)

从HFS表中删除数据

void delete(List fsDeletes)

从HFS表中删除多行数据

void close()

关闭表对象

org.apache.hadoop.hbase.filestream.client.FSTable是org.apache.hadoop.hbase.filestream.client.FSTableInterface接口的实现类。

org.apache.hadoop.hbase.filestream.client.FSHColumnDescriptor继承自org.apache.hadoop.hbase.HColumnDescriptor,新增如下接口:

方法

说明

public void setFileColumn()

设置这个列族为存储文件的列族。

public void setFileThreshold(int fileThreshold)

设置存储文件大小的阈值。

org.apache.hadoop.hbase.filestream.client.FSTableDescriptor继承自org.apache.hadoop.hbase.HTableDescriptor,没有新增接口,但是如果要使用JAVA接口创建HFS表来存储文件,必须使用该类。

org.apache.hadoop.hbase.filestream.client.FSPut继承自org.apache.hadoop.hbase.Put,新增如下接口:

方法

说明

public FSPut(byte[] row)

构造函数。通过rowkey来构造对象。

public FSPut(byte[] row, long timestamp)

构造函数。通过rowkey和时间戳来构造对象。

public void addFile(String name, byte[] value)

向HFS表中的存储文件的列族中插入一个文件,以name为列名,value为文件内容。

public void addFile(String name, byte[] value, long ts)

向HFS表中的存储文件的列族中插入一个文件,以name为列名,value为文件内容,ts为指定的时间戳。

public void addFile(String name, InputStream inputStream)

向HFS表中的存储文件的列族中插入一个文件,以name为列名,inputStream为文件的输入流对象。

输入流对象需要调用者自行关闭。

public void addFile(String name, InputStream inputStream, long ts)

向HFS表中的存储文件的列族中插入一个文件,以name为列名,inputStream为文件的输入流对象,ts为指定的时间戳。

输入流对象需要调用者自行关闭。

org.apache.hadoop.hbase.filestream.client.FSGet继承自org.apache.hadoop.hbase.Get,新增如下接口

方法

说明

public FSGet(byte[] row)

构造函数。根据rowkey构造对象。

public void addFile(String fileName)

指定需要返回的文件。

public void addFiles(List fileNames)

指定需要返回的多个文件。

org.apache.hadoop.hbase.filestream.client.FSResult继承自org.apache.hadoop.hbase.Result,新增如下接口:

方法

说明

public FSFile getFile(String fileName)

从查询结果中返回指定文件名的FSFile文件对象。

org.apache.hadoop.hbase.filestream.client.FSFile接口:

方法

说明

public InputStream createInputStream()

从FSFile对象中获取文件的输入流对象。

转载地址:https://blog.csdn.net/weixin_32141627/article/details/114935219 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:java外部类调用匿名内部类_Java匿名内部类访问外部变量,为何需被标志为final?...
下一篇:java9 stream_Java9 Stream API改进

发表评论

最新留言

很好
[***.229.124.182]2024年03月28日 14时23分21秒

关于作者

    喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!

推荐文章

idea测试连接mysql报错08001_IDEA连接MySQL错误 2019-04-21
layui导入模板数据_layui表格-template模板的三种用法 2019-04-21
mysql分组显示行号_mysql 显示行号,以及分组排序 2019-04-21
MySQL常见的主从复制架构_如何搭建经典的MySQL 主从复制架构 2019-04-21
编写python程序、计算账户余额_小明有20w存款存在余额宝中,按余额宝年收益为3.35%计算,用Python编写程序计算,多少年后小明的存款达到30w?... 2019-04-21
python 公众号引流_公众号引流方法有哪些? 2019-04-21
java 减少内存_java中减少内存占用小技巧 2019-04-21
centos 7 mysql图形界面_centos7-vnstat图形界面搭建 2019-04-21
java 防渗透_「java、工程师工作经验怎么写」-看准网 2019-04-21
java中跳出当前循环怎么做_在java中,如何跳出当前的多重循环? 2019-04-21
java程序中执行maven_java – 将一个enviornment变量传递给Maven中的已执行进程 2019-04-21
java16下载_java lombok下载 2019-04-21
python 图像处理与识别书籍_Python图像处理之识别图像中的文字(实例讲解) 2019-04-21
java安全初始化_java安全编码指南之:声明和初始化 2019-04-21
java jstat gc_分析JVM GC及内存情况的方法 2019-04-21
php pclzip.lib.php,php使用pclzip类实现文件压缩的方法(附pclzip类下载地址) 2019-04-21
php dns更新,php_mzdns: 站群,大量域名 通过 dns 服务商 api 批量添加 ip 工具。你懂的~ 基于 mzphp2 框架。... 2019-04-21
jdk 1.8 java.policy,JDK1.8 导致系统报错:java.security.InvalidKeyException:illegal Key Size 2019-04-21
php linux权限,Linux权限详细介绍 2019-04-21
典型环节的matlab仿真分析,典型环节的MATLAB仿真.doc 2019-04-21