HomeSort by relevance Sort by last modified time
    Searched refs:hdfs (Results 1 - 3 of 3) sorted by null

  /external/tensorflow/tensorflow/core/platform/hadoop/
hadoop_file_system_test.cc 42 TF_RETURN_IF_ERROR(hdfs.NewWritableFile(fname, &writer));
50 TF_RETURN_IF_ERROR(hdfs.NewRandomAccessFile(fname, &reader));
53 TF_RETURN_IF_ERROR(hdfs.GetFileSize(fname, &file_size));
66 HadoopFileSystem hdfs; member in class:tensorflow::__anon40097::HadoopFileSystemTest
75 TF_EXPECT_OK(hdfs.NewRandomAccessFile(fname, &reader));
95 TF_EXPECT_OK(hdfs.NewWritableFile(fname, &writer));
109 EXPECT_EQ(error::Code::NOT_FOUND, hdfs.FileExists(fname).code());
111 TF_EXPECT_OK(hdfs.FileExists(fname));
116 TF_EXPECT_OK(hdfs.CreateDir(base));
121 TF_EXPECT_OK(hdfs.CreateDir(subdir))
    [all...]
hadoop_file_system.cc 28 #include "third_party/hadoop/hdfs.h"
110 const char* kLibHdfsDso = "hdfs.dll";
137 // We rely on HDFS connection caching here. The HDFS client calls
162 // https://github.com/tensorflow/tensorflow/blob/v1.0.0/third_party/hadoop/hdfs.h#L259
190 LibHDFS* hdfs, hdfsFS fs, hdfsFile file)
193 hdfs_(hdfs),
222 // reading, HDFS requires that we reopen the file to see updated
274 HDFSWritableFile(const string& fname, LibHDFS* hdfs, hdfsFS fs, hdfsFile file)
275 : filename_(fname), hdfs_(hdfs), fs_(fs), file_(file) {
    [all...]
  /external/fio/engines/
libhdfs.c 4 * this engine helps perform read/write operations on hdfs cluster using
5 * libhdfs. hdfs doesnot support modification of data once file is created.
15 #include <hdfs.h>
46 .help = "Namenode of the HDFS cluster",
56 .help = "Namenode of the HDFS cluster",
62 .lname = "hdfs namenode port",
68 .help = "Port used by the HDFS cluster namenode",
78 .help = "The HDFS directory where fio will create chuncks",
105 .lname = "HDFS Use Direct",
141 log_err("hdfs: unable to close file: %s\n", strerror(errno))
    [all...]

Completed in 72 milliseconds