You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by cs...@apache.org on 2015/10/28 02:05:53 UTC
[1/2] incubator-apex-core git commit: - APEX-225 #resolve Adds
isConnected to DefaultInputPort
Repository: incubator-apex-core
Updated Branches:
refs/heads/devel-3 8d9aa4b32 -> ec51e8b63
- APEX-225 #resolve Adds isConnected to DefaultInputPort
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/eb7d721f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/eb7d721f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/eb7d721f
Branch: refs/heads/devel-3
Commit: eb7d721f66b5a22840678c55602eeb82e03a2aba
Parents: aa28887
Author: Timothy Farkas <ti...@datatorrent.com>
Authored: Mon Oct 26 22:28:03 2015 -0700
Committer: Timothy Farkas <ti...@datatorrent.com>
Committed: Tue Oct 27 17:57:58 2015 -0700
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/DefaultInputPort.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/eb7d721f/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/DefaultInputPort.java b/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
index e3998f0..2ed871d 100644
--- a/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
+++ b/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
@@ -55,6 +55,15 @@ public abstract class DefaultInputPort<T> implements InputPort<T>, Sink<T>
this.connected = connected;
}
+ /**
+ * Returns true if this port is connected and false otherwise.
+ * @return true if this port is connected and false otherwise.
+ */
+ public boolean isConnected()
+ {
+ return connected;
+ }
+
/** {@inheritDoc} */
@Override
public StreamCodec<T> getStreamCodec()
[2/2] incubator-apex-core git commit: Merge branch 'APEX-225' into
devel-3
Posted by cs...@apache.org.
Merge branch 'APEX-225' into devel-3
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/ec51e8b6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/ec51e8b6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/ec51e8b6
Branch: refs/heads/devel-3
Commit: ec51e8b639cc1a53ef8748c86955f157dab272a4
Parents: 8d9aa4b eb7d721
Author: Chandni Singh <cs...@apache.org>
Authored: Tue Oct 27 18:05:20 2015 -0700
Committer: Chandni Singh <cs...@apache.org>
Committed: Tue Oct 27 18:05:20 2015 -0700
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/DefaultInputPort.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------