public ConnectorPageSource createPageSource()

in paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java [45:59]

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

    public ConnectorPageSource createPageSource(
            ConnectorTransactionHandle transaction,
            ConnectorSession session,
            ConnectorSplit split,
            ConnectorTableHandle tableHandle,
            List<ColumnHandle> columns,
            DynamicFilter dynamicFilter) {
        TrinoTableHandle trinoTableHandle = (TrinoTableHandle) tableHandle;
        Table table = trinoTableHandle.tableWithDynamicOptions(session);
        return runWithContextClassLoader(
                () ->
                        createPageSource(
                                table, trinoTableHandle.getFilter(), (TrinoSplit) split, columns),
                TrinoPageSourceProvider.class.getClassLoader());
    }