Struct DeltaLakeSink 

pub struct DeltaLakeSink {
    pub config: DeltaLakeConfig,
    param: SinkParam,
}

Fields

config: DeltaLakeConfig

param: SinkParam

Implementations

impl DeltaLakeSink

pub fn new(config: DeltaLakeConfig, param: SinkParam) -> Result<Self>

Trait Implementations

impl Debug for DeltaLakeSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EnforceSecret for DeltaLakeSink

fn enforce_secret<'a>( prop_iter: impl Iterator<Item = &'a str>, ) -> ConnectorResult<()>

const ENFORCE_SECRET_PROPERTIES: Set<&'static str> = _

fn enforce_one(prop: &str) -> Result<()>

impl From<DeltaLakeSink> for SinkImpl

fn from(sink: DeltaLakeSink) -> SinkImpl

Converts to this type from the input type.

impl Sink for DeltaLakeSink

const SINK_NAME: &'static str = super::DELTALAKE_SINK

type Coordinator = DeltaLakeSinkCommitter

type LogSinker = CoordinatedLogSinker<DeltaLakeSinkWriter>

async fn new_log_sinker( &self, writer_param: SinkWriterParam, ) -> Result<Self::LogSinker>

fn validate_alter_config(config: &BTreeMap<String, String>) -> Result<()>

async fn validate(&self) -> Result<()>

fn is_coordinated_sink(&self) -> bool

async fn new_coordinator( &self, _db: DatabaseConnection, _iceberg_compact_stat_sender: Option<UnboundedSender<IcebergSinkCompactionUpdate>>, ) -> Result<Self::Coordinator>

fn set_default_commit_checkpoint_interval( desc: &mut SinkDesc, user_specified: &SinkDecouple, ) -> Result<()>

fn is_sink_decouple(user_specified: &SinkDecouple) -> Result<bool>

user_specified is the value of sink_decouple config.

fn support_schema_change() -> bool

impl TryFrom<SinkParam> for DeltaLakeSink

type Error = SinkError

The type returned in the event of a conversion error.

fn try_from(param: SinkParam) -> Result<Self, Self::Error>

Performs the conversion.