public class CachingHadoopFileSystemFactory extends BasicHadoopFileSystemFactory
FileSysteminstances on per-user basis. Doesn't rely on built-in Hadoop
FileSystemcaching mechanics. Separate
FileSysteminstance is created for each user instead.
This makes cache instance resistant to concurrent calls to
FileSystem.close() in other parts of the user
code. On the other hand, this might cause problems on some environments. E.g. if Kerberos is enabled, a call to
FileSystem.get(URI, Configuration, String) will refresh Kerberos token. But this factory implementation
calls this method only once per user what may lead to token expiration. In such cases it makes sense to either
BasicHadoopFileSystemFactory or implement your own factory.
|Constructor and Description|
get, getConfigPaths, getUri, getUserNameMapper, readExternal, setConfigPaths, setUri, setUserNameMapper, writeExternal