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 <[email protected]> Authored: Mon Oct 26 22:28:03 2015 -0700 Committer: Timothy Farkas <[email protected]> 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()
