You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2016/08/30 19:47:58 UTC
[1/2] incubator-beam git commit: [BEAM-569] Define maxNumRecords
default value to Long.MAX_VALUE in JmsIO
Repository: incubator-beam
Updated Branches:
refs/heads/master 92451d071 -> 33d747efa
[BEAM-569] Define maxNumRecords default value to Long.MAX_VALUE in JmsIO
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/800c0987
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/800c0987
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/800c0987
Branch: refs/heads/master
Commit: 800c09870a732a71c897705fbecdedec4a961804
Parents: 92451d0
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Sat Aug 27 14:01:34 2016 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Tue Aug 30 21:46:33 2016 +0200
----------------------------------------------------------------------
.../jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/800c0987/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java b/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java
index 29d0c5f..3107aab 100644
--- a/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java
+++ b/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java
@@ -101,11 +101,11 @@ public class JmsIO {
private static final Logger LOG = LoggerFactory.getLogger(JmsIO.class);
public static Read read() {
- return new Read();
+ return new Read(null, null, null, Long.MAX_VALUE, null);
}
public static Write write() {
- return new Write();
+ return new Write(null, null, null);
}
/**
@@ -185,8 +185,6 @@ public class JmsIO {
protected long maxNumRecords;
protected Duration maxReadTime;
- private Read() {}
-
private Read(
ConnectionFactory connectionFactory,
String queue,
@@ -428,8 +426,6 @@ public class JmsIO {
return new Write(connectionFactory, queue, topic);
}
- private Write() {}
-
private Write(ConnectionFactory connectionFactory, String queue, String topic) {
this.connectionFactory = connectionFactory;
this.queue = queue;
[2/2] incubator-beam git commit: [BEAM-569] This closes #898
Posted by jb...@apache.org.
[BEAM-569] This closes #898
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/33d747ef
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/33d747ef
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/33d747ef
Branch: refs/heads/master
Commit: 33d747efa2888961baf7b4d9a9b01ec1b4715c62
Parents: 92451d0 800c098
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Tue Aug 30 21:47:31 2016 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Tue Aug 30 21:47:31 2016 +0200
----------------------------------------------------------------------
.../jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
----------------------------------------------------------------------