Maprのjava開発ガイド(一)

6039 ワード

このページでは、JavaプログラムでMAPR-FSにアクセスし、サンプルコードを含める方法について説明します.このページには、次のトピックが含まれています.
JARファイルを使用してMavenのから
JARファイルを使用してMAPRインストールから
Javaアプリケーションの作成高性能のファイルシステムとして、MAPR-FSファイルのクライアント部分はローカルライブラリに基づいています.MAPR-FSファイルにアクセスするために必要なすべての依存関係は、32ビットおよび64ビットLinux、64ビットMac OSX、および32ビットおよび64ビットWindowsクライアントの1つのJARファイルに含まれます.アプリケーションを開発し、このJARへの依存を指定すると、プラットフォーム固有の依存関係構築アプリケーションを管理する必要がなくなります.アプリケーションがmaprfsライブラリをロードすると、maprclientがターゲットOSライブラリでJavaで使用できない場合  CLASSPATH 、アダプターは脂肪JARの内容を検索し、maprclientを見つけます.
JARファイルを使用してMavenの
MAPRリリースから2.1.2バージョン、Mavenコンポーネント以降http://repository.mapr.com/maven/.
例えば、MAPR 2.1.3版にコンパイルすると、以下の依存関係がプロジェクトのpom.xml ファイルに追加される.この依存性はMAPRのMaven倉庫から、次は依存関係の他の mvn を引っ張ることになります.    org.apache.hadoop groupId>    hadoop artifactId >    1.0.3-MAPR-2.1.3.1 > >
MAPRが提供する文化財と詳細の完全なリストについては、MavenリポジトリとワークMAPRを参照してください.
JARファイルを使用してMAPRからインストール
また、maprfsライブラリJARの / opt / MAPR / lib のディレクトリを見つけることもできます.
#サンプルコードをコンパイルするには、HadoopのコアJARファイルのみが必要です.javac -CP / opt/mapr/hadoop/hadoop-  0.20  / lib/hadoop-  0.20  -DEV-core.jar MapRTest.java
たとえば、MAPRバージョン3.0.0のサンプルコードを実行するには、次のライブラリパスを使用します.java Djava.library.path = / / MAPR / lib -CP:$(Hadoop )\ / opt/mapr/hadoop/hadoop-0.20.2/conf:\ / opt/mapr/hadoop/hadoop-0.20.2/lib/hadoop-0.20.2-dev-core.jar:\ / opt/mapr/hadoop/hadoop-0.20.2/lib/commons-logging-1.0.4.jar:\ / opt/mapr/hadoop/hadoop-0.20.2/lib/maprfs-1.0.3-mapr-3.0.0.jar:\ / opt/mapr/hadoop/hadoop-0.20.2/lib/maprfs-jni-1.0.3-mapr-3.0.0.jar:\ / opt/mapr/hadoop/hadoop-0.20.2/lib/zookeeper-3.3.6.jar \ MapRTest /
Javaアプリケーションの作成
Javaアプリケーションでは、 オブジェクトMAPR-FSインタフェースを使用します.Javaアプリケーションを実行すると、Hadoopの構成ディレクトリに/ opt/mapr/hadoop/hadoop- / conf がJavaクラスパスに追加されます. オブジェクトをインスタンス化すると、ディレクトリ内のプロファイルからデフォルト値をペイントして作成されます.
サンプルコード
次のサンプルコードは、MAPR-FSでJavaインタフェースを使用する方法を示しています.この例では、ディレクトリを作成し、ファイルに書き込み、ファイルの内容を読み込みます./ * (c)2009 。MAPR , * /
  / / com.mapr.fs;
    java.net *。;   org.apache.hadoop.fs *。;   org.apache.hadoop.conf *。;
  / ** * MAPR / opt / MAPR * * hadoop jar : * javac-CP / opt/mapr/hadoop/hadoop-0.20.2/lib/hadoop-0.20.2-dev-core.jar MapRTest.java * * : * java-Djava.library.path = / / MAPR / lib -CP MapRTest / * /     MapRTest {       ( [])   {   BUF [] =    65  1024  ];   AC =  ;   (args.length!=  ){ System.out.println(  “  :MapRTest ”  ); ; }
  / / maprfs :/ / / - > / opt / MAPR / conf / MAPR-clusters.conf / / maprfs :/ / / MAPR / my.cluster.com / / / / MAPR / my.cluster.com /
  / / uri =“maprfs :/ / /”; = [AC + +];
  CONF =    ();
  / / FS = FileSystem.get(URI.create(URI),conf ); / / FS = FileSystem.get( );
  dirpath =    ( +  “/ ”  ); wfilepath =    ( +  “/ file.w”  ); / / rfilepath = ( +“/ file.r”); rfilepath = wfilepath;
 
  / / TRY MKDIR   RES = fs.mkdirs(dirpath);   (! ){ System.out.println( “MKDIR , :”  + dirpath); ; }
  System.out.println( “MKDIR(”  + dirpath +  “) ok , ”  );
  / / wfile FSDataOutputStream OSTR = fs.create(wfilepath, / / 512  / / BUFFERSIZE / / )( 64  1024  1024  / / ); ostr.write(BUF); ostr.close();
  System.out.println(  “  (”  + wfilepath +  “) OK”  );
  / / System.out.println(  “  :”  + rfilepath); FSDataInputStream ISTR = fs.open(rfilepath);   BB = istr.readInt(); istr.close(); System.out.println(  “  OK”  ); } }