import org.apache.streams.pojo.json.Activity; //导入依赖的package包/类
@Override
public List<StreamsDatum> process(StreamsDatum entry) {

  MatcherAssert.assertThat(entry.getDocument(), IsInstanceOf.instanceOf(Activity.class));
  String id = entry.getId();
  // replace delete with post in id
  // ensure ElasticsearchPersistDeleter will remove original post if present
  id = StringUtils.replace(id, "delete", "post");
  entry.setId(id);

  return Stream.of(entry).collect(Collectors.toList());
}