Hadoop Javaポートへの接続

2年 ago
結衣, 春花
1 minute

HadoopによるJavaからのポート接続方法には、HadoopのHDFS APIまたはYARN APIを利用する方法があります。JavaからHadoopのHDFSポートに接続するコード例を以下に示します。

“`java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

public class HadoopConnection {
public static void main(String[] args) {
try {
// Hadoopの設定オブジェクトを作成
Configuration conf = new Configuration();
// HadoopのファイルシステムをHDFSに設定
conf.set(“fs.defaultFS”, “hdfs://localhost:9000”);

// Hadoopファイルシステムオブジェクトを作成
FileSystem fs = FileSystem.get(conf);

// ファイルパスを作成
Path filePath = new Path(“/path/to/file.txt”);

// ファイルの存在を確認
boolean exists = fs.exists(filePath);

if (exists) {
System.out.println(“File exists!”);
} else {
System.out.println(“File does not exist!”);
}

// ファイルシステム接続を閉じる
fs.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
“`

上記の例では、最初にHadoopの設定オブジェクトを作成し、ファイルシステムをHDFSに設定します。次に、`FileSystem.get(conf)`を使用してHDFSのファイルシステムオブジェクトを取得します。続いて、ファイルシステムオブジェクトを使用して、ファイルの存在確認などのさまざまな操作を実行できます。最後に、ファイルシステム接続を閉じます。なお、この例ではHadoopのHDFSポートが9000であることを前提としていますが、実際のHadoop設定に応じて変更する必要があります。

bannerAds