Skip to content

Commit

Permalink
1
Browse files Browse the repository at this point in the history
  • Loading branch information
morningman committed Jul 6, 2023
1 parent 79221a5 commit aeb242f
Showing 1 changed file with 7 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@

/**
* FileQueryScanNode for querying the file access type of catalog, now only support
* hive,hudi, iceberg and TVF.
* hive, hudi, iceberg and TVF.
*/
public abstract class FileQueryScanNode extends FileScanNode {
private static final Logger LOG = LogManager.getLogger(FileQueryScanNode.class);
Expand Down Expand Up @@ -163,6 +163,10 @@ protected void initSchemaParams() throws UserException {
@Override
public void updateRequiredSlots(PlanTranslatorContext planTranslatorContext,
Set<SlotId> requiredByProjectSlotIdSet) throws UserException {
updateRequiredSlots();
}

private void updateRequiredSlots() throws UserException {
params.unsetRequiredSlots();
for (SlotDescriptor slot : desc.getSlots()) {
if (!slot.isMaterialized()) {
Expand Down Expand Up @@ -196,6 +200,7 @@ public void finalizeForNereids() throws UserException {
// Create scan range locations and the statistics.
protected void doFinalize() throws UserException {
createScanRangeLocations();
updateRequiredSlots();
}

private void setColumnPositionMapping()
Expand Down Expand Up @@ -415,3 +420,4 @@ protected static Optional<TFileType> getTFileType(String location) {
return Optional.empty();
}
}

0 comments on commit aeb242f

Please sign in to comment.