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への依存を指定すると、プラットフォーム固有の依存関係構築アプリケーションを管理する必要がなくなります.アプリケーションが
JARファイルを使用してMavenの
MAPRリリースから2.1.2バージョン、Mavenコンポーネント以降http://repository.mapr.com/maven/.
例えば、MAPR 2.1.3版にコンパイルすると、以下の依存関係がプロジェクトの
MAPRが提供する文化財と詳細の完全なリストについては、MavenリポジトリとワークMAPRを参照してください.
JARファイルを使用してMAPRからインストール
また、
#サンプルコードをコンパイルするには、HadoopのコアJARファイルのみが必要です.
たとえば、MAPRバージョン3.0.0のサンプルコードを実行するには、次のライブラリパスを使用します.
Javaアプリケーションの作成
Javaアプリケーションでは、
サンプルコード
次のサンプルコードは、MAPR-FSでJavaインタフェースを使用する方法を示しています.この例では、ディレクトリを作成し、ファイルに書き込み、ファイルの内容を読み込みます.
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
。
2
/ lib/hadoop-
0.20
。
2
-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 =
0
;
(args.length!=
1
){
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
(
)
1
,
/ /
(
)(
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”
);
}
}