apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From csi...@apache.org
Subject [1/2] incubator-apex-core git commit: - APEX-225 #resolve Adds isConnected to DefaultInputPort
Date Wed, 28 Oct 2015 01:05:53 GMT
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 <tim@datatorrent.com>
Authored: Mon Oct 26 22:28:03 2015 -0700
Committer: Timothy Farkas <tim@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()


Mime
View raw message