STREAMS-105 | Code review feedback
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/26f3614f Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/26f3614f Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/26f3614f Branch: refs/heads/STREAMS-46 Commit: 26f3614fd7d72be4526fc9589e75dfb32dda6588 Parents: 949b676 Author: Robert Douglas <[email protected]> Authored: Wed Jul 2 10:11:16 2014 -0500 Committer: Robert Douglas <[email protected]> Committed: Wed Jul 2 10:11:16 2014 -0500 ---------------------------------------------------------------------- .../datasift/serializer/DatasiftDefaultActivitySerializer.java | 2 +- .../datasift/serializer/DatasiftTweetActivitySerializer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/26f3614f/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftDefaultActivitySerializer.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftDefaultActivitySerializer.java b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftDefaultActivitySerializer.java index 09126dc..4095df6 100644 --- a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftDefaultActivitySerializer.java +++ b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftDefaultActivitySerializer.java @@ -174,7 +174,7 @@ public class DatasiftDefaultActivitySerializer implements ActivitySerializer<Dat ActivityObject actObj = new ActivityObject(); actObj.setObjectType(interaction.getContenttype()); actObj.setUrl(interaction.getLink()); - actObj.setId(interaction.getId()); + actObj.setId(formatId("post",interaction.getId())); actObj.setContent(interaction.getContent()); return actObj; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/26f3614f/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftTweetActivitySerializer.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftTweetActivitySerializer.java b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftTweetActivitySerializer.java index 1fecc4b..0482235 100644 --- a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftTweetActivitySerializer.java +++ b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/serializer/DatasiftTweetActivitySerializer.java @@ -165,7 +165,7 @@ public class DatasiftTweetActivitySerializer extends DatasiftDefaultActivitySeri double[] coordiantes = new double[] { twitter.getGeo().getLongitude(), twitter.getGeo().getLatitude() }; Map<String, Object> coords = Maps.newHashMap(); coords.put("coordinates", coordiantes); - coords.put("type", "geo_point"); + coords.put("type", "point"); location.put("coordinates", coords); extensions.put("location", location); }
