public TrinoPageSource()

in src/main/java/org/apache/paimon/trino/TrinoPageSource.java [100:115]

15 lines of code
2 McCabe index (conditional complexity)


    public TrinoPageSource(
            RecordReader<InternalRow> reader,
            List<ColumnHandle> projectedColumns,
            OptionalLong limit) {
        this.iterator = reader.toCloseableIterator();
        this.limit = limit;
        this.columnTypes = new ArrayList<>();
        this.logicalTypes = new ArrayList<>();
        for (ColumnHandle handle : projectedColumns) {
            TrinoColumnHandle trinoColumnHandle = (TrinoColumnHandle) handle;
            columnTypes.add(trinoColumnHandle.getTrinoType());
            logicalTypes.add(trinoColumnHandle.logicalType());
        }

        this.pageBuilder = new PageBuilder(columnTypes);
    }