Home
last modified time | relevance | path

Searched refs:srcFS (Results 1 – 23 of 23) sorted by relevance

/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/fs/
H A DFileUtil.java144 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 DFsShell.java193 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 Dfilter_test.go19 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 Dfilter_test.go19 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 Dfilter_test.go19 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 DFileUtil.java270 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 DFileContext.java952 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 Dhdfs_internal.h74 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 Dhdfs_internal.cc424 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 Dhdfs_internal.h74 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 Dhdfs_internal.cc435 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 Dhdfs_internal.h74 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 Dhdfs_internal.cc424 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 Dhdfs.h253 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 Dhdfs.c921 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 Dhdfs.h567 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 Dhdfs.c1664 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 Dhdfs.h652 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 Dhdfs.h652 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 Dhdfs.h652 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 Dhdfs.h652 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 Dsimplefs.go1289 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 Dhdfs_web.c1527 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