[
https://issues.apache.org/jira/browse/APEXCORE-107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15106300#comment-15106300
]
ASF GitHub Bot commented on APEXCORE-107:
-----------------------------------------
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/206#discussion_r50075910
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlan.java ---
@@ -2059,4 +2106,64 @@ public int hashCode()
return result;
}
+ /**
+ * This class hold Proxy Ports for a stream, and resolves them later
after modules
+ * are expanded.
+ *
+ * If any source and sink added to a stream is ProxyInputPort or
ProxyOutputPort
+ * we create a StreamLinkInfo with the stream reference and keep
ProxyPorts In this class.
+ * Later we go over each Proxy port and find out the actual port
connected to the ProxyPort
+ * and update StreamMeta.
+ */
+ private static final class StreamLinkInfo
+ {
+ OutputPort<?> source;
+ List<InputPort<?>> sinks = new ArrayList<>();
+ final StreamMeta smeta;
+
+ private StreamLinkInfo(StreamMeta smeta)
+ {
+ this.smeta = smeta;
+ }
+
+ private void setSource(OutputPort<?> source)
+ {
+ if (!(source instanceof ProxyOutputPort)) {
+ throw new IllegalArgumentException("Invalid port type expected
ProxyOutputPort");
+ }
+ this.source = source;
+ }
+
+ private void addSink(InputPort<?> sink)
+ {
+ if (!(sink instanceof ProxyInputPort)) {
+ throw new IllegalArgumentException("Invalid port type expected
ProxyOutputPort");
--- End diff --
Same here?
> Support adding module to application using property file API.
> -------------------------------------------------------------
>
> Key: APEXCORE-107
> URL: https://issues.apache.org/jira/browse/APEXCORE-107
> Project: Apache Apex Core
> Issue Type: Sub-task
> Reporter: Tushar Gosavi
> Assignee: Tushar Gosavi
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
