streams-contrib/streams-processor-peoplepattern/src/main/java/org/apache/streams/peoplepattern/AccountTypeProcessor.java [70:80]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected Map<String, String> prepareParams(StreamsDatum entry) {
    Activity activity = mapper.convertValue(entry.getDocument(), Activity.class);
    ActivityObject actor = mapper.convertValue(activity.getActor(), ActivityObject.class);
    String username = (String) ExtensionUtil.getInstance().getExtension(actor, "screenName");
    Map<String, String> params = new HashMap<>();
    params.put("id", actor.getId());
    params.put("name", actor.getDisplayName());
    params.put("username", username);
    params.put("description", actor.getSummary());
    return params;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



streams-contrib/streams-processor-peoplepattern/src/main/java/org/apache/streams/peoplepattern/DemographicsProcessor.java [70:80]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected Map<String, String> prepareParams(StreamsDatum entry) {
    Activity activity = mapper.convertValue(entry.getDocument(), Activity.class);
    ActivityObject actor = mapper.convertValue(activity.getActor(), ActivityObject.class);
    String username = (String) ExtensionUtil.getInstance().getExtension(actor, "screenName");
    Map<String, String> params = new HashMap<>();
    params.put("id", actor.getId());
    params.put("name", actor.getDisplayName());
    params.put("username", username);
    params.put("description", actor.getSummary());
    return params;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -