Question

java 怎么读取hdfs上csv文件的某一列

Answer 1

java 怎么读取hdfs上csv文件的某一列
import java.io.IOException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import com.csvreader.CsvReader;
import com.csvreader.CsvWriter;
/**
* 读取CSV文件
* 所谓"CSV",是Comma Separated Value（逗号分隔值）的英文缩写，通常都是纯文本文件。
* 可以看成数据库程序与电子表格之间一种中间通信文件，数据库可以导出。csv格式，excel也可以导入并打开。csv文件，例子如下
* sj_mino1001.jpg,715282,4FB55FE8,
* sj_mino1002.jpg,471289,93203C5C,
* sj_mino1003.jpg,451929,C4E80467,
*
*/
public class CSVDeal{
public static void main（String[] args） {
try {
String[] stringList;
String csvFilePath = "C:\\Users\\Administrator\\Desktop\\20140227135936.csv";
String sourceFileString= "C:\\Users\\Administrator\\Desktop\\test.csv";
CsvReader reader = new CsvReader（csvFilePath）； //默认是逗号分隔符，UTF-8编码
CsvWriter writer = new CsvWriter（sourceFileString）；
/*
* readRecord（）判断是否还有记录，getValues（）读取当前记录，然后指针下移
*/
reader.readRecord（）；
writer.writeRecord（reader.getValues（））； //读取表头
/*
* 逐行读取，以免文件太大
* 处理表头后面的数据，这里是在第12列数据统一加前缀"V"
*/
while（reader.readRecord（））{
stringList = reader.getValues（）；
stringList[11] = 'V' + stringList[11];
writer.writeRecord（stringList）；
}
reader.close（）；
writer.close（）；
}catch（Exception ex）{
System.out.println（ex）；
}
}
}