delta lake
API DeltaTable
DeltaTable(DeltaTableOperations)
executeDelete
executeUpdate
SQL DeltaSparkSessionExtension
DeltaDataSource
1
2
3
4
5
6
7
8
class DeltaDataSource
extends RelationProvider
with StreamSourceProvider
with StreamSinkProvider
with CreatableRelationProvider
with DataSourceRegister
with TableProvider
with DeltaLogging {
- RelationProvider 批量读取
- CreatableRelationProvider 批量写入
- StreamSourceProvider stream source
- StreamSinkProvider stream sink