Packages

t

org.apache.spark.sql.connector.write

SupportsDynamicOverwrite

trait SupportsDynamicOverwrite extends WriteBuilder

Write builder trait for tables that support dynamic partition overwrite.

A write that dynamically overwrites partitions removes all existing data in each logical partition for which the write will commit new data. Any existing logical partition for which the write does not contain data will remain unchanged.

This is provided to implement SQL compatible with Hive table operations but is not recommended. Instead, use the overwrite by filter API to explicitly replace data.

Annotations
@Evolving()
Source
SupportsDynamicOverwrite.java
Since

3.0.0

Linear Supertypes
WriteBuilder, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SupportsDynamicOverwrite
  2. WriteBuilder
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def overwriteDynamicPartitions(): WriteBuilder

    Configures a write to dynamically replace partitions with data committed in the write.

    Configures a write to dynamically replace partitions with data committed in the write.

    returns

    this write builder for method chaining

Concrete Value Members

  1. def build(): Write

    Returns a logical Write shared between batch and streaming.

    Returns a logical Write shared between batch and streaming.

    Definition Classes
    WriteBuilder
    Since

    3.2.0

Deprecated Value Members

  1. def buildForBatch(): BatchWrite

    Returns a BatchWrite to write data to batch source.

    Returns a BatchWrite to write data to batch source.

    Definition Classes
    WriteBuilder
    Annotations
    @Deprecated
    Deprecated

    (Since version 3.2.0)

  2. def buildForStreaming(): StreamingWrite

    Returns a StreamingWrite to write data to streaming source.

    Returns a StreamingWrite to write data to streaming source.

    Definition Classes
    WriteBuilder
    Annotations
    @Deprecated
    Deprecated

    (Since version 3.2.0)