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/10/20 19:28:58 UTC
[06/11] git commit: Added javadocs and set default queue size to 500
Added javadocs and set default queue size to 500
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/91a0f9a6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/91a0f9a6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/91a0f9a6
Branch: refs/heads/master
Commit: 91a0f9a6799135619d2688699dcd71cfd3321138
Parents: 0d20773
Author: Ryan Ebanks <ry...@gmail.com>
Authored: Wed Oct 8 12:57:24 2014 -0500
Committer: Ryan Ebanks <ry...@gmail.com>
Committed: Wed Oct 8 12:57:24 2014 -0500
----------------------------------------------------------------------
.../streams/local/builders/LocalStreamBuilder.java | 15 +++++++++------
1 file changed, 9 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/91a0f9a6/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java
index 4606aa7..57f3aa4 100644
--- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java
+++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java
@@ -44,6 +44,7 @@ import java.util.concurrent.TimeUnit;
public class LocalStreamBuilder implements StreamBuilder {
private static final Logger LOGGER = org.slf4j.LoggerFactory.getLogger(LocalStreamBuilder.class);
+ private static final int DEFAULT_QUEUE_SIZE = 500;
public static final String TIMEOUT_KEY = "TIMEOUT";
private Map<String, StreamComponent> providers;
@@ -60,22 +61,23 @@ public class LocalStreamBuilder implements StreamBuilder {
private int maxQueueCapacity;
/**
- *
+ * Creates a local stream builder with no config object and default maximum internal queue size of 500
*/
public LocalStreamBuilder(){
- this(-1, null);
+ this(DEFAULT_QUEUE_SIZE, null);
}
/**
- *
+ * Creates a local stream builder with a config object and default maximum internal queue size of 500
* @param streamConfig
*/
public LocalStreamBuilder(Map<String, Object> streamConfig) {
- this(-1, streamConfig);
+ this(DEFAULT_QUEUE_SIZE, streamConfig);
}
/**
- *
+ * Creates a local stream builder with no config object. If maxQueueCapacity is less than 1 the queue is
+ * unbounded.
* @param maxQueueCapacity
*/
public LocalStreamBuilder(int maxQueueCapacity) {
@@ -83,7 +85,8 @@ public class LocalStreamBuilder implements StreamBuilder {
}
/**
- *
+ * Creates a local stream builder with a config object. If maxQueueCapacity is less than 1 the queue is
+ * unbounded.
* @param maxQueueCapacity
* @param streamConfig
*/