-
大小: 36.73MB文件類(lèi)型: .gz金幣: 1下載: 0 次發(fā)布日期: 2023-06-22
- 語(yǔ)言: 其他
- 標(biāo)簽: spark??機(jī)器學(xué)習(xí)??股票預(yù)測(cè)??
資源簡(jiǎn)介
這個(gè)主要是利用spark的api,樸素貝葉斯算法,來(lái)預(yù)測(cè)股票,其中包含的股票的原始數(shù)據(jù)和處理后適合spark api處理的訓(xùn)練模型
代碼片段和文件信息
package?com.test;
import?java.io.*;
import?java.util.ArrayList;
import?java.util.Arrays;
import?java.util.List;
public?class?DealDataToTrain?{
????public?static?void?main(String[]args)?throws?IOException?{
?????????????/*?寫(xiě)入Txt文件?*/
????????????File?writename?=?new?File(“/usr/local/data/train.txt“);?//?相對(duì)路徑,如果沒(méi)有則要建立一個(gè)新的output。txt文件
????????????writename.createNewFile();?//?創(chuàng)建新文件
????????????BufferedWriter?out?=?new?BufferedWriter(new?FileWriter(writename));
????????????//處理數(shù)據(jù),從perfect.csv文件中讀取數(shù)據(jù)
????????????ArrayList>?alldata1=CSV2Array(“/usr/local/data/perfect_data.csv“);
????????????//遍歷數(shù)組
????????????for?(ArrayList?arrayList?:?alldata1)?{
????????????????for?(String?string?:?arrayList)?{
????????????????????out.write(string?+?“\n“);
????????????????????out.flush();
????????????????????System.out.println(string);
????????????????}
????????????}
//
//????????????/*?讀入TXT文件?*/
//????????????String?pathname?=?“/usr/local/data/perfect_data.csv“;?//?絕對(duì)路徑或相對(duì)路徑都可以,這里是絕對(duì)路徑,寫(xiě)入文件時(shí)演示相對(duì)路徑
//????????????File?filename?=?new?File(pathname);?//?要讀取以上路徑的input。txt文件
//????????????InputStreamReader?reader?=?new?InputStreamReader(
//????????????????????new?FileInputStream(filename));?//?建立一個(gè)輸入流對(duì)象reader
//????????????BufferedReader?br?=?new?BufferedReader(reader);?//?建立一個(gè)對(duì)象,它把文件內(nèi)容轉(zhuǎn)成計(jì)算機(jī)能讀懂的語(yǔ)言
//????????????String?line?=?““;
//????????????line?=?br.readLine();
//
//????????????//===========================================
//
////????????????/*?寫(xiě)入Txt文件?*/
////????????????File?writename?=?new?File(“/usr/local/data/train.txt“);?//?相對(duì)路徑,如果沒(méi)有則要建立一個(gè)新的output。txt文件
////????????????writename.createNewFile();?//?創(chuàng)建新文件
////????????????BufferedWriter?out?=?new?BufferedWriter(new?FileWriter(writename));
//
//
//
//
//????????????//===========================================
//????????????while?(line?!=?null)?{
//????????????????System.out.println(line);
////????????????????line?=?br.readLine();?//?一次讀入一行數(shù)據(jù)
////????????????????String[]arr=null;
////????????????????if(line!=null)?{
////????????????????????arr?=?line.split(““);
////????????????????}
////????????????????String?Linedata=““;
////????????????????if(!arr[0].equals(“gate“)?&&?arr.length>=7)?{
////????????????????????Linedata=arr[0]+““+arr[1]+“?“+arr[2]+“?“+arr[3]+“?“+arr[4]+“?“+arr[5]+“?“+arr[6];
////????????????????????out.write(Linedata?+?“\n“);?//?\r\n即為換行
////????????????????????out.flush();?//?把緩存區(qū)內(nèi)容壓入文件
////????????????????}
//
//????????????}
????}
????public?static?ArrayList>?CSV2Array(String?path)?{
????????try?{
????????????BufferedReader?in?=?new?BufferedReader(new?InputStreamReader(new?FileInputStream(path)?“UTF-8“));
????????????ArrayList>?alldata?=?new?ArrayList>();
????????????String?line;
????????????String[]?arr;
????????????String?linedata;
????????????while?((line?=?in.readLine())?!=?null)?{
????????????????arr?=?line.split(““);??//默認(rèn)分割符為逗號(hào),可以不使用逗號(hào)
????????????????linedata=arr[0]+““+arr[1]+“?“+arr[2]+“?“+arr[3
評(píng)論
共有 條評(píng)論