byte[] stringBuffer = new byte[1024];
stringBuffer = writeString.getBytes();
Path inputPath = new Path("hdfs://192.168.56.171:9000/testWrite");
OutputStream out = inputFileSystem.create(inputPath);
out.write(stringBuffer);
out.close();
}
}
hadoop通过FileSystem API读取和写入数据 (二)
Copies from one stream to another.\n";
byte[] stringBuffer = new byte[1024];
stringBuffer = writeString.getBytes();
Path inputPath = new Path("hdfs://192.168.56.171:9000/testWrite");
OutputStream out = inputFileSystem.create(inputPath);
out.write(stringBuffer);
out.close();
}
byte[] stringBuffer = new byte[1024];
stringBuffer = writeString.getBytes();
Path inputPath = new Path("hdfs://192.168.56.171:9000/testWrite");
OutputStream out = inputFileSystem.create(inputPath);
out.write(stringBuffer);
out.close();
}