public class $Hdfs extends $Hadoop
| Constructor and Description |
|---|
$Hdfs() |
| Modifier and Type | Method and Description |
|---|---|
com.ailbb.ajj.entity.$Result |
deletePath(String path) |
com.ailbb.ajj.entity.$Result |
deletePath(String path,
boolean recursive) |
com.ailbb.ajj.entity.$Result |
downloadFile(String path,
String descPath,
boolean overwrite) |
org.apache.hadoop.conf.Configuration |
getConf() |
org.apache.hadoop.fs.FileSystem |
getFileSystem() |
List<String> |
getNameSpace(String path) |
long |
getTryTimeOut() |
$Hdfs |
init($Kerberos kerberos) |
$Hdfs |
init(org.apache.hadoop.conf.Configuration conf) |
$Hdfs |
setConf(org.apache.hadoop.conf.Configuration conf) |
$Hdfs |
setFileSystem(org.apache.hadoop.fs.FileSystem fileSystem) |
void |
setTryTimeOut(long tryTimeOut) |
com.ailbb.ajj.entity.$Result |
uploadFile(String path,
String descPath) |
com.ailbb.ajj.entity.$Result |
uploadFile(String path,
String descPath,
boolean overwrite) |
getKerberos, run, setKerberospublic $Hdfs init(org.apache.hadoop.conf.Configuration conf) throws Exception
Exceptionpublic com.ailbb.ajj.entity.$Result deletePath(String path, boolean recursive)
public com.ailbb.ajj.entity.$Result deletePath(String path)
public com.ailbb.ajj.entity.$Result uploadFile(String path, String descPath, boolean overwrite)
public com.ailbb.ajj.entity.$Result downloadFile(String path, String descPath, boolean overwrite)
public org.apache.hadoop.fs.FileSystem getFileSystem()
throws Exception
Exceptionpublic $Hdfs setFileSystem(org.apache.hadoop.fs.FileSystem fileSystem)
public org.apache.hadoop.conf.Configuration getConf()
public $Hdfs setConf(org.apache.hadoop.conf.Configuration conf)
public long getTryTimeOut()
public void setTryTimeOut(long tryTimeOut)
Copyright © 2021. All rights reserved.