streams-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (STREAMS-274) Create a YoutubeTypeConverter and serializer
Date Mon, 09 Feb 2015 22:39:42 GMT

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

ASF GitHub Bot commented on STREAMS-274:
----------------------------------------

Github user robdouglas commented on a diff in the pull request:

    https://github.com/apache/incubator-streams/pull/176#discussion_r24372792
  
    --- Diff: streams-contrib/streams-provider-youtube/src/main/java/com/youtube/processor/YoutubeTypeConverter.java
---
    @@ -0,0 +1,110 @@
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one
    + * or more contributor license agreements.  See the NOTICE file
    + * distributed with this work for additional information
    + * regarding copyright ownership.  The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the
    + * "License"); you may not use this file except in compliance
    + *
    + *   http://www.apache.org/licenses/LICENSE-2.0
    + *
    + * Unless required by applicable law or agreed to in writing,
    + * software distributed under the License is distributed on an
    + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
    + * KIND, either express or implied.  See the License for the
    + * specific language governing permissions and limitations
    + * under the License.
    + */
    +
    +package com.youtube.processor;
    +
    +import com.fasterxml.jackson.databind.module.SimpleModule;
    +import com.google.api.services.youtube.model.Video;
    +import com.google.common.collect.Lists;
    +import com.youtube.serializer.YoutubeActivityUtil;
    +import com.youtube.serializer.YoutubeEventClassifier;
    +import com.youtube.serializer.YoutubeVideoDeserializer;
    +import org.apache.streams.core.StreamsDatum;
    +import org.apache.streams.core.StreamsProcessor;
    +import org.apache.streams.jackson.StreamsJacksonMapper;
    +import org.apache.streams.pojo.json.Activity;
    +import org.slf4j.Logger;
    +import org.slf4j.LoggerFactory;
    +
    +import java.util.List;
    +import java.util.Queue;
    +
    +public class YoutubeTypeConverter implements StreamsProcessor {
    +    public final static String STREAMS_ID = "YoutubeTypeConverter";
    +
    +    private final static Logger LOGGER = LoggerFactory.getLogger(YoutubeTypeConverter.class);
    +    private StreamsJacksonMapper mapper;
    +    private Queue<Video> inQueue;
    +    private Queue<StreamsDatum> outQueue;
    +    private YoutubeActivityUtil youtubeActivityUtil;
    +    private int count = 0;
    +
    +    public YoutubeTypeConverter() {}
    +
    +
    +    @Override
    +    public List<StreamsDatum> process(StreamsDatum streamsDatum) {
    +        StreamsDatum result = null;
    +
    +        try {
    +            Object item = streamsDatum.getDocument();
    +
    +            LOGGER.debug("{} processing {}", STREAMS_ID, item.getClass());
    +            Activity activity = null;
    +
    +            if(item instanceof String) {
    +                item = deserializeItem(item);
    +            }
    +
    +            if(item instanceof Video) {
    +                activity = new Activity();
    +                youtubeActivityUtil.updateActivity((Video)item, activity, streamsDatum.getId());
    +            }
    +
    +            if(activity != null) {
    +                result = new StreamsDatum(activity);
    +                count++;
    +            }
    +        } catch (Exception e) {
    +            e.printStackTrace();
    --- End diff --
    
    Will change


> Create a YoutubeTypeConverter and serializer
> --------------------------------------------
>
>                 Key: STREAMS-274
>                 URL: https://issues.apache.org/jira/browse/STREAMS-274
>             Project: Streams
>          Issue Type: Task
>            Reporter: Robert Douglas
>
> As a Streams user, I should be able to convert valid Youtube Video objects into usable
Activity Streams.



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

Mime
View raw message