shuai-xu commented on code in PR #9600:
URL: https://github.com/apache/incubator-gluten/pull/9600#discussion_r2088351085
##########
gluten-flink/runtime/src/main/java/org/apache/gluten/table/runtime/operators/GlutenSingleInputOperator.java:
##########
@@ -50,19 +49,17 @@
import org.slf4j.LoggerFactory;
import java.util.List;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
/** Calculate operator in gluten, which will call Velox to run. */
public class GlutenSingleInputOperator extends TableStreamOperator<RowData>
implements OneInputStreamOperator<RowData, RowData>, GlutenOperator {
private static final Logger LOG =
LoggerFactory.getLogger(GlutenSingleInputOperator.class);
- private final PlanNode glutenPlan;
+ private final Velox4JBean<PlanNode> glutenPlan;
private final String id;
- private final RowType inputType;
- private final RowType outputType;
+ private final Velox4JBean<RowType> inputType;
+ private final Velox4JBean<RowType> outputType;
Review Comment:
If outputType changes to Map<String, RowType>, does it work?
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
