Package org.apache.spark.sql.connector.catalog

Interface TransactionalCatalogPlugin

All Superinterfaces:

CatalogPlugin

@Evolving
public interface TransactionalCatalogPlugin
extends CatalogPlugin

A CatalogPlugin that supports transactions.

Catalogs that implement this interface opt in to transactional query execution. A catalog implementing this interface is responsible for starting transactions.

Since:

4.2.0

Method Summary

Modifier and Type	Method	Description
Transaction	beginTransaction(TransactionInfo info)	Begins a new transaction and returns a Transaction representing it.

Methods inherited from interface org.apache.spark.sql.connector.catalog.CatalogPlugin

defaultNamespace, initialize, name

Method Details

beginTransaction

Transaction beginTransaction(TransactionInfo info)

Begins a new transaction and returns a Transaction representing it.

Parameters:

info - metadata about the transaction being started.