updateStateByKey报错is not applicable for the arguments

首页 » Spark » updateStateByKey报错is not applicable for the arguments
JavaPairDStream<String,Integer> counts=pairword.updateStateByKey(new Function2<List<Integer>, Optional<Integer>, Optional<Integer>>() {
  @Override
  public Optional<Integer> call(List<Integer> values, Optional<Integer> state) throws Exception {
   // TODO Auto-generated method stub
   // TODO Auto-generated method stub
      /*
       * values:经过分组最后这个key所对应的value【1,1,1,1,1】
       * state:这个key在本次之前的状态
       */
      Integer update=0;
      if(state.isPresent()) {
       //判断state上一次是否有值
       update=state.get();
      }
      for(Integer value : values) {
       //累加
       update+=value;
      }
      return Optional.of(update);
  }

 });

updateStateByKey报错is not applicable for the arguments

解决办法:可能是Optional导错包了,应该导

import com.google.common.base.Optional;

updateStateByKey报错is not applicable for the arguments
分享到:
赞(0) 打赏

评论 2

评论前必须登录!

 

  1. #1

    以后多发点哦

    我也是渣渣6个月前 (04-06)
  2. #2

    给你点赞

    我是你哥6个月前 (04-06)

觉得文章有用就打赏一下弟弟吧

支付宝扫一扫打赏

微信扫一扫打赏

Vieu4.5主题
专业打造轻量级个人企业风格博客主题!专注于前端开发,全站响应式布局自适应模板。
正在播放:

作者想对您说:

累了就停下来听首歌吧

听完后会给您一个好心情

最后

等到您不容易

还希望您能多待一会儿

      00:00/00:00