You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2015/11/02 16:49:50 UTC
[03/11] incubator-apex-core git commit: - APEX-225 #resolve Adds
isConnected to DefaultInputPort
- 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/feature-module
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()