kw2542 commented on a change in pull request #14945:
URL: https://github.com/apache/beam/pull/14945#discussion_r647052941
##########
File path: runners/samza/src/test/resources/ExpectedDag.json
##########
@@ -0,0 +1,97 @@
+{
+ "RootNode": [
+ { "fullName":"OuterMostNode",
+ "shortName":"OuterMostNode",
+ "id":"OuterMostNode",
+ "ChildNode":[
+ { "fullName":"Create.TimestampedValues",
+ "shortName":"Create.TimestampedValues",
+ "id":"Create.TimestampedValues",
+ "enclosingNode":"OuterMostNode",
+ "ChildNode":[
+ { "fullName":"Create.TimestampedValues/Create.Values",
+ "shortName":"Create.Values",
+ "id":"Create.TimestampedValues/Create.Values",
+ "enclosingNode":"Create.TimestampedValues",
+ "ChildNode":[
+ {
"fullName":"Create.TimestampedValues/Create.Values/Read(CreateSource)",
+ "shortName":"Read(CreateSource)",
+
"id":"Create.TimestampedValues/Create.Values/Read(CreateSource)",
+ "enclosingNode":"Create.TimestampedValues/Create.Values",
+ "ChildNode":[
+ {
"fullName":"Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse",
+ "shortName":"Impulse",
+
"enclosingNode":"Create.TimestampedValues/Create.Values/Read(CreateSource)",
+
"id":"Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse"},
+ {
"fullName":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(OutputSingleSource)",
+ "shortName":"ParDo(OutputSingleSource)",
+
"id":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(OutputSingleSource)",
+
"enclosingNode":"Create.TimestampedValues/Create.Values/Read(CreateSource)",
+ "ChildNode":[
+ {
"fullName":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)",
+ "shortName":"ParMultiDo(OutputSingleSource)",
+
"enclosingNode":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(OutputSingleSource)",
+
"id":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)"}
+ ]},
+ {
"fullName":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)",
+ "shortName":"ParDo(BoundedSourceAsSDFWrapper)",
+
"id":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)",
+
"enclosingNode":"Create.TimestampedValues/Create.Values/Read(CreateSource)",
+ "ChildNode":[
+ {
"fullName":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)",
+ "shortName":"ParMultiDo(BoundedSourceAsSDFWrapper)",
+
"enclosingNode":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)",
+
"id":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)"}
+ ]}
+ ]}
+ ]},
+ { "fullName":"Create.TimestampedValues/ParDo(ConvertTimestamps)",
+ "shortName":"ParDo(ConvertTimestamps)",
+ "id":"Create.TimestampedValues/ParDo(ConvertTimestamps)",
+ "enclosingNode":"Create.TimestampedValues",
+ "ChildNode":[
+ {
"fullName":"Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps)",
+ "shortName":"ParMultiDo(ConvertTimestamps)",
+
"enclosingNode":"Create.TimestampedValues/ParDo(ConvertTimestamps)",
+
"id":"Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps)"}
+ ]}
+ ]},
+ { "fullName":"Window.Into()",
+ "shortName":"Window.Into()",
+ "id":"Window.Into()",
+ "enclosingNode":"OuterMostNode",
+ "ChildNode":[
+ { "fullName":"Window.Into()/Window.Assign",
+ "shortName":"Window.Assign",
+ "enclosingNode":"Window.Into()",
+ "id":"Window.Into()/Window.Assign"}
+ ]},
+ { "fullName":"Combine.perKey(SumInteger)",
+ "shortName":"Combine.perKey(SumInteger)",
+ "id":"Combine.perKey(SumInteger)",
+ "enclosingNode":"OuterMostNode",
+ "ChildNode":[
+ { "fullName":"Combine.perKey(SumInteger)/GroupByKey",
+ "shortName":"GroupByKey",
+ "enclosingNode":"Combine.perKey(SumInteger)",
+ "id":"Combine.perKey(SumInteger)/GroupByKey"},
+ { "fullName":"Combine.perKey(SumInteger)/Combine.GroupedValues",
+ "shortName":"Combine.GroupedValues",
+ "id":"Combine.perKey(SumInteger)/Combine.GroupedValues",
+ "enclosingNode":"Combine.perKey(SumInteger)",
+ "ChildNode":[
+ {
"fullName":"Combine.perKey(SumInteger)/Combine.GroupedValues/ParDo(Anonymous)",
+ "shortName":"ParDo(Anonymous)",
+
"id":"Combine.perKey(SumInteger)/Combine.GroupedValues/ParDo(Anonymous)",
+
"enclosingNode":"Combine.perKey(SumInteger)/Combine.GroupedValues",
+ "ChildNode":[
+ {
"fullName":"Combine.perKey(SumInteger)/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous)",
+ "shortName":"ParMultiDo(Anonymous)",
+
"enclosingNode":"Combine.perKey(SumInteger)/Combine.GroupedValues/ParDo(Anonymous)",
+
"id":"Combine.perKey(SumInteger)/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous)"}
+ ]}
+ ]}
+ ]}
+ ]}
+ ]
+,"graphLinks":
[{"from":"Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse","to":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)","hashId":"402#bb20b45fd4d95138"},{"from":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)","to":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)","hashId":"402#3d93cb799b3970be"},{"from":"Create.TimestampedValues/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)","to":"Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps)","hashId":"402#a32dc9f64f1df03a"},{"from":"Create.TimestampedValues/ParDo(ConvertTimestamps)/ParMultiDo(ConvertTimestamps)","to":"Window.Into()/Window.Assign","hashId":"402#8ce970b71df42503"},{"from":"Window.Into()/Window.Assign","
to":"Combine.perKey(SumInteger)/GroupByKey","hashId":"402#98f8ba3dc812a76d"},{"from":"Combine.perKey(SumInteger)/GroupByKey","to":"Combine.perKey(SumInteger)/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous)","hashId":"402#554dcd2b40b5f04b"}]}
Review comment:
is this line expected to be long single line?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
