trait SupportsOverwrite extends SupportsOverwriteV2
Write builder trait for tables that support overwrite by filter.
Overwriting data by filter will delete any data that matches the filter and replace it with data that is committed in the write.
- Annotations
- @Evolving()
- Source
- SupportsOverwrite.java
- Since
3.0.0
- Alphabetic
- By Inheritance
- SupportsOverwrite
- SupportsOverwriteV2
- SupportsTruncate
- WriteBuilder
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def overwrite(filters: Array[Filter]): WriteBuilder
Configures a write to replace data matching the filters with data committed in the write.
Configures a write to replace data matching the filters with data committed in the write.
Rows must be deleted from the data source if and only if all of the filters match. That is, filters must be interpreted as ANDed together.
- filters
filters used to match data to overwrite
- returns
this write builder for method chaining
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def build(): Write
Returns a logical
Writeshared between batch and streaming.Returns a logical
Writeshared between batch and streaming.- Definition Classes
- WriteBuilder
- Since
3.2.0
- def canOverwrite(predicates: Array[Predicate]): Boolean
Checks whether it is possible to overwrite data from a data source table that matches filter expressions.
Checks whether it is possible to overwrite data from a data source table that matches filter expressions.
Rows should be overwritten from the data source iff all of the filter expressions match. That is, the expressions must be interpreted as a set of filters that are ANDed together.
- predicates
V2 filter expressions, used to match data to overwrite
- returns
true if the delete operation can be performed
- Definition Classes
- SupportsOverwrite → SupportsOverwriteV2
- Since
3.4.0
- def canOverwrite(filters: Array[Filter]): Boolean
Checks whether it is possible to overwrite data from a data source table that matches filter expressions.
Checks whether it is possible to overwrite data from a data source table that matches filter expressions.
Rows should be overwritten from the data source iff all of the filter expressions match. That is, the expressions must be interpreted as a set of filters that are ANDed together.
- filters
V2 filter expressions, used to match data to overwrite
- returns
true if the delete operation can be performed
- Since
3.4.0
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def overwrite(predicates: Array[Predicate]): WriteBuilder
Configures a write to replace data matching the filters with data committed in the write.
Configures a write to replace data matching the filters with data committed in the write.
Rows must be deleted from the data source if and only if all of the filters match. That is, filters must be interpreted as ANDed together.
- predicates
filters used to match data to overwrite
- returns
this write builder for method chaining
- Definition Classes
- SupportsOverwrite → SupportsOverwriteV2
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def truncate(): WriteBuilder
Configures a write to replace all existing data with data committed in the write.
Configures a write to replace all existing data with data committed in the write.
- returns
this write builder for method chaining
- Definition Classes
- SupportsOverwrite → SupportsOverwriteV2 → SupportsTruncate
- Annotations
- @Override()
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def buildForBatch(): BatchWrite
Returns a
BatchWriteto write data to batch source.Returns a
BatchWriteto write data to batch source.- Definition Classes
- WriteBuilder
- Annotations
- @Deprecated
- Deprecated
(Since version 3.2.0)
- def buildForStreaming(): StreamingWrite
Returns a
StreamingWriteto write data to streaming source.Returns a
StreamingWriteto write data to streaming source.- Definition Classes
- WriteBuilder
- Annotations
- @Deprecated
- Deprecated
(Since version 3.2.0)
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)