public class FileSystemFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<org.apache.hadoop.fs.FileSystem>FileSystem インスタンスを作成するための FactoryBean。Map Reduce ジョブの外部から HDFS を操作する場合に便利です。パラメーターを指定しない場合は、インストールされた Hadoop のデフォルトを使用してファイルシステムが作成されます。| コンストラクターと説明 |
|---|
FileSystemFactoryBean() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | afterPropertiesSet() |
void | destroy() |
org.apache.hadoop.fs.FileSystem | getObject() |
java.lang.Class<?> | getObjectType() |
boolean | isSingleton() |
void | setClose(boolean close) このファクトリが破棄されたら Hadoop ファイルシステムを閉じるかどうかを示します。 |
void | setCloseAll(boolean closeAll) このファクトリが破棄されたら、すべての Hadoop ファイルシステムを閉じる必要があるかどうかを示します。 |
void | setConfiguration(org.apache.hadoop.conf.Configuration configuration) このファイルシステムの Hadoop 構成を設定します。 |
void | setUri(java.net.URI uri) このファイルシステムの URI (使用可能な場合) を設定します。 |
void | setUser(java.lang.String user) このファイルシステムを作成するためのユーザーの偽装 (オプション) を設定します。 |
public void afterPropertiesSet()
throws java.lang.Exceptionorg.springframework.beans.factory.InitializingBean 内の afterPropertiesSet java.lang.Exceptionpublic void destroy()
throws java.lang.Exceptionorg.springframework.beans.factory.DisposableBean 内の destroy java.lang.Exceptionpublic org.apache.hadoop.fs.FileSystem getObject()
throws java.lang.Exceptionorg.springframework.beans.factory.FactoryBean<org.apache.hadoop.fs.FileSystem> 内の getObject java.lang.Exceptionpublic java.lang.Class<?> getObjectType()
org.springframework.beans.factory.FactoryBean<org.apache.hadoop.fs.FileSystem> 内の getObjectType public boolean isSingleton()
org.springframework.beans.factory.FactoryBean<org.apache.hadoop.fs.FileSystem> 内の isSingleton public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration - 設定する構成。public void setUri(java.net.URI uri)
uri - 設定する URI。public void setUser(java.lang.String user)
user - ユーザー / グループ情報 public void setCloseAll(boolean closeAll)
closeAll - すべてを閉じる FileSystem.closeAll()public void setClose(boolean close)
close - 閉じる FileSystem.close()