小编Sri*_*ahu的帖子

我在 HDFS 中有一些数据/user/Cloudera/Test/*。我非常能够通过运行来查看记录hdfs -dfs -cat Test/*。

现在同一个文件，我需要在 scala 中将其读取为 RDD。我在 scala shell 中尝试了以下操作。

val file = sc.textFile("hdfs://quickstart.cloudera:8020/user/Cloudera/Test")

然后我编写了一些过滤器和 for 循环来读取单词。但是当我最后使用时Println，它说找不到文件。

谁能帮我知道在这种情况下 HDFS url 是什么。注意：我使用的是Cloudera CDH5.0 VM

我有一个DbSet,我已经嘲笑和暴露.我把一些部门填满了上下文.当我访问这些部门时,我得到null.

    private Mock<DbSet<Department>> departmentSet;
    private Mock<DemoEntities> context;

    [TestInitializeAttribute()]
    public void TestInit()
    {
        context = new Mock<DemoEntities>();
        departmentSet = new Mock<DbSet<Department>>();
        context.Setup(c => c.Departments).Returns(departmentSet.Object);
        context.Object.Departments.Add(new Department() { Name = "HR", Id = 1 });
        context.Object.Departments.Add(new Department() { Name = "Operations", Id = 2 });


        context.Object.SaveChanges();

        var list = context.Object.Departments; //returns null
     }

任何人都可以让我知道我做错了什么.其他测试用例依赖于访问context.Object.Departments.