Showing content from https://docs.delta.io/latest/api/scala/spark/io/delta/tables/DeltaTable.html below:
Delta Spark 4.0.0 - Scala API Docs
class DeltaTable extends DeltaTableOperations with Serializable
Ordering
- Alphabetic
- By Inheritance
Inherited
- DeltaTable
- Serializable
- DeltaTableOperations
- AnalysisHelper
- AnyRef
- Any
Visibility
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- final def ##: Int
- final def ==(arg0: Any): Boolean
- def addFeatureSupport(featureName: String): Unit
- def alias(alias: String): DeltaTable
- def as(alias: String): DeltaTable
- final def asInstanceOf[T0]: T0
- def clone(target: String, isShallow: Boolean): DeltaTable
- def clone(target: String, isShallow: Boolean, replace: Boolean): DeltaTable
- def clone(target: String, isShallow: Boolean, replace: Boolean, properties: HashMap[String, String]): DeltaTable
- def clone(target: String, isShallow: Boolean, replace: Boolean, properties: Map[String, String]): DeltaTable
- def clone(): AnyRef
- def cloneAtTimestamp(timestamp: String, target: String, isShallow: Boolean): DeltaTable
- def cloneAtTimestamp(timestamp: String, target: String, isShallow: Boolean, replace: Boolean): DeltaTable
- def cloneAtTimestamp(timestamp: String, target: String, isShallow: Boolean, replace: Boolean, properties: HashMap[String, String]): DeltaTable
- def cloneAtTimestamp(timestamp: String, target: String, isShallow: Boolean, replace: Boolean, properties: Map[String, String]): DeltaTable
- def cloneAtVersion(version: Long, target: String, isShallow: Boolean): DeltaTable
- def cloneAtVersion(version: Long, target: String, isShallow: Boolean, replace: Boolean): DeltaTable
- def cloneAtVersion(version: Long, target: String, isShallow: Boolean, replace: Boolean, properties: HashMap[String, String]): DeltaTable
- def cloneAtVersion(version: Long, target: String, isShallow: Boolean, replace: Boolean, properties: Map[String, String]): DeltaTable
- def delete(): Unit
- def delete(condition: Column): Unit
- def delete(condition: String): Unit
- def deltaLog: DeltaLog
- def detail(): DataFrame
- def df: Dataset[Row]
- def dropFeatureSupport(featureName: String): Unit
- def dropFeatureSupport(featureName: String, truncateHistory: Boolean): Unit
- final def eq(arg0: AnyRef): Boolean
- def equals(arg0: AnyRef): Boolean
- def executeClone(table: DeltaTableV2, target: String, isShallow: Boolean, replace: Boolean, properties: Map[String, String], versionAsOf: Option[Long], timestampAsOf: Option[String]): DeltaTable
- def executeDelete(condition: Option[Expression]): Unit
- def executeDetails(path: String, tableIdentifier: Option[TableIdentifier]): DataFrame
- def executeGenerate(path: String, tableIdentifier: Option[TableIdentifier], mode: String): Unit
- def executeHistory(deltaLog: DeltaLog, limit: Option[Int], catalogTable: Option[CatalogTable]): DataFrame
- def executeRestore(table: DeltaTableV2, versionAsOf: Option[Long], timestampAsOf: Option[String]): DataFrame
- def executeUpdate(set: Map[String, Column], condition: Option[Column]): Unit
- def executeVacuum(table: DeltaTableV2, retentionHours: Option[Double]): DataFrame
- def generate(mode: String): Unit
- final def getClass(): Class[_ <: AnyRef]
- def hashCode(): Int
- def history(): DataFrame
- def history(limit: Int): DataFrame
- def improveUnsupportedOpError[T](f: => T): T
- final def isInstanceOf[T0]: Boolean
- def merge(source: DataFrame, condition: Column): DeltaMergeBuilder
- def merge(source: DataFrame, condition: String): DeltaMergeBuilder
- final def ne(arg0: AnyRef): Boolean
- final def notify(): Unit
- final def notifyAll(): Unit
- def optimize(): DeltaOptimizeBuilder
- def resolveReferencesForExpressions(sparkSession: SparkSession, exprs: Seq[Expression], planProvidingAttrs: LogicalPlan): Seq[Expression]
- def restoreToTimestamp(timestamp: String): DataFrame
- def restoreToVersion(version: Long): DataFrame
- def sparkSession: SparkSession
- final def synchronized[T0](arg0: => T0): T0
- def toDF: Dataset[Row]
- def toDataset(sparkSession: SparkSession, logicalPlan: LogicalPlan): Dataset[Row]
- def toStrColumnMap(map: Map[String, String]): Map[String, Column]
- def toString(): String
- def tryResolveReferences(sparkSession: SparkSession)(expr: Expression, planContainingExpr: LogicalPlan): Expression
- def tryResolveReferencesForExpressions(sparkSession: SparkSession)(exprs: Seq[Expression], plansProvidingAttrs: Seq[LogicalPlan]): Seq[Expression]
- def tryResolveReferencesForExpressions(sparkSession: SparkSession, exprs: Seq[Expression], planContainingExpr: LogicalPlan): Seq[Expression]
- def update(condition: Column, set: Map[String, Column]): Unit
- def update(condition: Column, set: Map[String, Column]): Unit
- def update(set: Map[String, Column]): Unit
- def update(set: Map[String, Column]): Unit
- def updateExpr(condition: String, set: Map[String, String]): Unit
- def updateExpr(condition: String, set: Map[String, String]): Unit
- def updateExpr(set: Map[String, String]): Unit
- def updateExpr(set: Map[String, String]): Unit
- def upgradeTableProtocol(readerVersion: Int, writerVersion: Int): Unit
- def vacuum(): DataFrame
- def vacuum(retentionHours: Double): DataFrame
- final def wait(arg0: Long, arg1: Int): Unit
- final def wait(arg0: Long): Unit
- final def wait(): Unit
Deprecated Value Members
- def finalize(): Unit
Inherited from DeltaTableOperations
Inherited from AnalysisHelper
Inherited from AnyRef
Inherited from Any
RetroSearch is an open source project built by @garambo
| Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4