public ConnectorPageSource createPageSource()

in paimon-prestosql-common/src/main/java/org/apache/paimon/prestosql/PrestoSqlPageSourceProvider.java [44:60]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    public ConnectorPageSource createPageSource(
            ConnectorTransactionHandle transaction,
            ConnectorSession session,
            ConnectorSplit split,
            ConnectorTableHandle tableHandle,
            List<ColumnHandle> columns) {
        PrestoSqlTableHandle prestosqlTableHandle = (PrestoSqlTableHandle) tableHandle;
        Table table = prestosqlTableHandle.tableWithDynamicOptions(session);
        return runWithContextClassLoader(
                () ->
                        createPageSource(
                                table,
                                prestosqlTableHandle.getFilter(),
                                (PrestoSqlSplit) split,
                                columns),
                PrestoSqlPageSourceProvider.class.getClassLoader());
    }