You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/07/21 17:45:02 UTC
[16/47] git commit: STREAMS-105 | Code review feedback
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 <rd...@w2odigital.com>
Authored: Wed Jul 2 10:11:16 2014 -0500
Committer: Robert Douglas <rd...@w2odigital.com>
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);
}