Cpaulyz commented on code in PR #15136:
URL: https://github.com/apache/iotdb/pull/15136#discussion_r2013358673
##########
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/TableFunctionOperator.java:
##########
@@ -61,16 +65,19 @@ public class TableFunctionOperator implements
ProcessOperator {
private final Operator inputOperator;
private final TableFunctionProcessorProvider processorProvider;
private final PartitionRecognizer partitionRecognizer;
- private final TsBlockBuilder blockBuilder;
+ private final TsBlockBuilder properBlockBuilder;
private final int properChannelCount;
private final boolean needPassThrough;
- private final SliceCache sliceCache;
+ private final PartitionCache partitionCache;
+ private final boolean requireRecordSnapshot;
private TableFunctionDataProcessor processor;
private PartitionState partitionState;
private ListenableFuture<?> isBlocked;
private boolean finished = false;
+ private Queue<TsBlock> resultTsBlocks;
Review Comment:
done
--
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]
