private ConnectorPageSink createPageSink()

in src/main/java/org/apache/paimon/trino/TrinoPageSinkProvider.java [73:89]

• 16 lines of code
• 2 McCabe index (conditional complexity)

    private ConnectorPageSink createPageSink(
            TrinoTableHandle tableHandle, ConnectorSession session) {
        trinoCatalog.initSession(session);
        Table table = tableHandle.tableWithDynamicOptions(trinoCatalog, session);
        validataBucketMode(table);

        return runWithContextClassLoader(
                () -> {
                    BatchWriteBuilder batchWriteBuilder = table.newBatchWriteBuilder();
                    if (TrinoSessionProperties.enableInsertOverwrite(session)) {
                        batchWriteBuilder.withOverwrite();
                    }
                    BatchTableWrite write = batchWriteBuilder.newWrite();
                    return new TrinoPageSink(write);
                },
                TrinoPageSinkProvider.class.getClassLoader());
    }