String webhdfsAuth = getConfiguration().get(
DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY);
DatasetRepository repo = DatasetRepositories
.repositoryFor("repo:webhdfs://" + webhdfsAuth + "/tmp/data");
repo.delete("ns", "test");
repo.create("ns", "test", descriptor);
Dataset<Object> ds = Datasets.<Object, Dataset<Object>>
load("dataset:webhdfs://" + webhdfsAuth + "/tmp/data/ns/test", Object.class);
Assert.assertNotNull("Should load dataset", ds);