wiki:waue/2009/1026
  • ICAS.java 完成 上傳檔案到hdfs的程式
  static boolean upload2HDFS() {
    Configuration conf = new Configuration();
    String hdfs_src = fa_in;
    String local_src = rdc_out + "/parsed";
    Path dstPath = new Path(hdfs_src);
    try {
      FileSystem dstFs = dstPath.getFileSystem(conf);
      dstFs.copyFromLocalFile(false, new Path(local_src), new Path(
          hdfs_src));
      return true;
    } catch (IOException e) {
      e.printStackTrace();
      return false;
    }
  }
  • RawDataCheck?.java 四個功能皆完成
  • icas main programDriver .. ok
Last modified 15 years ago Last modified on Oct 26, 2009, 8:02:33 PM