Skip to content

DeltaTableIdentifier

DeltaTableIdentifier is an identifier of a delta table by directory or TableIdentifier depending whether it is a catalog table or not (and living non-cataloged).

Creating Instance

DeltaTableIdentifier takes the following to be created:

  • Directory (default: undefined)
  • TableIdentifier (default: undefined)

Creating DeltaTableIdentifier

apply(
  spark: SparkSession,
  identifier: TableIdentifier): Option[DeltaTableIdentifier]

apply creates a new DeltaTableIdentifier for the given TableIdentifier if the specified table identifier represents a Delta table or None.

apply is used when:

Creating DeltaLog

getDeltaLog(
  spark: SparkSession): DeltaLog

getDeltaLog creates a DeltaLog (for the location).

Note

getDeltaLog does not seem to be used.

Location Path

getPath(
  spark: SparkSession): Path

getPath creates a Hadoop Path) for the path if defined or requests SessionCatalog (Spark SQL) for the table metadata and uses the locationUri.


Last update: 2021-03-19