You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by re...@apache.org on 2014/11/07 22:04:29 UTC
[3/5] incubator-streams git commit: Added some java docs
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 <ry...@gmail.com>
Authored: Thu Nov 6 22:39:04 2014 -0600
Committer: Ryan Ebanks <ry...@gmail.com>
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() {