java框架与大数据存储和管理系统的集成（java大数

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.Connection;

import org.apache.hadoop.hbase.client.Put; zvvq.cn

import org.apache.hadoop.hbase.client.Table;

内容来自samhan

import org.apache.hadoop.hbase.util.Bytes;

import org.springframework.beans.factory.annotation.Autowired; zvvq

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

内容来自samhan666

import org.springframework.data.hadoop.hbase.HbaseTemplate; 内容来自zvvq

import org.springframework.web.bind.annotation.; 内容来自samhan666

@SpringBootApplication

内容来自samhan666

public class HBaseSpringBootApplication { 内容来自samhan666

@Autowired

内容来自zvvq，别采集哟

private HbaseTemplate hbaseTemplate; zvvq.cn

public static void main(String[] args) {

zvvq

SpringApplication.run(HBaseSpringBootApplication.class, args);

内容来自samhan

}

内容来自zvvq，别采集哟

@PostMapping("/save-data") 本文来自zvvq

public void saveData(@RequestParam String rowKey, @RequestParam String value) {

zvvq好，好zvvq

TableName tableName = TableName.valueOf("user_table");

内容来自samhan

try (Table table = hbaseTemplate.getConnection().getTable(tableName)) { zvvq.cn

Put put = new Put(Bytes.toBytes(rowKey));

put.addColumn(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes(value)); zvvq.cn

table.put(put);

} catch (Exception e) { 内容来自samhan

e.printStackTrace(); 内容来自samhan

}

本文来自zvvq

}

内容来自samhan666

}

内容来自zvvq