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/11/21 20:35:13 UTC
[6/9] incubator-streams git commit: useful to have this metadata
downstream
useful to have this metadata downstream
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/069969d7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/069969d7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/069969d7
Branch: refs/heads/STREAMS-222
Commit: 069969d7f9496fbadc18a847648eead27396518e
Parents: 1987427
Author: sblackmon <sb...@apache.org>
Authored: Thu Nov 20 17:19:39 2014 -0600
Committer: sblackmon <sb...@apache.org>
Committed: Thu Nov 20 17:19:39 2014 -0600
----------------------------------------------------------------------
.../streams/datasift/provider/DatasiftPushProvider.java | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/069969d7/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftPushProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftPushProvider.java b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftPushProvider.java
index 4d5bff3..a363cb1 100644
--- a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftPushProvider.java
+++ b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftPushProvider.java
@@ -29,6 +29,7 @@ import com.google.common.collect.Maps;
import com.google.common.collect.Queues;
import org.apache.streams.core.StreamsDatum;
import org.apache.streams.core.StreamsProvider;
+import org.apache.streams.core.StreamsResource;
import org.apache.streams.core.StreamsResultSet;
import org.apache.streams.datasift.Datasift;
import org.apache.streams.datasift.DatasiftConfiguration;
@@ -66,7 +67,7 @@ import java.util.regex.Pattern;
@Path("/streams/webhooks/datasift")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
-public class DatasiftPushProvider implements StreamsProvider {
+public class DatasiftPushProvider implements StreamsProvider, StreamsResource {
private final static Logger LOGGER = LoggerFactory.getLogger(DatasiftPushProvider.class);
@@ -183,14 +184,14 @@ public class DatasiftPushProvider implements StreamsProvider {
datum.setTimestamp(item.getInteraction().getCreatedAt());
}
Map<String, Object> metadata = Maps.newHashMap();
- metadata.put("datasift.hash", objectWrapper.getHash());
- metadata.put("datasift.hashType", objectWrapper.getHashType());
- metadata.put("datasift.id",objectWrapper.getId());
+ metadata.put("hash", objectWrapper.getHash());
+ metadata.put("hashType", objectWrapper.getHashType());
+ metadata.put("id",objectWrapper.getId());
if( item.getInteraction() != null &&
item.getInteraction().getTags() != null &&
item.getInteraction().getTags().size() > 0) {
- metadata.put("datasift.interaction.tags", item.getInteraction().getTags());
+ metadata.put("tags", item.getInteraction().getTags());
}
datum.setMetadata(metadata);