Home
last modified time | relevance | path

Searched refs:hdfsWrite (Results 1 – 25 of 48) sorted by relevance

12

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/native/libhdfs/test/
H A Dtest_libhdfs_ops.c113 hdfsWrite(fs, writeFile, (void*)fileContents, in main()
239 num_written_bytes = hdfsWrite(lfs, localFile, (void*)fileContents, in main()
424 num_written_bytes = hdfsWrite(fs, appendFile, (void*)buffer3, in main()
445 num_written_bytes = hdfsWrite(fs, appendFile, (void*)buffer3, in main()
503 num_written_bytes = hdfsWrite(fs, userFile, (void*)fileContents, in main()
H A Dtest_libhdfs_write.c83 if ((written = hdfsWrite(fs, writeFile, (void*)buffer, curSize)) != curSize) { in main()
/dports/devel/hadoop/hadoop-1.2.1/src/c++/libhdfs/
H A Dhdfs_test.c80 tSize num_written_bytes = hdfsWrite(fs, writeFile, (void*)buffer, strlen(buffer)+1); in main()
333 tSize num_written_bytes = hdfsWrite(fs, writeFile, (void*)buffer, strlen(buffer)); in main()
353 num_written_bytes = hdfsWrite(fs, writeFile, (void*)buffer, strlen(buffer) + 1); in main()
415 tSize num_written_bytes = hdfsWrite(fs, writeFile, (void*)buffer, strlen(buffer)+1); in main()
H A Dhdfs_write.c58 hdfsWrite(fs, writeFile, (void*)buffer, curSize); in main()
H A Dhdfs.h222 tSize hdfsWrite(hdfsFS fs, hdfsFile file, const void* buffer,
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/contrib/libwebhdfs/src/
H A Dtest_libwebhdfs_ops.c104 num_written_bytes = hdfsWrite(fs, writeFile, (void*)fileContents, in main()
423 num_written_bytes = hdfsWrite(fs, writeFile, helloBuffer, in main()
443 num_written_bytes = hdfsWrite(fs, writeFile, helloBuffer, in main()
511 num_written_bytes = hdfsWrite(fs, writeFile, fileContents, in main()
H A Dtest_libwebhdfs_write.c97 written = hdfsWrite(fs, writeFile, (void*)buffer, toWrite); in main()
/dports/misc/vxl/vxl-3.3.2/contrib/brl/bbas/bhdfs/tests/
H A Dtest_hadoop.cxx37 tSize num_written_bytes = hdfsWrite(fs, writeFile, (void*)buffer2.c_str(), buffer2.length()); in test_hadoop()
/dports/benchmarks/fio/fio-3.29/engines/
H A Dlibhdfs.c193 ret = hdfsWrite(hd->fs, hd->fp, io_u->xfer_buf, in fio_hdfsio_queue()
277 if( hdfsWrite(hd->fs, fp, buffer, CHUNCK_CREATION_BUFFER_SIZE) in fio_hdfsio_io_u_init()
286 if( hdfsWrite(hd->fs, fp, buffer, bytes_left) in fio_hdfsio_io_u_init()
/dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/filesystem/
H A Dhdfs_filesystem.cc132 std::function<tSize(hdfsFS, hdfsFile, const void*, tSize)> hdfsWrite; member in tiledb::sm::hdfs::LibHDFS
163 BIND_HDFS_FUNC(hdfsWrite); in load_and_bind()
461 tSize bytes_written = libhdfs_->hdfsWrite( in write()
475 tSize bytes_written = libhdfs_->hdfsWrite( in write()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/native/fuse-dfs/
H A Dfuse_impls_write.c60 length = hdfsWrite(fs, file_handle, buf, size); in dfs_write()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/fuse-dfs/src/
H A Dfuse_impls_write.c58 length = hdfsWrite(fh->fs, file_handle, buf, size); in dfs_write()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/io/
H A Dhdfs_internal.h71 tSize (*hdfsWrite)(hdfsFS fs, hdfsFile file, const void* buffer, tSize length); member
112 this->hdfsWrite = nullptr; in Initialize()
H A Dhdfs_internal.cc309 GET_SYMBOL_REQUIRED(this, hdfsWrite); in GetRequiredSymbols()
411 return this->hdfsWrite(fs, file, buffer, length); in Write()
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/io/
H A Dhdfs_internal.h71 tSize (*hdfsWrite)(hdfsFS fs, hdfsFile file, const void* buffer, tSize length); member
112 this->hdfsWrite = nullptr; in Initialize()
H A Dhdfs_internal.cc320 GET_SYMBOL_REQUIRED(this, hdfsWrite); in GetRequiredSymbols()
422 return this->hdfsWrite(fs, file, buffer, length); in Write()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/arrow/io/
H A Dhdfs_internal.h71 tSize (*hdfsWrite)(hdfsFS fs, hdfsFile file, const void* buffer, tSize length); member
112 this->hdfsWrite = nullptr; in Initialize()
H A Dhdfs_internal.cc309 GET_SYMBOL_REQUIRED(this, hdfsWrite); in GetRequiredSymbols()
411 return this->hdfsWrite(fs, file, buffer, length); in Write()
/dports/misc/vxl/vxl-3.3.2/contrib/brl/bbas/bhdfs/
H A Dbhdfs_fstream.cxx56 tSize num_written_bytes = hdfsWrite(bhdfs_manager::instance()->fs_, f_, buf, n); in write()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestMiniMRWithDFS.java269 long hdfsWrite = in runWordCount() local
274 assertEquals(result.output.length(), hdfsWrite); in runWordCount() local
/dports/misc/py-tvm/incubator-tvm-0.6.1/3rdparty/dmlc-core/src/io/
H A Dhdfs_filesys.cc54 tSize nwrite = hdfsWrite(fs_, fp_, buf, size); in Write()
/dports/devel/dmlc-core/dmlc-core-0.3-123-gb3a4c71/src/io/
H A Dhdfs_filesys.cc54 tSize nwrite = hdfsWrite(fs_, fp_, buf, size); in Write()
/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/env/
H A Denv_hdfs.cc232 size_t ret = hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(left)); in Append()
262 if (hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(size)) != in Append()
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/env/
H A Denv_hdfs.cc232 size_t ret = hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(left)); in Append()
262 if (hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(size)) != in Append()
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/env/
H A Denv_hdfs.cc232 size_t ret = hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(left)); in Append()
262 if (hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(size)) != in Append()

12