当前位置：文档之家 › scanner

scanner

  • 格式：docx
  • 大小：14.35 KB
  • 文档页数：9

import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor;import org.apache.hadoop.hbase.HTableDescriptor;import org.apache.hadoop.hbase.KeyValue;import org.apache.hadoop.hbase.client.Delete;import org.apache.hadoop.hbase.client.Get;import org.apache.hadoop.hbase.client.HBaseAdmin;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.client.HTablePool;import org.apache.hadoop.hbase.client.Put;import org.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.ResultScanner;import org.apache.hadoop.hbase.client.Scan;import org.apache.hadoop.hbase.util.Bytes;public class Hbase {// 声明静态配置static Configuration conf = null;static {conf = HBaseConfiguration.create();conf.set("hbase.zookeeper.quorum", "localhost");}/** 创建表** @tableName 表名** @family 列族列表*/public static void creatTable(String tableName, String[] family)throws Exception {HBaseAdmin admin = new HBaseAdmin(conf);HTableDescriptor desc = new HTableDescriptor(tableName);for (int i = 0; i < family.length; i++) {desc.addFamily(new HColumnDescriptor(family[i]));}if (admin.tableExists(tableName)) {System.out.println("table Exists!");System.exit(0);} else {admin.createTable(desc);System.out.println("create table Success!");}}/** 为表添加数据（适合知道有多少列族的固定表）** @rowKey rowKey** @tableName 表名** @column1 第一个列族列表** @value1 第一个列的值的列表** @column2 第二个列族列表** @value2 第二个列的值的列表*/public static void addData(String rowKey, String tableName,String[] column1, String[] value1, String[] column2, String[] value2)throws IOException {Put put = new Put(Bytes.toBytes(rowKey));// 设置rowkeyHTable table = new HTable(conf, Bytes.toBytes(tableName));// HTabel负责跟记录相关的操作如增删改查等//// 获取表HColumnDescriptor[] columnFamilies = table.getTableDescriptor() // 获取所有的列族.getColumnFamilies();for (int i = 0; i < columnFamilies.length; i++) {String familyName = columnFamilies[i].getNameAsString(); // 获取列族名if (familyName.equals("article")) { // article列族put数据for (int j = 0; j < column1.length; j++) {put.add(Bytes.toBytes(familyName),Bytes.toBytes(column1[j]), Bytes.toBytes(value1[j]));}}if (familyName.equals("author")) { // author列族put数据for (int j = 0; j < column2.length; j++) {put.add(Bytes.toBytes(familyName),Bytes.toBytes(column2[j]), Bytes.toBytes(value2[j]));}}}table.put(put);System.out.println("add data Success!");}/** 根据rwokey查询** @rowKey rowKey** @tableName 表名*/public static Result getResult(String tableName, String rowKey)throws IOException {Get get = new Get(Bytes.toBytes(rowKey));HTable table = new HTable(conf, Bytes.toBytes(tableName));// 获取表Result result = table.get(get);for (KeyValue kv : result.list()) {System.out.println("family:" + Bytes.toString(kv.getFamily()));System.out.println("qualifier:" + Bytes.toString(kv.getQualifier()));System.out.println("value:" + Bytes.toString(kv.getValue()));System.out.println("Timestamp:" + kv.getTimestamp());System.out.println("-------------------------------------------");}return result;}/** 遍历查询hbase表** @tableName 表名*/public static void getResultScann(String tableName) throws IOException { Scan scan = new Scan();ResultScanner rs = null;HTable table = new HTable(conf, Bytes.toBytes(tableName));try {rs = table.getScanner(scan);for (Result r : rs) {for (KeyValue kv : r.list()) {System.out.println("row:" + Bytes.toString(kv.getRow()));System.out.println("family:"+ Bytes.toString(kv.getFamily()));System.out.println("qualifier:"+ Bytes.toString(kv.getQualifier()));System.out.println("value:" + Bytes.toString(kv.getValue()));System.out.println("timestamp:" + kv.getTimestamp());System.out.println("-------------------------------------------");}}} finally {rs.close();}}/** 遍历查询hbase表** @tableName 表名*/public static void getResultScann(String tableName, String start_rowkey, String stop_rowkey) throws IOException {Scan scan = new Scan();scan.setStartRow(Bytes.toBytes(start_rowkey));scan.setStopRow(Bytes.toBytes(stop_rowkey));ResultScanner rs = null;HTable table = new HTable(conf, Bytes.toBytes(tableName));try {rs = table.getScanner(scan);for (Result r : rs) {for (KeyValue kv : r.list()) {System.out.println("row:" + Bytes.toString(kv.getRow()));System.out.println("family:"+ Bytes.toString(kv.getFamily()));System.out.println("qualifier:"+ Bytes.toString(kv.getQualifier()));System.out.println("value:" + Bytes.toString(kv.getValue()));System.out.println("timestamp:" + kv.getTimestamp());System.out.println("-------------------------------------------");}}} finally {rs.close();}}/** 查询表中的某一列** @tableName 表名** @rowKey rowKey*/public static void getResultByColumn(String tableName, String rowKey,String familyName, String columnName) throws IOException {HTable table = new HTable(conf, Bytes.toBytes(tableName));Get get = new Get(Bytes.toBytes(rowKey));get.addColumn(Bytes.toBytes(familyName), Bytes.toBytes(columnName)); // 获取指定列族和列修饰符对应的列Result result = table.get(get);for (KeyValue kv : result.list()) {System.out.println("family:" + Bytes.toString(kv.getFamily()));System.out.println("qualifier:" + Bytes.toString(kv.getQualifier()));System.out.println("value:" + Bytes.toString(kv.getValue()));System.out.println("Timestamp:" + kv.getTimestamp());System.out.println("-------------------------------------------");}}/** 更新表中的某一列** @tableName 表名** @rowKey rowKey** @familyName 列族名** @columnName 列名** @value 更新后的值*/public static void updateTable(String tableName, String rowKey,String familyName, String columnName, String value)throws IOException {HTable table = new HTable(conf, Bytes.toBytes(tableName));Put put = new Put(Bytes.toBytes(rowKey));put.add(Bytes.toBytes(familyName), Bytes.toBytes(columnName),Bytes.toBytes(value));table.put(put);System.out.println("update table Success!");}/** 查询某列数据的多个版本** @tableName 表名** @rowKey rowKey** @familyName 列族名** @columnName 列名*/public static void getResultByVersion(String tableName, String rowKey, String familyName, String columnName) throws IOException { HTable table = new HTable(conf, Bytes.toBytes(tableName));Get get = new Get(Bytes.toBytes(rowKey));get.addColumn(Bytes.toBytes(familyName), Bytes.toBytes(columnName));get.setMaxVersions(5);Result result = table.get(get);for (KeyValue kv : result.list()) {System.out.println("family:" + Bytes.toString(kv.getFamily()));System.out.println("qualifier:" + Bytes.toString(kv.getQualifier()));System.out.println("value:" + Bytes.toString(kv.getValue()));System.out.println("Timestamp:" + kv.getTimestamp());System.out.println("-------------------------------------------");}/** List<?> results = table.get(get).list(); Iterator<?> it =* results.iterator(); while (it.hasNext()) {* System.out.println(it.next().toString()); }*/}/** 删除指定的列** @tableName 表名** @rowKey rowKey** @familyName 列族名** @columnName 列名*/public static void deleteColumn(String tableName, String rowKey, String falilyName, String columnName) throws IOException { HTable table = new HTable(conf, Bytes.toBytes(tableName));Delete deleteColumn = new Delete(Bytes.toBytes(rowKey));deleteColumn.deleteColumns(Bytes.toBytes(falilyName),Bytes.toBytes(columnName));table.delete(deleteColumn);System.out.println(falilyName + ":" + columnName + "is deleted!"); }/** 删除指定的列** @tableName 表名** @rowKey rowKey*/public static void deleteAllColumn(String tableName, String rowKey) throws IOException {HTable table = new HTable(conf, Bytes.toBytes(tableName));Delete deleteAll = new Delete(Bytes.toBytes(rowKey));table.delete(deleteAll);System.out.println("all columns are deleted!");}/** 删除表** @tableName 表名*/public static void deleteTable(String tableName) throws IOException { HBaseAdmin admin = new HBaseAdmin(conf);admin.disableTable(tableName);admin.deleteTable(tableName);System.out.println(tableName + "is deleted!");}public static void main(String[] args) throws Exception {// 创建表String tableName = "blog2";String[] family = { "article", "author" };// creatTable(tableName, family);// 为表添加数据String[] column1 = { "title", "content", "tag" };String[] value1 = {"Head First HBase","HBase is the Hadoop database. Use it when you need random, realtime read/write access to your Big Data.","Hadoop,HBase,NoSQL" };String[] column2 = { "name", "nickname" };String[] value2 = { "nicholas", "lee" };addData("rowkey1", "blog2", column1, value1, column2, value2);addData("rowkey2", "blog2", column1, value1, column2, value2);addData("rowkey3", "blog2", column1, value1, column2, value2);// 遍历查询getResultScann("blog2", "rowkey4", "rowkey5");// 根据row key范围遍历查询getResultScann("blog2", "rowkey4", "rowkey5");// 查询getResult("blog2", "rowkey1");// 查询某一列的值getResultByColumn("blog2", "rowkey1", "author", "name");// 更新列updateTable("blog2", "rowkey1", "author", "name", "bin");// 查询某一列的值getResultByColumn("blog2", "rowkey1", "author", "name");// 查询某列的多版本getResultByVersion("blog2", "rowkey1", "author", "name");// 删除一列deleteColumn("blog2", "rowkey1", "author", "nickname");// 删除所有列deleteAllColumn("blog2", "rowkey1");// 删除表deleteTable("blog2");}}。

合集下载

SCANNER手持便携式扫描仪使用手册

SCANNER手持便携式扫描仪使用手册

SCANNER手持便携式扫描仪使用手册产品参数：名称：SCANNER品牌便携式手持扫描仪影像传感器：A4彩色光电传感器白平衡：自动扫描分辨率：300dpi, 600dpi.900dpi存储格式：JPEG/PDF扫描幅度：A4（216mm）存储方式：MicroSD/TF卡扩展内存：MicroSD/TF(1G-32GB)传输方式：USB2.0产品尺寸：254mm*30mm*28mm电源：电池（5号电池X2）重量：约50g本体颜色: 标准颜色银黑色工作方式：脱机扫描自动关机：无操作3分钟后自动断电扫描软件: 可支持Windows Imaging，PHOTO Shop 和其他类似图像处理OCR软件。

系统环境: Windows 2000/ME/XP,MAC X, 128 MB RAM ，1000 MB HDD,设备特点: 双滚轮稳定控制系统整页扫描产品特点：1、一键式的扫描模式切换和高低分辨率设置，简单易操作。

2、可实时看到扫描纸张数，不需要安装任何专业的驱动软件。

3、MicroSD卡直接存储读取扫描数据，读卡器或者连接USB线就可以实现，无需扫描笔。

4、扫描数据为JPEG/PDF格式，编辑便利。

5、电源为普通5号电池，外出办公携带方便，更换简单。

1. 主要特点扫描选择彩色/黑白，分辨率600/300dpi可选，直接储存JPG文件到Micro SD卡，最大支持32GB,系统环境Windows 7/ Vista/ XP/ 和Mac OS 10.4或者以上（直接插入，不需安装驱动程序）。

2. 各部位功能1. 电池口：两个AA碱性电池；2. 电源/扫描电源开/关：持续按键两秒直到电源开/关,在电源开启的情况下，继续按键一次开始扫描，再次按键停止扫描；3. 错误指示灯：扫描速度过快，红灯亮；4. 扫描指示灯：绿灯亮，开始扫描；5. LED屏幕：扫描状态显示；6. 分辨率：选择高(600dpi)/低(300dpi)分辨率,屏幕有图标显示；选择彩色/黑白状态扫描时，屏幕有图标显示。

scanner java 用法

scanner java 用法

scanner java 用法Scanner Java 用法Scanner 是 Java 中的一个类，用于读取用户输入和文件内容。

在本文中，我们将详细介绍 Scanner 类的用法。

创建 Scanner 对象使用 Scanner 类之前，我们需要先创建一个 Scanner 对象。

创建 Scanner 对象的语法如下：Scanner scanner = new Scanner();上述代码创建了一个与标准输入流（）相关联的 Scanner 对象。

我们可以使用这个对象来读取用户在控制台上输入的内容。

读取基本数据类型Scanner 类提供了各种方法来读取不同类型的数据，例如读取整数、浮点数、字符串等。

下面是一些常用的读取数据的方法：•读取整数：nextInt()方法用于读取一个整数。

•读取浮点数：nextDouble()方法用于读取一个浮点数。

•读取字符串：next()方法用于读取一个字符串，它以空格作为分隔符。

以下示例代码展示了如何使用 Scanner 读取不同类型的数据：Scanner scanner = new Scanner();("请输入一个整数：");int num = ();("你输入的整数是：" + num);("请输入一个浮点数：");double decimal = ();("你输入的浮点数是：" + decimal);("请输入一个字符串：");String str = ();("你输入的字符串是：" + str);读取文件内容除了读取用户输入，Scanner 类还可以用于读取文件内容。

我们可以通过传递文件对象作为参数来创建与文件相关联的 Scanner 对象。

下面是一个示例，展示了如何使用 Scanner 读取文件内容：import ;import ;import ;public class FileScannerExample {public static void main(String[] args) {try {File file = new File("");Scanner scanner = new Scanner(file);while (()) {String line = ();(line);}();} catch (FileNotFoundException e) {("文件未找到！");}}}在上述示例中，我们创建了一个名为“” 的文本文件，并使用Scanner 逐行读取了文件内容并打印出来。

scanner基本表达式

scanner基本表达式

scanner基本表达式Scanner是Java中用于扫描输入的类，它可以从标准输入、文件、字符串等来源读取数据。

使用Scanner类需要先创建Scanner 对象，然后调用其方法来获取输入的数据。

以下是一些基本的Scanner表达式：1. 从标准输入中获取整数：java.Scanner scanner = new Scanner(System.in);System.out.println("请输入一个整数，");int num = scanner.nextInt();2. 从标准输入中获取字符串：java.Scanner scanner = new Scanner(System.in); System.out.println("请输入一个字符串，"); String str = scanner.nextLine();3. 从文件中获取数据：java.File file = new File("input.txt");Scanner scanner = new Scanner(file);while (scanner.hasNextLine()) {。

String line = scanner.nextLine();// 处理每一行数据。

}。

scanner.close();4. 使用正则表达式切割输入：java.Scanner scanner = new Scanner("1,2,3,4,5");eDelimiter(",");while (scanner.hasNextInt()) {。

int num = scanner.nextInt();// 处理每个整数。

}。

这些是一些基本的Scanner表达式，它们可以帮助我们从不同的来源获取输入并进行处理。

当使用Scanner时，需要注意及时关闭Scanner对象以释放资源，避免内存泄漏。

scanner数组在java中的用法

scanner数组在java中的用法

scanner数组在Java中的用法在Java编程中，scanner是一个非常常用的类，用于获取用户的输入。

而在一些特定的情况下，我们可能需要用到scanner数组来处理多个输入流。

本文将探讨scanner数组在Java中的用法，并深入理解其在实际开发中的应用。

1. 创建scanner数组我们需要了解如何创建一个包含多个scanner对象的数组。

在Java中，可以使用以下语法来创建一个大小为n的scanner数组：```Scanner[] scanners = new Scanner[n];```这样就创建了一个大小为n的scanner数组，可以用来处理多个输入流。

2. 初始化scanner数组在创建好scanner数组之后，我们需要对每个元素进行初始化，使其指向一个具体的输入流。

初始化scanner数组可以使用如下方法：```scanners[0] = new Scanner(System.in);scanners[1] = new Scanner(new File("input.txt"));// 其他初始化操作这样就为scanner数组的每个元素指定了一个具体的输入流，可以分别对不同的输入进行处理。

3. 使用scanner数组获取输入当我们需要从多个输入流中获取数据时，就可以利用scanner数组来分别处理。

通过循环遍历scanner数组，可以按照顺序获取每个输入流的数据，如下所示：```for (int i = 0; i < scanners.length; i++) {while (scanners[i].hasNext()) {// 从第i个输入流中获取数据并进行相应处理String data = scanners[i].next();// 其他操作}}```通过这种方式，我们可以方便地从多个输入流中获取数据，并进行相应的处理操作。

4. 关闭scanner数组在处理完所有输入流之后，我们需要及时关闭scanner数组，释放相关资源，避免资源泄露和浪费。