S3にバケットが存在するかどうかを確認する必要があり、次のコードがあります。
public static final String S3_URI = "s3n://accessKey:secretKey";
FileSystem fs = new NativeS3FileSystem(new Jets3tNativeFileSystemStore(S3_URI, null));
if (!fs.exists(bucket)) {
getLogger().error("The input directory '{}' does not exists.", bucket);
return false;
}
ただし、不平を言ったeclipseはJets3tNativeFileSystemStoreをタイプに解決できず、不平を言ったimportsステートメントはorg.apache.hadoop.fs.s3native.Jets3tNativeFileSystemStoreを表示しません。Jets3tNativeFileSystemStoreのソースコードを確認しました。
class Jets3tNativeFileSystemStore implements NativeFileSystemStore {
private S3Service s3Service;
private S3Bucket bucket;
...
それはプライベートクラスだということですか?バケットがS3に存在するかどうかを確認する正しい方法は何ですか?ありがとう。