一致疏于JAVA IO方面的基础学习。
这次在使用到HDFS的文件接口的时候,就遇到这方面的问题。
于是巩固一下基础。
java io是典型的decorator设计模式。
Path path = new Path(“路径”);
FSDataIOutputStream fdos = fs.append(path); //追加
fdos.write……即可
fdos.flush();//刷出数据
FSDataInputStream fdis = fs.open(path);
Text line = new Text();
LineReader reader = new LineReader(fdis); //一行一行的读 使用LineReader
while(reader.readLine(line) > 0) {
System.out.println(line);//输出
}
fdis.close();
使用bufferedReader读取
String uri = "hdfs://localhost:9000/hadoop/test/IP-COUNTRY-REGION-CITY.CSV.hive";
Configuration conf = new Configuration();
FileSystem fs = null;
FSDataInputStream in = null;
BufferedReader d = null;
try {
fs = FileSystem.get(URI.create(uri), conf);
in = fs.open(new Path(uri));
d = new BufferedReader(new InputStreamReader(in)); //使用BufferedReader 进行readLine
String s = null;
int stat = 1;
while (true) {
System.out.println("line "+stat++);
s = d.readLine();
public class JavaFile01 { //InputStream 三个基本的读方法 //abstract int read() :读取一个字节数据,并返回读到的数据,如果返回-1,表示读到了输入流的末尾。 //int read(byte[] b) :将数据读入一个字节数组,同时返回实际读取的字节数。如果返回-1,表示读到了输入流的末尾。 //int read(byte[] b, int off, int len) :将数据读入一个字节数组,同时返回实际读取的字节数。 //如果返回-1,表示读到了输入流的末尾。 //off指定在数组b中存放数据的起始偏移位置; //len指定读取的最大字节数。 public static void main(String[] args) throws IOException { File f = new File("a.txt"); //InputStream是一个标准的输入接口 //对应读取数据的类有:FileInputStream ObjectInputStream等 //XXXInputStream就是为InputStream对象赋予额外的功能, InputStream in = new BufferedInputStream(new FileInputStream(f)); byte[] b = new byte[1024]; while(in.read()!=-1){ try { in.read(b); System.out.println("读入buffer的信息:"+new String(b)); } catch (IOException e) { e.printStackTrace(); } } // InputSteream和OutpurStream是针对基于字节(byte)输入输出设计的,实际应用中常常需要读 // 写的是基于字符(char ,Unicode 2 个字节)的,java.io.Reader和java.io.Writer就是所有读 // 写字符数据流的父类。 //FileReader作为Reader对象的数据源 BufferedReader brin = new BufferedReader(new FileReader("a.txt")); //Stream与Reader之间的转换 InputStreamReader isr = new InputStreamReader(in);//<--Stream输入 BufferedReader reader = new BufferedReader(isr);//使用Reader进行读取 System.out.println(reader.readLine()); } }
相关推荐
import java.io.*; import java.util.*; public class FileFormatChange { /** * 1、创建输入(输出)流对象 * 2、读(写)数据 * 3、关闭输入输出流 */ public static void main(String[] args) { // ...
高级javaimport java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; public class Client { public static void main (String args[]){ try{ ...
关于Java io的一些代码import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.io...
while( (line = br.readLine() ) != null ) { sb.append(line).append(LINE_BREAK); } ret = sb.toString(); } finally { if(br!=null) {try{br.close();} catch(Exception e){} } } long endTime = System....
黑马程序员_毕向东_Java基础视频教程第18天-14-IO流(拷贝文本文件图例).zip
import java.io.*; public class FirstPart{ public static void main(String[] args) throws Exception{ System.out.print("The input Fahrenheit is "); BufferedReader br = new BufferedReader(new ...
import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.InputStreamReader; import java.io.Reader; /** * @author...
import java.io.DataInputStream; import java.io.IOException; import java.net.MalformedURLException; import java.net.URL; public class UrlHtml { @SuppressWarnings("deprecation") public ...
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.net.UnknownHostException; import javax....
import java.io.*; //加载 java.io 类库里的所有类 public class app3_{ public static void main(String[] args) throws IOException { BufferedReader buf; String str; buf=new BufferedReader(new ...
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintStream; import java.net.ServerSocket; import java.net.Socket; import java.text....
import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io....
JAVA课程设计1 import java.io.*; class Test { public static void main(String[] args) { BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); boolean b = true; try { while (b) ...
停车场管理系统(java) import java.io.*; public class Method { private int intinput() throws IOException,NumberFormatException { BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); ...
java.io.BufferedReader l_reader = new java.io.BufferedReader( new java.io.InputStreamReader(l_urlStream)); while ((sCurrentLine = l_reader.readLine()) != null) { sTotalString += sCurrentLine; }
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; /* 如何注册myeclipse 1、菜单myeclipse---->subscription Information 2、window----preferences----...
import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io....
import java.io.*; class FileB{ public static void main(String args[]){ String s="How do you do!\r\nI like Java!\r\n"; InputStreamReader in; FileWriter out; BufferedReader br; try{ in=new ...
import java.io.*; public class Calendar{ static int year; static int weekDay; public static void main(String args[])throws IOException{ System.out.println("请输入年份:"); InputStreamReader ir; ...
import java.io.InputStreamReader; import java.io.LineNumberReader; import java.util.StringTokenizer; import sun.management.ManagementFactory; import com.sun.management.OperatingSystemMXBean; public...