spark 朴素贝叶斯实现股票预测数据+代码

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