问答详情
源自:6-1 项目实战-监控维基百科的编辑日志

cannot resolve symbol f0,f1

DataStream<Tuple2<String, Long>> result = keyedEdits
        .timeWindow(Time.seconds(5))  //指定窗口的宽度为5秒
        .fold(new Tuple2<>("", 0L), new FoldFunction<WikipediaEditEvent, Tuple2<String, Long>>() {
            @Override
            public Tuple2<String, Long> fold(Tuple2<String, Long> acc, WikipediaEditEvent o) throws Exception {
                acc.f0 = o.getUser();
                acc.f1 += o.getByteDiff();
                return acc;
            }
        });


提问者:一丢丢的小罪恶 2019-02-13 19:29

个回答

  • 大数据技术与架构
    2019-02-18 19:30:10

    你好,我才看到你的留言。这个问题比较可能是因为:你这个类中import的是不是StreamExecutionEnvironment,或者看看Tuple2是不是引用对了。