[ 
https://issues.apache.org/jira/browse/STREAMS-95?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15304801#comment-15304801
 ] 

Joey Frazee commented on STREAMS-95:
------------------------------------

Is this still valid? createStreamsDatum() looks like it's using the id from the 
user object:  
https://github.com/apache/incubator-streams/blob/c7490d3b621429df235b6280f7b86837623ab80c/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterProfileProcessor.java#L77

> TwitterProfileProcessor needs to send a user ID in each StreamsDatum
> --------------------------------------------------------------------
>
>                 Key: STREAMS-95
>                 URL: https://issues.apache.org/jira/browse/STREAMS-95
>             Project: Streams
>          Issue Type: Task
>            Reporter: Robert Douglas
>   Original Estimate: 10m
>  Remaining Estimate: 10m
>
> When the TwitterProfileProcessor encounters a Retweet or User object, it 
> creates a new StreamsDatum that consists only of that user. The created 
> StreamsDatum needs to also have that user's unique identifier (passed in via 
> the constructor) so that we don't end up with duplicates down the stream



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to