trait V1WriteBuilder extends WriteBuilder
A trait that should be implemented by V1 DataSources that would like to leverage the DataSource V2 write code paths. The InsertableRelation will be used only to Append data. Other instances of the WriteBuilder interface such as SupportsOverwrite, SupportsTruncate should be extended as well to support additional operations other than data appends.
This interface is designed to provide Spark DataSources time to migrate to DataSource V2 and will be removed in a future Spark release.
- Annotations
- @Experimental() @Unstable()
- Source
- V1WriteBuilder.scala
- Since
3.0.0
- Alphabetic
- By Inheritance
- V1WriteBuilder
- WriteBuilder
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
buildForV1Write(): InsertableRelation
Creates an InsertableRelation that allows appending a DataFrame to a a destination (using data source-specific parameters).
Creates an InsertableRelation that allows appending a DataFrame to a a destination (using data source-specific parameters). The insert method will only be called with
overwrite=false
. The DataSource should implement the overwrite behavior as part of the SupportsOverwrite, and SupportsTruncate interfaces.- Since
3.0.0
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
-
final
def
buildForBatch(): BatchWrite
- Definition Classes
- V1WriteBuilder → WriteBuilder
-
final
def
buildForStreaming(): StreamingWrite
- Definition Classes
- V1WriteBuilder → WriteBuilder
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
withInputDataSchema(schema: StructType): WriteBuilder
- Definition Classes
- WriteBuilder
-
def
withQueryId(queryId: String): WriteBuilder
- Definition Classes
- WriteBuilder