/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/fs/ |
H A D | FileUtil.java | 144 if (srcFS == dstFS) { in checkDependencies() 213 if (srcFS.getFileStatus(src).isDir()) { in copy() 224 } else if (srcFS.isFile(src)) { in copy() 228 in = srcFS.open(src); in copy() 240 return srcFS.delete(src, true); in copy() 280 return srcFS.delete(srcDir, true); in copyMerge() 329 if (srcFS.getFileStatus(src).isDir()) { in copy() 335 copy(srcFS, contents[i].getPath(), in copy() 339 } else if (srcFS.isFile(src)) { in copy() 340 InputStream in = srcFS.open(src); in copy() [all …]
|
H A D | FsShell.java | 193 if (copyCrc && !(srcFS instanceof ChecksumFileSystem)) { in copyToLocal() 198 FileStatus[] srcs = srcFS.globStatus(srcpath); in copyToLocal() 207 copyToLocal(srcFS, p, f, copyCrc); in copyToLocal() 238 private void copyToLocal(final FileSystem srcFS, final Path src, in copyToLocal() argument 247 if (!srcFS.getFileStatus(src).isDir()) { in copyToLocal() 256 if (!FileUtil.copy(srcFS, src, tmp, false, srcFS.getConf())) { in copyToLocal() 266 if (!(srcFS instanceof ChecksumFileSystem)) { in copyToLocal() 270 ChecksumFileSystem csfs = (ChecksumFileSystem) srcFS; in copyToLocal() 271 File dstcs = FileSystem.getLocal(srcFS.getConf()) in copyToLocal() 279 for(FileStatus path : srcFS.listStatus(src)) { in copyToLocal() [all …]
|
/dports/net-mgmt/pushgateway/pushgateway-1.4.2/vendor/github.com/shurcooL/httpfs/filter/ |
H A D | filter_test.go | 19 var srcFS http.FileSystem 22 fs := filter.Keep(srcFS, func(path string, fi os.FileInfo) bool { 33 var srcFS http.FileSystem 36 fs := filter.Skip(srcFS, func(path string, fi os.FileInfo) bool { 44 srcFS := httpfs.New(mapfs.New(map[string]string{ 59 fs := filter.Skip(srcFS, func(path string, fi os.FileInfo) bool {
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/shurcooL/httpfs/filter/ |
H A D | filter_test.go | 19 var srcFS http.FileSystem 22 fs := filter.Keep(srcFS, func(path string, fi os.FileInfo) bool { 33 var srcFS http.FileSystem 36 fs := filter.Skip(srcFS, func(path string, fi os.FileInfo) bool { 44 srcFS := httpfs.New(mapfs.New(map[string]string{ 59 fs := filter.Skip(srcFS, func(path string, fi os.FileInfo) bool {
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/shurcooL/httpfs/filter/ |
H A D | filter_test.go | 19 var srcFS http.FileSystem 22 fs := filter.Keep(srcFS, func(path string, fi os.FileInfo) bool { 33 var srcFS http.FileSystem 36 fs := filter.Skip(srcFS, func(path string, fi os.FileInfo) bool { 44 srcFS := httpfs.New(mapfs.New(map[string]string{ 59 fs := filter.Skip(srcFS, func(path string, fi os.FileInfo) bool {
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ |
H A D | FileUtil.java | 270 if (srcFS == dstFS) { in checkDependencies() 350 checkDependencies(srcFS, src, dstFS, dst); in copy() 354 FileStatus contents[] = srcFS.listStatus(src); in copy() 356 copy(srcFS, contents[i], dstFS, in copy() 364 in = srcFS.open(src); in copy() 374 return srcFS.delete(src, true); in copy() 388 if (!srcFS.getFileStatus(srcDir).isDirectory()) in copyMerge() 415 return srcFS.delete(srcDir, true); in copyMerge() 479 copy(srcFS, contents[i], in copy() 484 InputStream in = srcFS.open(src); in copy() [all …]
|
H A D | FileContext.java | 952 AbstractFileSystem srcFS = getFSofPath(absSrc); 954 if(!srcFS.getUri().equals(dstFS.getUri())) { 958 srcFS.rename(absSrc, absDst, options);
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/io/ |
H A D | hdfs_internal.h | 74 int (*hdfsCopy)(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 75 int (*hdfsMove)(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 177 int Copy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 179 int Move(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
H A D | hdfs_internal.cc | 424 int LibHdfsShim::Copy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) { in Copy() argument 427 return this->hdfsCopy(srcFS, src, dstFS, dst); in Copy() 432 int LibHdfsShim::Move(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) { in Move() argument 435 return this->hdfsMove(srcFS, src, dstFS, dst); in Move()
|
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/io/ |
H A D | hdfs_internal.h | 74 int (*hdfsCopy)(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 75 int (*hdfsMove)(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 177 int Copy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 179 int Move(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
H A D | hdfs_internal.cc | 435 int LibHdfsShim::Copy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) { in Copy() argument 438 return this->hdfsCopy(srcFS, src, dstFS, dst); in Copy() 443 int LibHdfsShim::Move(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) { in Move() argument 446 return this->hdfsMove(srcFS, src, dstFS, dst); in Move()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/arrow/io/ |
H A D | hdfs_internal.h | 74 int (*hdfsCopy)(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 75 int (*hdfsMove)(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 177 int Copy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 179 int Move(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
H A D | hdfs_internal.cc | 424 int LibHdfsShim::Copy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) { in Copy() argument 427 return this->hdfsCopy(srcFS, src, dstFS, dst); in Copy() 432 int LibHdfsShim::Move(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) { in Move() argument 435 return this->hdfsMove(srcFS, src, dstFS, dst); in Move()
|
/dports/devel/hadoop/hadoop-1.2.1/src/c++/libhdfs/ |
H A D | hdfs.h | 253 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 264 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
H A D | hdfs.c | 921 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) in hdfsCopy() argument 935 jobject jSrcFS = (jobject)srcFS; in hdfsCopy() 992 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) in hdfsMove() argument 1007 jobject jSrcFS = (jobject)srcFS; in hdfsMove()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/native/libhdfs/ |
H A D | hdfs.h | 567 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 579 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
H A D | hdfs.c | 1664 static int hdfsCopyImpl(hdfsFS srcFS, const char *src, hdfsFS dstFS, in hdfsCopyImpl() argument 1672 jobject jSrcFS = (jobject)srcFS; in hdfsCopyImpl() 1740 int hdfsCopy(hdfsFS srcFS, const char *src, hdfsFS dstFS, const char *dst) in hdfsCopy() argument 1742 return hdfsCopyImpl(srcFS, src, dstFS, dst, 0); in hdfsCopy() 1745 int hdfsMove(hdfsFS srcFS, const char *src, hdfsFS dstFS, const char *dst) in hdfsMove() argument 1747 return hdfsCopyImpl(srcFS, src, dstFS, dst, 1); in hdfsMove()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/thirdparty/hadoop/include/ |
H A D | hdfs.h | 652 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 664 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
/dports/databases/tiledb/TileDB-2.5.2/external/include/hadoop/ |
H A D | hdfs.h | 652 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 664 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
/dports/databases/arrow/apache-arrow-6.0.1/cpp/thirdparty/hadoop/include/ |
H A D | hdfs.h | 652 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 664 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/thirdparty/hadoop/include/ |
H A D | hdfs.h | 652 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst); 664 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst);
|
/dports/security/keybase/client-v5.7.1/go/kbfs/simplefs/ |
H A D | simplefs.go | 1289 srcFS billy.Filesystem, srcFI os.FileInfo, 1303 src, err := srcFS.Open(srcFI.Name()) 1341 srcFS, finalSrcElem, err := k.getFS(ctx, srcPath) 1345 srcFI, err := srcFS.Stat(finalSrcElem) 1397 srcFS, destFS billy.Filesystem member 1425 srcFI, err := srcFS.Stat(finalSrcElem) 1430 chrootFS, err := srcFS.Chroot(srcFI.Name()) 1452 srcFS: srcFS, 1467 srcFI, err := node.srcFS.Stat(node.srcFinalElem) 1481 fis, err := node.srcFS.ReadDir(srcFI.Name()) [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/contrib/libwebhdfs/src/ |
H A D | hdfs_web.c | 1527 int hdfsCopy(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) in hdfsCopy() argument 1533 int hdfsMove(hdfsFS srcFS, const char* src, hdfsFS dstFS, const char* dst) in hdfsMove() argument
|