在hadoop中使用reducer类

jhkqcmku  于 2021-06-02  发布在  Hadoop
关注(0)|答案(1)|浏览(367)

这个问题在这里已经有答案了

如何比较java中的字符串(23个答案)
5年前关门了。
我正在做一个Map缩小的工作。
问题是比较不能正常工作。
如何比较这些字符串?

public void reduce(Text key, Iterable<Text> values,
        Context context) throws IOException, InterruptedException {

    int numItems1 = 0;

    for (Text val1 : values) {
        if(val1.toString()  == "view")   /// if not working
        {
            numItems1 = numItems1+1;
            numItems2 = 0;
            numItems3 = 0;
            result1.set( numItems1 );
            // val1.set(   result1 + "," + numItems2 + "," +   numItems3  );
        }
    }

    val1.set(result1 + ",");
    context.write(key,val1);
}
iqih9akk

iqih9akk1#

正如copeg所说,它既不依赖hadoop,也不依赖reducer。问题来自你的比较。在java中,应该使用
val1.tostring().equals(“视图”)

相关问题