paimon-presto-0.236/src/main/java/org/apache/paimon/presto/PrestoConnector.java [31:56]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class PrestoConnector extends PrestoConnectorBase {

    private final PrestoTransactionManager transactionManager;

    @Inject
    public PrestoConnector(
            List<PropertyMetadata<?>> sessionProperties,
            PrestoTransactionManager transactionManager,
            PrestoSplitManager prestoSplitManager,
            PrestoPageSourceProvider prestoPageSourceProvider,
            PrestoMetadata prestoMetadata,
            Optional<PrestoPlanOptimizerProvider> prestoPlanOptimizerProvider) {
        // Presto 236 compute push-down api is too low, not yet impl.
        super(
                sessionProperties,
                transactionManager,
                prestoSplitManager,
                prestoPageSourceProvider,
                prestoMetadata,
                prestoPlanOptimizerProvider);
        this.transactionManager = transactionManager;
    }

    @Override
    public void commit(ConnectorTransactionHandle transaction) {
        transactionManager.remove(transaction);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



paimon-presto-0.268/src/main/java/org/apache/paimon/presto/PrestoConnector.java [31:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class PrestoConnector extends PrestoConnectorBase {

    private final PrestoTransactionManager transactionManager;

    @Inject
    public PrestoConnector(
            List<PropertyMetadata<?>> sessionProperties,
            PrestoTransactionManager transactionManager,
            PrestoSplitManager prestoSplitManager,
            PrestoPageSourceProvider prestoPageSourceProvider,
            PrestoMetadata prestoMetadata,
            Optional<PrestoPlanOptimizerProvider> prestoPlanOptimizerProvider) {
        super(
                sessionProperties,
                transactionManager,
                prestoSplitManager,
                prestoPageSourceProvider,
                prestoMetadata,
                prestoPlanOptimizerProvider);
        this.transactionManager = transactionManager;
    }

    @Override
    public void commit(ConnectorTransactionHandle transaction) {
        transactionManager.remove(transaction);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -