AMashenkov commented on code in PR #1617:
URL: https://github.com/apache/ignite-3/pull/1617#discussion_r1095685058
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/Fragment.java:
##########
@@ -64,19 +73,21 @@ public class Fragment {
* @param remotes Remote sources of the fragment.
*/
public Fragment(long id, IgniteRel root, List<IgniteReceiver> remotes) {
- this(id, root, remotes, null, null);
+ this(id, root, expectsCorrelatesFromOutside(root), remotes, null,
null);
}
/**
* Constructor.
* TODO Documentation https://issues.apache.org/jira/browse/IGNITE-15859
*/
- Fragment(long id, IgniteRel root, List<IgniteReceiver> remotes, @Nullable
String rootSer, @Nullable FragmentMapping mapping) {
+ Fragment(long id, IgniteRel root, boolean expectsCorrelatesFromOutside,
List<IgniteReceiver> remotes,
Review Comment:
I guess, we can pass 'expectsCorrelatesFromOutside' to constructor through
FragmentProto in FragmenSplitter.go(Fragment).
see: stack.push(new FragmentProto(IdGenerator.nextId(), fragment.root()));
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
