Skip to content

DeltaCatalog

DeltaCatalog is a concrete AbstractDeltaCatalog.

loadCatalogTable

AbstractDeltaCatalog
Table loadCatalogTable(
  Identifier ident,
  CatalogTable catalogTable)

loadCatalogTable is part of the AbstractDeltaCatalog abstraction.

loadCatalogTable loadTableInternal to decide on the table implementation:

loadPathTable

AbstractDeltaCatalog
Table loadPathTable(
  Identifier ident)

loadPathTable is part of the AbstractDeltaCatalog abstraction.

loadPathTable...FIXME

Load Delta Table

Table loadTableInternal(
  Supplier<Table> v2ConnectorSupplier,
  Supplier<Table> v1ConnectorSupplier)

loadTableInternal creates a DeltaV2Mode (for the SQLConf of the active SparkSession).

When shouldCatalogReturnV2Tables loadTableInternal uses the given v2ConnectorSupplier. Otherwise, loadTableInternal uses the given v1ConnectorSupplier.