streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From reba...@apache.org
Subject [3/5] incubator-streams git commit: Added some java docs
Date Fri, 07 Nov 2014 21:04:29 GMT
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 <ryanebanks@gmail.com>
Authored: Thu Nov 6 22:39:04 2014 -0600
Committer: Ryan Ebanks <ryanebanks@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() {


Mime
View raw message