Java 类org.apache.hadoop.fs.kfs.KosmosFileSystem 实例源码

项目：hadoop-EAR 文件：TestKosmosFileSystem.java

@Override
protected void setUp() throws IOException {
    Configuration conf = new Configuration();

    kfsEmul = new KFSEmulationImpl(conf);
    kosmosFileSystem = new KosmosFileSystem(kfsEmul);
    // a dummy URI; we are not connecting to any setup here
    kosmosFileSystem.initialize(URI.create("kfs:///"), conf);
    baseDir = new Path(System.getProperty("test.build.data", "/tmp" ) +
                                          "/kfs-test");
}

项目：hadoop-on-lustre 文件：TestKosmosFileSystem.java

@Override
protected void setUp() throws IOException {
    Configuration conf = new Configuration();

    kfsEmul = new KFSEmulationImpl(conf);
    kosmosFileSystem = new KosmosFileSystem(kfsEmul);
    // a dummy URI; we are not connecting to any setup here
    kosmosFileSystem.initialize(URI.create("kfs:///"), conf);
    baseDir = new Path(System.getProperty("test.build.data", "/tmp" ) +
                                          "/kfs-test");
}

项目：RDFS 文件：TestKosmosFileSystem.java

@Override
protected void setUp() throws IOException {
    Configuration conf = new Configuration();

    kfsEmul = new KFSEmulationImpl(conf);
    kosmosFileSystem = new KosmosFileSystem(kfsEmul);
    // a dummy URI; we are not connecting to any setup here
    kosmosFileSystem.initialize(URI.create("kfs:///"), conf);
    baseDir = new Path(System.getProperty("test.build.data", "/tmp" ) +
                                          "/kfs-test");
}

项目：hadoop-0.20 文件：TestKosmosFileSystem.java

@Override
protected void setUp() throws IOException {
    Configuration conf = new Configuration();

    kfsEmul = new KFSEmulationImpl(conf);
    kosmosFileSystem = new KosmosFileSystem(kfsEmul);
    // a dummy URI; we are not connecting to any setup here
    kosmosFileSystem.initialize(URI.create("kfs:///"), conf);
    baseDir = new Path(System.getProperty("test.build.data", "/tmp" ) +
                                          "/kfs-test");
}

项目：hortonworks-extension 文件：TestKosmosFileSystem.java

@Override
protected void setUp() throws IOException {
    Configuration conf = new Configuration();

    kfsEmul = new KFSEmulationImpl(conf);
    kosmosFileSystem = new KosmosFileSystem(kfsEmul);
    // a dummy URI; we are not connecting to any setup here
    kosmosFileSystem.initialize(URI.create("kfs:///"), conf);
    baseDir = new Path(System.getProperty("test.build.data", "/tmp" ) +
                                          "/kfs-test");
}

项目：hortonworks-extension 文件：TestKosmosFileSystem.java

@Override
protected void setUp() throws IOException {
    Configuration conf = new Configuration();

    kfsEmul = new KFSEmulationImpl(conf);
    kosmosFileSystem = new KosmosFileSystem(kfsEmul);
    // a dummy URI; we are not connecting to any setup here
    kosmosFileSystem.initialize(URI.create("kfs:///"), conf);
    baseDir = new Path(System.getProperty("test.build.data", "/tmp" ) +
                                          "/kfs-test");
}

项目：hadoop-gpu 文件：TestKosmosFileSystem.java

@Override
protected void setUp() throws IOException {
    Configuration conf = new Configuration();

    kfsEmul = new KFSEmulationImpl(conf);
    kosmosFileSystem = new KosmosFileSystem(kfsEmul);
    // a dummy URI; we are not connecting to any setup here
    kosmosFileSystem.initialize(URI.create("kfs:///"), conf);
    baseDir = new Path(System.getProperty("test.build.data", "/tmp" ) +
                                          "/kfs-test");
}