1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.apache.commons.vfs2.provider.hdfs;
18
19 import java.util.Arrays;
20 import java.util.Collection;
21 import java.util.Collections;
22
23 import org.apache.commons.vfs2.Capability;
24 import org.apache.commons.vfs2.FileName;
25 import org.apache.commons.vfs2.FileSystem;
26 import org.apache.commons.vfs2.FileSystemConfigBuilder;
27 import org.apache.commons.vfs2.FileSystemException;
28 import org.apache.commons.vfs2.FileSystemOptions;
29 import org.apache.commons.vfs2.provider.AbstractOriginatingFileProvider;
30 import org.apache.commons.vfs2.provider.http.HttpFileNameParser;
31
32
33
34
35
36
37 public class HdfsFileProvider extends AbstractOriginatingFileProvider {
38
39 static final Collection<Capability> CAPABILITIES = Collections
40 .unmodifiableCollection(Arrays.asList(Capability.GET_TYPE, Capability.READ_CONTENT,
41 Capability.CREATE,
42 Capability.DELETE,
43 Capability.RENAME,
44 Capability.WRITE_CONTENT,
45 Capability.URI, Capability.GET_LAST_MODIFIED,
46 Capability.SET_LAST_MODIFIED_FILE,
47 Capability.ATTRIBUTES, Capability.RANDOM_ACCESS_READ, Capability.DIRECTORY_READ_CONTENT,
48 Capability.LIST_CHILDREN));
49
50
51
52
53 public HdfsFileProvider() {
54 this.setFileNameParser(HttpFileNameParser.getInstance());
55 }
56
57
58
59
60
61
62
63
64 @Override
65 protected FileSystem doCreateFileSystem(final FileName rootName, final FileSystemOptions fileSystemOptions)
66 throws FileSystemException {
67 return new HdfsFileSystem(rootName, fileSystemOptions);
68 }
69
70
71
72
73
74
75 @Override
76 public Collection<Capability> getCapabilities() {
77 return CAPABILITIES;
78 }
79
80
81
82
83
84
85
86 @Override
87 public FileSystemConfigBuilder getConfigBuilder() {
88 return HdfsFileSystemConfigBuilder.getInstance();
89 }
90
91 }