DestPlugin

class

class DestPlugin

Bases: ABC

Categories: spi

Plugin implementing the write-side of a Dest subclass.

Methods

method

write_out

def write_out(ctx: DestContext, conn: C, dest: D, tables: list[TableFileSpec])

Push the per-slot parquet files in tables to dest.

Parameters:

parameter

ctxDestContext

The DestContext for this trx.

parameter

connC

The resolved connection.

parameter

destD

The Dest config declared on the flow.

parameter

tableslist[TableFileSpec] (list[Path])

One parquet file per target; the runtime guarantees len(tables) equals dest's declared target count.