HBase客户端API HBase退出 HBase创建数据 本章介绍用于在HBase表上执行 CRUD 操作的HBase 的Java客户端API 。HBase用Java编写,并具有Java Native API。因此它提供对数据操作语言(DML)的编程访问。 Class HBase配置 将HBase配置文件添加到配置。这个类属于 org.apache.hadoop.hbase 包。 方法和描述 序号 方法和描述 1 static org.apache.hadoop.conf.Configuration create() 此方法使用HBase资源创建配置。 Class HTable HTable是代表HBase表的HBase内部类。它是用于与单个HBase表进行通信的表实现。这个类属于 org.apache.hadoop.hbase.client 类。 构造函数 序号 构造函数和描述 1 HTable() 2 HTable(TableName tableName, ClusterConnection connection, ExecutorService pool) 使用这个构造函数,你可以创建一个对象来访问一个HBase表。 方法和描述 序号 方法和描述 1 void close() 释放HTable的所有资源。 2 void delete(Delete delete) 删除指定的单元格/行。 3 boolean exists(Get get) 使用此方法,您可以按照Get指定的方式测试表中列的存在性。 4 Result get(Get get) 从给定行中检索某些单元格。 5 org.apache.hadoop.conf.Configuration getConfiguration() 返回此实例使用的Configuration对象。 6 TableName getName() 返回此表的表名称实例。 7 HTableDescriptor getTableDescriptor() 返回此表的表描述符。 8 byte[] getTableName() 返回此表的名称。 9 void put(Put put) 使用这种方法,您可以将数据插入表中。 Put类 该类用于对单行执行Put操作。它属于 org.apache.hadoop.hbase.client 包。 构造函数 序号 构造函数和描述 1 Put(byte[] row) 使用此构造函数,您可以为指定的行创建Put操作。 2 Put(byte[] rowArray, int rowOffset, int rowLength) 使用此构造函数,您可以复制传入的行键以保持本地。 3 Put(byte[] rowArray, int rowOffset, int rowLength, long ts) 使用此构造函数,您可以复制传入的行键以保持本地。 4 Put(byte[] row, long ts) 使用这个构造函数,我们可以使用给定的时间戳为指定的行创建一个Put操作。 方法 序号 方法和描述 1 Put add(byte[] family, byte[] qualifier, byte[] value) 将指定的列和值添加到此Put操作中。 2 Put add(byte[] family, byte[] qualifier, long ts, byte[] value) 添加指定的列和值,并将指定的时间戳作为其版本的Put操作。 3 Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) 添加指定的列和值,并将指定的时间戳作为其版本的Put操作。 4 Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) 添加指定的列和值,并将指定的时间戳作为其版本的Put操作。 Get类 该类用于在单个行上执行Get操作。该类属于 org.apache.hadoop.hbase.client 包。 构造函数 序号 构造函数和说明 1 Get(byte[] row) 使用这个构造函数,你可以为指定的行创建一个Get操作。 2 Get(Get get) 方法 序号 方法和描述 1 Get addColumn(byte[] family, byte[] qualifier) 使用指定的限定符从特定族中检索列。 2 Get addFamily(byte[] family) 检索指定系列的所有列。 删除类 该类用于在单个行上执行删除操作。要删除整行,请使用要删除的行实例化Delete对象。该类属于 org.apache.hadoop.hbase.client 包。 构造函数 序号 构造函数和说明 1 Delete(byte[] row) 为指定的行创建一个删除操作。 2 Delete(byte[] rowArray, int rowOffset, int rowLength) 为指定的行和时间戳创建一个删除操作。 3 Delete(byte[] rowArray, int rowOffset, int rowLength, long ts) 为指定的行和时间戳创建一个删除操作。 4 Delete(byte[] row, long timestamp) 为指定的行和时间戳创建一个删除操作。 方法 序号 方法和描述 1 Delete addColumn(byte[] family, byte[] qualifier) 删除指定列的最新版本。 2 Delete addColumns(byte[] family, byte[] qualifier, long timestamp) 删除时间戳小于或等于指定时间戳的指定列的所有版本。 3 Delete addFamily(byte[] family) 删除指定系列的所有列的所有版本。 4 Delete addFamily(byte[] family, long timestamp) 使用小于或等于指定时间戳的时间戳删除指定系列的所有列。 结果类 该类用于获取Get或Scan查询的单行结果。 构造函数 序号 构造函数 1 Result() 使用这个构造函数,你可以创建一个没有KeyValue负载的空Result; 如果调用原始的Cells(),则返回null。 方法 序号 方法和描述 1 byte[] getValue(byte[] family, byte[] qualifier) 此方法用于获取指定列的最新版本。 2 byte[] getRow() 此方法用于检索与创建此结果的行对应的行键。 HBase退出 HBase创建数据