java - 如何在Hadoop映射器中将String转换为Writable对象

几个小时以来，这是一个非常疯狂的问题。

任何帮助将不胜感激。

我不能

public void map(Object key, Text value, Context context) throws IOException, InterruptedException {
      if (!value.toString().equals("")) {



          Gson gson = new Gson();
          Boolean flag = true;
          System.out.println("000000000");
          while(flag){
              Text tweetId = new Text();
              Tweet tweet = gson.fromJson(value.toString(), Tweet.class);
              tweetId.set(tweet.getRetweetStatus().getUser().getId().toString());
              System.out.println("Tweet objects:" + tweet.toString());
              System.out.println("ParentUserId:" + tweetId);
              context.write(tweetId, tweet);
              flag = false;
          }
          Text tweetId = new Text();
          Tweet tweet = gson.fromJson(value.toString(), Tweet.class);
          tweetId.set(tweet.getUser().getId().toString());
          String tweetReverse = (Object) tweet.getRetweetStatus().getUser().getId();

          System.out.println("Reverse::");
          System.out.println("Tweet objects:" + tweetReverse);
          System.out.println("ParentUserId:" + tweetId);

          context.write(tweetId, tweetReverse);
      }
    }

我想将String对象'tweetReverse'转换为Writable，以便可以使用context.write函数。

这有可能吗？

如果不转换怎么办？

如果将通用类型更改为String，那么在将Writable扩展为读写值的类中也会遇到问题。

任何帮助将不胜感激。

非常感谢。

最佳答案

我觉得您只需要

context.write(tweetId, new Text(tweetReverse));

也就是说，您只需创建一个新的Text对象(实现Writable)，然后在构造函数中传递一个String。