public class HDFSSession extends Object
Constructor and Description |
---|
HDFSSession(String nameNode,
String user) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
createFile(org.apache.hadoop.fs.Path path,
InputStream input) |
void |
deleteFile(org.apache.hadoop.fs.Path path) |
Map<String,String> |
getRepositoryInfo() |
URI |
getUri() |
public HDFSSession(String nameNode, String user) throws URISyntaxException, IOException, InterruptedException
public void deleteFile(org.apache.hadoop.fs.Path path) throws IOException
IOException
public void createFile(org.apache.hadoop.fs.Path path, InputStream input) throws IOException
IOException
public URI getUri()
public void close() throws IOException
IOException