|
@@ -289,7 +289,7 @@ static unsigned calcInlineFlags(BuildCtx * ctx, IHqlExpression * expr)
|
|
case no_getresult:
|
|
case no_getresult:
|
|
return expr->isDatarow() ? RETevaluate : RETassign;
|
|
return expr->isDatarow() ? RETevaluate : RETassign;
|
|
case no_getgraphresult:
|
|
case no_getgraphresult:
|
|
- if (expr->hasAttribute(_distributed_Atom))
|
|
|
|
|
|
+ if (expr->hasAttribute(_distributed_Atom) || expr->hasAttribute(_streaming_Atom))
|
|
return 0;
|
|
return 0;
|
|
return expr->isDatarow() ? RETevaluate : RETassign;
|
|
return expr->isDatarow() ? RETevaluate : RETassign;
|
|
case no_temptable:
|
|
case no_temptable:
|