package com.web.controller;
import com.web.controller.utils.*;
import com.web.controller.utils.HbaseUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
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.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.io.IOException;
import java.lang.reflect.Array;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Scanner;
import static java.util.Arrays.asList;
@Controller
public class WebController {
String hbaseQuorum = "hadoop10,hadoop11,hadoop12,hadoop13";
String zookeeperPort = "2181";
String tableName = "tmdb";
String tmdb_popularity = "tmdb_popularity";
String tmdb_runtime = "tmdb_runtime";
Configuration hbaseConf = new HbaseUtils().getHbaseConf(hbaseQuorum, zookeeperPort);
public WebController() throws Exception {
}
@RequestMapping(value = {"", "/index"})
public String index(Model model) {
// model.addAttribute("msg", "hello world");
return "index";
}
@RequestMapping(value = {"/demo"})
@ResponseBody
public List<Product> myProject() {
String[] data = {"羊毛衫","雪纺衫","裤子","高跟鞋","袜子"};
long[] nums = {20, 36, 10, 10, 20};
ArrayList<Product> productArr = new ArrayList<Product>();
for (int i=0; i<data.length; i++){
Product p = new Product();
p.setProductName(data[i]);
p.setNums(nums[i]);
productArr.add(p);
}
return productArr;
}
@RequestMapping(value = {"/popularity"})
@ResponseBody
public List<Product> Popularity() throws IOException {
Table table = new HbaseUtils().getTable(hbaseConf, tmdb_popularity);
Scan scan = new Scan();
ResultScanner resultScanner = table.getScanner(scan);
ArrayList<Product> productArr = new ArrayList<Product>();
long[] popularity = new long[10];
String[] original_title = new String[10];
int oindex = 0;
int pindex = 0;
for(Result result : resultScanner){
Cell[] cells = result.rawCells();
for(Cell cell : cells) {
// //得到rowkey
// System.out.println("行键:" + Bytes.toString(CellUtil.cloneRow(cell)));
// //得到列族
// System.out.println("列族" + Bytes.toString(CellUtil.cloneFamily(cell)));
// System.out.println("列:" + Bytes.toString(CellUtil.cloneQualifier(cell)));
// System.out.println("值:" + Bytes.toString(CellUtil.cloneValue(cell)));
String col = Bytes.toString(CellUtil.cloneQualifier(cell));
if (col.equals("original_title")) {
String value = Bytes.toString(CellUtil.cloneValue(cell));
original_title[oindex++] = value.split(":")[0];
} else if (col.equals("popularity")) {
Float value = Bytes.toFloat(CellUtil.cloneValue(cell));
popularity[pindex++] = value.longValue();
}
}
}
System.out.println(Arrays.toString(original_title));
System.out.println(Arrays.toString(popularity));
for (int i=0; i<original_title.length; i++){
Product p = new Product();
p.setProductName(original_title[i]);
p.setNums(popularity[i]);
productArr.add(p);
}
return productArr;
}
@RequestMapping(value = {"/runtime"})
@ResponseBody
public List<Product> Runtime() throws IOException {
Table table = new HbaseUtils().getTable(hbaseConf, tmdb_runtime);
Scan scan = new Scan();
ResultScanner resultScanner = table.getScanner(scan);
ArrayList<Product> productArr = new ArrayList<Product>();
long[] count = new long[16];
String[] runtime = new String[16];
int rindex = 0;
int cindex = 0;
for(Result result : resultScanner){
Cell[] cells = result.rawCells();
for(Cell cell : cells) {
String col = Bytes.toString(CellUtil.cloneQualifier(cell));
if (col.equals("runtime")) {
String value = Bytes.toString(CellUtil.cloneValue(cell));
runtime[rindex++] = value;
} else if (col.equals("count")) {
Long value = Bytes.toLong(CellUtil.cloneValue(cell));
count[cindex++] = value;
}
}
}
for (int i=0; i<runtime.length; i++){
Product p = new Product();
p.setProductName(runtime[i]);
p.setNums(count[i]);
productArr.add(p);
}
return productArr;
}
}
基于spark和hbase的电影数据可视化及推荐系统源码(课程设计).zip （61个子文件） 
hs_err_pid14256.log 34KB 说明.md 334B pom.xml 2KB
web HELP.md 1KB mvnw.cmd 6KB pom.xml 2KB src test java com web WebApplicationTests.java 196B main resources templates 
index.html 4KB static js echarts.min.js 753KB jquery-3.2.1.js 262KB jquery.js 274KB application.yml 21B java com web WebApplication.java 394B controller utils Product.java 439B HbaseUtils.java 1KB WebController.java 5KB target classes templates index.html 4KB static js echarts.min.js 753KB jquery-3.2.1.js 262KB jquery.js 274KB application.yml 21B com web WebApplication.class 682B controller utils Product.class 811B HbaseUtils.class 2KB WebController.class 6KB test-classes com web WebApplicationTests.class 510B web.iml 19KB mvnw 10KB replay_pid14256.log 551KB sparkBigProject.iml 1KB trainend trainend.iml 21KB pom.xml 3KB src main resources tmdb_5000_movies.csv 5.49MB tmdb.csv 5.43MB untitled0.py 637B scala com hjy dataprocess DataProcessing.scala 8KB ml ScorePredict.scala 7KB dataloader DataToHbase.scala 4KB uilts Uilts.scala 4KB target classes tmdb_5000_movies.csv 5.49MB tmdb.csv 5.43MB untitled0.py 637B com hjy dataprocess DataProcessing$$anonfun$2.class 2KB DataProcessing$$typecreator3$1.class 3KB DataProcessing$$anonfun$1.class 3KB DataProcessing.class 1KB DataProcessing$.class 11KB DataProcessing$$anonfun$getPopularity$1$1.class 2KB DataProcessing$$anonfun$3.class 2KB DataProcessing$$anonfun$getRuntime$1$1.class 2KB ml ScorePredict$$anonfun$1.class 3KB ScorePredict$$anonfun$getVoteAverage$1$1.class 2KB ScorePredict$.class 12KB ScorePredict$$typecreator3$1.class 3KB ScorePredict.class 1KB dataloader DataToHbase$$anonfun$insertSmallData$1.class 4KB DataToHbase$$anonfun$1.class 2KB DataToHbase$.class 5KB DataToHbase.class 2KB uilts Uilts$.class 5KB Uilts.class 2KB资源评论
Tang001012024-06-21资源简直太好了，完美解决了当下遇到的难题，这样的资源很难不支持~
