資源簡介
這個主要是利用spark的api,樸素貝葉斯算法,來預測股票,其中包含的股票的原始數據和處理后適合spark api處理的訓練模型
代碼片段和文件信息
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?{
?????????????/*?寫入Txt文件?*/
????????????File?writename?=?new?File(“/usr/local/data/train.txt“);?//?相對路徑,如果沒有則要建立一個新的output。txt文件
????????????writename.createNewFile();?//?創建新文件
????????????BufferedWriter?out?=?new?BufferedWriter(new?FileWriter(writename));
????????????//處理數據,從perfect.csv文件中讀取數據
????????????ArrayList>?alldata1=CSV2Array(“/usr/local/data/perfect_data.csv“);
????????????//遍歷數組
????????????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“;?//?絕對路徑或相對路徑都可以,這里是絕對路徑,寫入文件時演示相對路徑
//????????????File?filename?=?new?File(pathname);?//?要讀取以上路徑的input。txt文件
//????????????InputStreamReader?reader?=?new?InputStreamReader(
//????????????????????new?FileInputStream(filename));?//?建立一個輸入流對象reader
//????????????BufferedReader?br?=?new?BufferedReader(reader);?//?建立一個對象,它把文件內容轉成計算機能讀懂的語言
//????????????String?line?=?““;
//????????????line?=?br.readLine();
//
//????????????//===========================================
//
////????????????/*?寫入Txt文件?*/
////????????????File?writename?=?new?File(“/usr/local/data/train.txt“);?//?相對路徑,如果沒有則要建立一個新的output。txt文件
////????????????writename.createNewFile();?//?創建新文件
////????????????BufferedWriter?out?=?new?BufferedWriter(new?FileWriter(writename));
//
//
//
//
//????????????//===========================================
//????????????while?(line?!=?null)?{
//????????????????System.out.println(line);
////????????????????line?=?br.readLine();?//?一次讀入一行數據
////????????????????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();?//?把緩存區內容壓入文件
////????????????????}
//
//????????????}
????}
????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(““);??//默認分割符為逗號,可以不使用逗號
????????????????linedata=arr[0]+““+arr[1]+“?“+arr[2]+“?“+arr[3
- 上一篇:iOS 13.0-13.3真機調試包
- 下一篇:最新暴風魔鏡sdk
評論
共有 條評論