Return-Path: X-Original-To: apmail-streams-commits-archive@minotaur.apache.org Delivered-To: apmail-streams-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2E4A9175EC for ; Fri, 7 Nov 2014 21:04:51 +0000 (UTC) Received: (qmail 35995 invoked by uid 500); 7 Nov 2014 21:04:51 -0000 Delivered-To: apmail-streams-commits-archive@streams.apache.org Received: (qmail 35974 invoked by uid 500); 7 Nov 2014 21:04:51 -0000 Mailing-List: contact commits-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list commits@streams.incubator.apache.org Received: (qmail 35965 invoked by uid 99); 7 Nov 2014 21:04:51 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Nov 2014 21:04:51 +0000 X-ASF-Spam-Status: No, hits=-2000.6 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Fri, 07 Nov 2014 21:04:49 +0000 Received: (qmail 32908 invoked by uid 99); 7 Nov 2014 21:04:29 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Nov 2014 21:04:29 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 0EAC399DA0E; Fri, 7 Nov 2014 21:04:29 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: rebanks@apache.org To: commits@streams.incubator.apache.org Date: Fri, 07 Nov 2014 21:04:29 -0000 Message-Id: <0714c4e9618540f0921105f6f20b682d@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [3/5] incubator-streams git commit: Added some java docs X-Virus-Checked: Checked by ClamAV on apache.org Added some java docs Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/ff6cb52d Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/ff6cb52d Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/ff6cb52d Branch: refs/heads/master Commit: ff6cb52d90908d7be22c2d3439e00a682981e242 Parents: 4e0e9da Author: Ryan Ebanks Authored: Thu Nov 6 22:39:04 2014 -0600 Committer: Ryan Ebanks Committed: Thu Nov 6 22:39:04 2014 -0600 ---------------------------------------------------------------------- .../java/com/google/gplus/provider/AbstractGPlusProvider.java | 2 +- .../com/google/gplus/provider/GPlusUserActivityCollector.java | 2 +- .../java/com/google/gplus/provider/GPlusUserDataCollector.java | 2 +- .../com/google/gplus/provider/TestAbstractGPlusProvider.java | 5 ++++- 4 files changed, 7 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ff6cb52d/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/AbstractGPlusProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/AbstractGPlusProvider.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/AbstractGPlusProvider.java index daa34d5..6e59da2 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/AbstractGPlusProvider.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/AbstractGPlusProvider.java @@ -52,7 +52,7 @@ import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicBoolean; /** - * + * Provider that creates a GPlus client and will run task that queue data to an outing queue */ public abstract class AbstractGPlusProvider implements StreamsProvider { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ff6cb52d/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserActivityCollector.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserActivityCollector.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserActivityCollector.java index c6952bf..d9a89d9 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserActivityCollector.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserActivityCollector.java @@ -20,7 +20,7 @@ import org.slf4j.LoggerFactory; import java.util.concurrent.BlockingQueue; /** - * + * Collects the public activities of a GPlus user. Has ability to filter by date ranges. */ public class GPlusUserActivityCollector implements Runnable { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ff6cb52d/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserDataCollector.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserDataCollector.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserDataCollector.java index 6a5ce49..5269e10 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserDataCollector.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserDataCollector.java @@ -17,7 +17,7 @@ import org.slf4j.LoggerFactory; import java.util.concurrent.BlockingQueue; /** - * + * Collects user profile information for a specific GPlus user */ public class GPlusUserDataCollector implements Runnable{ http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ff6cb52d/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/provider/TestAbstractGPlusProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/provider/TestAbstractGPlusProvider.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/provider/TestAbstractGPlusProvider.java index 80b1b23..ced612b 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/provider/TestAbstractGPlusProvider.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/provider/TestAbstractGPlusProvider.java @@ -19,10 +19,13 @@ import static org.junit.Assert.fail; import static org.mockito.Mockito.mock; /** - * + * Unit tests for {@link com.google.gplus.provider.AbstractGPlusProvider} */ public class TestAbstractGPlusProvider extends RandomizedTest{ + /** + * Test that every collector will be run and that data queued from the collectors will be processed. + */ @Test @Repeat(iterations = 3) public void testDataCollectorRunsPerUser() {