[
https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406983#comment-15406983
]
ASF GitHub Bot commented on APEXCORE-448:
-----------------------------------------
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73452493
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -902,14 +902,14 @@ private void deployNodes(List<OperatorDeployInfo>
nodeList) throws IOException
Context parentContext;
if (ndi instanceof UnifierDeployInfo) {
- OperatorContext unifiedOperatorContext = new OperatorContext(0,
((UnifierDeployInfo)ndi).operatorAttributes, containerContext);
+ OperatorContext unifiedOperatorContext = new OperatorContext(ndi,
containerContext);
parentContext = new
PortContext(ndi.inputs.get(0).contextAttributes, unifiedOperatorContext);
massageUnifierDeployInfo(ndi);
} else {
parentContext = containerContext;
}
- OperatorContext ctx = new OperatorContext(ndi.id,
ndi.contextAttributes, parentContext);
+ OperatorContext ctx = new OperatorContext(ndi, parentContext);
--- End diff --
This is the constructor of OperatorContext:
```
public OperatorContext(@NotNull OperatorDeployInfo operatorDeployInfo,
Context parentContext)
{
super(operatorDeployInfo instanceof
OperatorDeployInfo.UnifierDeployInfo ?
((OperatorDeployInfo.UnifierDeployInfo)operatorDeployInfo).operatorAttributes :
operatorDeployInfo.contextAttributes,
parentContext);
this.lastProcessedWindowId = Stateless.WINDOW_ID;
this.operatorDeployInfo =
Preconditions.checkNotNull(operatorDeployInfo, "operator deploy info");
this.stateless = super.getValue(OperatorContext.STATELESS);
}
> Make operator name available in OperatorContext
> -----------------------------------------------
>
> Key: APEXCORE-448
> URL: https://issues.apache.org/jira/browse/APEXCORE-448
> Project: Apache Apex Core
> Issue Type: Improvement
> Reporter: Chandni Singh
> Assignee: Chandni Singh
>
> Need name of the logical operator in the OperatorContext which can be used by
> WindowDataManager to create a unique path per logical operator .
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
