HDFSµÄJava·ÃÎʽӿÚ
µÃµ½filesystemµÄʵÀý
ÓÐÁ½¸ö¾²Ì¬·½·¨¿ÉÒԵõ½filesystem½Ó¿ÚµÄʵÀý
public static FileSystem get(Configuration conf) throws IOException
public static FileSystem get(URI uri, Configuration conf) throws IOException
µÚÒ»¸ö·½·¨µÃµ½È±Ê¡µÄÎļþϵͳ£¬¾ßÌåÓÉÅäÖÃÎļþµÄfs.default.nameÊôÐÔ¾ö¶¨¡£
µÚ¶þ¸ö·½·¨ÓÉURIµÄǰ׺¾ö¶¨ÊÇÄĸöÎļþϵͳ£¨²Î¿¼Ç°Ò»ÆªÎÄÕ£©£¬Èç¹ûURIûÓÐǰ׺ҲÊǵõ½È±Ê¡µÄÎļþϵͳ¡£
ʹÓÃopen·½·¨µÃµ½ÎļþµÄÊäÈëÁ÷
ÓÐÁËfilesystemµÄʵÀý£¬ÎÒÃǾͿÉÒÔµ÷ÓÃopen·½·¨µÃµ½Ä³¸öÎļþµÄÊäÈëÁ÷ÁË
public FSDataInputStream open(Path f) throws IOException
public abstract FSDataInputStream open(Path f, int bufferSize) throws IOException
µÚÒ»¸ö·½·¨ÓÃȱʡµÄbuffer´óС4K
ʹÓÃFSDataInputStream¶ÁÊý¾Ý
FSDataInputStreamÅÉÉú×Ôjava.io.DataInputStream£¬Ö§³ÖËæ»ú¶ÁÈ¡¡£
public class FSDataInputStream extends DataInputStream
implements Seekable, PositionedReadable {
void seek(long pos) throws IOException;
public int read(long position, byte[] buffer, int offset, int length) throws IOException;
}
ʹÓÃFSDataOutputStreamдÊý¾Ý
filesystem½Ó¿Ú´´½¨ÎļþµÄ½Ó¿Ú
public FSDataOutputStream create(Path f) throws IOException
»¹¿ÉÒÔappendµ½Ò»¸öÒѾ´æÔÚµÄÎļþ
public FSDataOutputStream append(Path f) throws IOException
public class FSDataOutputStream extends DataOutputStream implements Syncable {
public void write(int b) throws IOException;
public void write(byte b[], int off, int len) throws IOException;
}
filesystemµÄÎļþϵͳ²Ù×÷·½·¨
public boolean mkdirs(Path f) throws IOException ;
public void copyToLocalFile(boolean delSrc, Path src, Path dst) throws IOException;
public abstract boolean delete(Path f, boolean recursive) throws IOException;
public abstract boolean rename(Path src, Path dst) throws IOException;
public abstract FileStatu
Ïà¹ØÎĵµ£º
Java NIO APIÏê½â
ÔÚJDK
1.4ÒÔǰ£¬JavaµÄIO²Ù×÷¼¯ÖÐÔÚjava.ioÕâ¸ö°üÖУ¬ÊÇ»ùÓÚÁ÷µÄ×èÈû£¨blocking£©API¡£¶ÔÓÚ´ó¶àÊýÓ¦ÓÃÀ´Ëµ£¬ÕâÑùµÄAPIʹÓúܷ½
±ã£¬È»¶ø£¬Ò»Ð©¶ÔÐÔÄÜÒªÇó½Ï¸ßµÄÓ¦Óã¬ÓÈÆäÊÇ·þÎñ¶ËÓ¦Óã¬ÍùÍùÐèÒªÒ»¸ö¸üΪÓÐЧµÄ·½Ê½À´´¦ÀíIO¡£´ÓJDK 1.4Æð£¬NIO
API×÷Ϊһ¸ö»ùÓÚ»º³åÇø£¬²¢ÄÜÌṩ·Ç×èÈû(non-blo ......
½Ì³Ì5 ËãÊýÔËËãѧϰ³ÌÐò ѧϰĿ±ê 5.1¼òµ¥¼Ó·¨Ñ§Ï°³ÌÐò СѧÉúÔÚ¸Õ¸Õ¿ªÊ¼Ñ§Ï°ÊýѧÔËËãµÄʱºò£¬ÐèÒª²»¶ÏµØ½øÐз´¸´´óÁ¿µÄÁ·Ï°£¬²ÅÄܹ»Ñ¸ËÙÕÆÎÕÕⲿ·ÖÄÚÈÝ¡£ÏÂÃæ¿ª·¢Ò»¸ö¼òµ¥µÄ¼Ó·¨Ñ§Ï°³ÌÐò£¬Äܹ»²úÉú¼Ó·¨ÔËËãÈÃѧÉúÀ´Ñ§Ï°Ìá¸ß¡£ ±àд³ÌÐòÈçÏ£º 1 package lesson5; 2 3 public class Operation1 { 4 int number1; 5 ......
ѧϰjavaµÄ30¸öÄ¿±ê----Èç¹ûÕâ30ÌõÄã×öµÄ²î²»¶àÁË£¬jAVAˮƽ¾Íµ±È»²»ÓÃ˵ÁË£¬ºÃºÃŬÁ¦°É
1.ÄãÐèÒª¾«Í¨ÃæÏò¶ÔÏó·ÖÎöÓëÉè¼Æ(OOA/OOD)¡¢É漰ģʽ(GOF£¬J2EEDP)ÒÔ¼°×ÛºÏģʽ¡£ÄãÓ¦¸ÃÊ®·ÖÁ˽âUML£¬ÓÈÆäÊÇclass£¬object£¬interactionÒÔ¼°statediagrams¡£
¡¡¡¡2.ÄãÐèҪѧϰJAVAÓïÑԵĻù´¡ÖªÊ¶ÒÔ¼°ËüµÄºË ......
3.package com.ncs.opts.tools;
import java.util.HashMap;
import java.util.Map;
import com.ncs.opts.common.icp.dao.po.audit.IcpMainHistory;
import com.ncs.opts.common.icp.dao.po.audit.IcpModifyHistory;
import com.ncs.opts.common.icp.dao.po.audit.IcpSiteAccessHistory;
import com.ncs.opts.common.i ......
Îļþ´ò¿ªÊ±ºòÊÇͨ¹ýÎļþÍ·À´È·¶¨ÎļþµÄ±àÂë
StreamReader sr=new StreamReader(@"F:\cym\temp\1.txt");
sr.CurrentEncoding //·µ»Ø±àÂë
ÊÀ½çÉϵĸ÷µØÇø¶¼Óб¾µØµÄÓïÑÔ¡£µØÇø²îÒìÖ±½Óµ¼ÖÂÁËÓïÑÔ»·¾³µÄ²îÒì¡£ÔÚ¿ª·¢Ò»¸ö¹ú¼Ê»¯³ÌÐòµÄ¹ý³ÌÖУ¬´¦ÀíÓïÑÔÎ ......