public class HDFSSession extends Object
Constructor and Description |
---|
HDFSSession(String nameNode,
String user) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.fs.FSDataInputStream |
getFSDataInputStream(org.apache.hadoop.fs.Path path) |
org.apache.hadoop.fs.FileStatus |
getObject(org.apache.hadoop.fs.Path path) |
Map<String,String> |
getRepositoryInfo() |
URI |
getUri() |
org.apache.hadoop.fs.FileStatus[] |
listStatus(org.apache.hadoop.fs.Path path) |
static void |
runMe() |
public HDFSSession(String nameNode, String user) throws URISyntaxException, IOException, InterruptedException
public static void runMe()
public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path path) throws IOException
IOException
public URI getUri()
public org.apache.hadoop.fs.FileStatus getObject(org.apache.hadoop.fs.Path path) throws IOException
IOException
public org.apache.hadoop.fs.FSDataInputStream getFSDataInputStream(org.apache.hadoop.fs.Path path) throws IOException
IOException
public void close() throws IOException
IOException