Home
last modified time | relevance | path

Searched refs:HdfsEnv (Results 1 – 8 of 8) sorted by relevance

/rocksdb-6.9/env/
Denv_hdfs.cc387 const std::string HdfsEnv::kProto = "hdfs://";
388 const std::string HdfsEnv::pathsep = "/";
449 Status HdfsEnv::NewDirectory(const std::string& name, in NewDirectory()
464 Status HdfsEnv::FileExists(const std::string& fname) { in FileExists()
478 Status HdfsEnv::GetChildren(const std::string& path, in GetChildren()
515 Status HdfsEnv::DeleteFile(const std::string& fname) { in DeleteFile()
522 Status HdfsEnv::CreateDir(const std::string& name) { in CreateDir()
544 Status HdfsEnv::DeleteDir(const std::string& name) { in DeleteDir()
591 Status HdfsEnv::NewLogger(const std::string& fname, in NewLogger()
604 HdfsLogger* h = new HdfsLogger(f, &HdfsEnv::gettid); in NewLogger()
[all …]
/rocksdb-6.9/hdfs/
Denv_hdfs.h44 class HdfsEnv : public Env {
47 explicit HdfsEnv(const std::string& fsname) : fsname_(fsname) { in HdfsEnv() function
52 virtual ~HdfsEnv() { in ~HdfsEnv()
168 uint64_t GetThreadID() const override { return HdfsEnv::gettid(); } in GetThreadID()
241 class HdfsEnv : public Env {
244 explicit HdfsEnv(const std::string& /*fsname*/) { in HdfsEnv() function
250 virtual ~HdfsEnv() { in ~HdfsEnv()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DHdfsEnv.java11 public class HdfsEnv extends Env { class
21 public HdfsEnv(final String fsName) { in HdfsEnv() method in HdfsEnv
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DHdfsEnvTest.java27 try (final Env env = new HdfsEnv("hdfs://localhost:5000")) { in construct()
35 try (final Env env = new HdfsEnv("hdfs://localhost:5000"); in construct_integration()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_tool.cc62 raw_env = new ROCKSDB_NAMESPACE::HdfsEnv(FLAGS_hdfs); in db_stress_tool()
/rocksdb-6.9/java/
DCMakeLists.txt144 src/main/java/org/rocksdb/HdfsEnv.java
418 org.rocksdb.HdfsEnv
DMakefile37 org.rocksdb.HdfsEnv\
/rocksdb-6.9/tools/
Ddb_bench_tool.cc7023 FLAGS_env = new ROCKSDB_NAMESPACE::HdfsEnv(FLAGS_hdfs); in db_bench_tool()