tabsdatak.spi

check_plugin_param_type	Validate a plugin method's parameter type matches expected.
CommitStateFn
Conn	Abstract base for every connection.
ConnMetaModel	Abstract base for a connection kind (SQL, objects, storage, ...).
DestContext	Context handed to DestPlugin.write_out -- combines TrxCtx with PluginCtx.
DestDef	Entry-point registration for a Dest binding.
DestPlugin	Plugin implementing the write-side of a Dest subclass.
Entity	Abstract base for an entity within a connection.
Explorer	Optional connector capability for ad-hoc inspection of a live Conn: catalog metadata and arbitrary query execution.
FilesSpec
FlowCtx	Flow-level identifiers (collection / function) shared by every role that runs inside a trx -- plugins and user-decorated functions.
FunctionCtx	Context handed to a user-decorated function (@publisher / @transformer / @subscriber) that declares a trailing ctx parameter.
MetadataSpec
PluginCtx	Common context surface shared by every plugin variant (batch source, stream source, destination).
SrcDef	Entry-point registration for a batch Src binding.
SrcPlugin	Plugin implementing the read-side of a Src subclass.
SrcPluginCtx	Context handed to SrcPlugin.read_in -- combines TrxCtx (trx identifiers + scratch state) with PluginCtx (flow identifiers + work dir).
StreamSrcDef	Entry-point registration for a StreamSrc binding.
StreamSrcPlugin	Plugin implementing the long-running side of a StreamSrc subclass (CDC, log tail, queue tail).
StreamSrcPluginCtx	Context handed to StreamSrcPlugin.run -- the plugin's long-lived control surface.
StreamStageSrc	Config type for the hidden batch source that ingests a stream's staged manifests.
StreamStageSrcPlugin	Hidden batch-side (publisher) source that ingests a stream stage's manifests.
StreamStateSpec
TableFileInput	One parquet file SrcPlugin.read_in produces for an output slot, paired with optional metadata to carry alongside it.
TableFileSpec
TableMode	How a SrcPlugin returns slot contents -- the length of each inner list in SrcPlugin.read_in's return.
to_table_file_inputs	Wrap per-slot parquet paths as TableFileInput\ s with no metadata -- the shape SrcPlugin.read_in returns.

---

CommitStateFn

type_alias

CommitStateFn: Callable[[], None]

---

FilesSpec

type_alias

FilesSpec: list[TableFileSpec]

Resolved type:

list[Path]

---

MetadataSpec

type_alias

MetadataSpec: dict[str, _MetadataBasicType]

Resolved type:

dict[str, str | int | float | bool]

---

StreamStateSpec

type_alias

StreamStateSpec: Union[BasicDictSpec, CommitStateFn]

Resolved type:

dict[str, str | int | float | bool] | Callable[[], None]

---

TableFileSpec

type_alias

TableFileSpec: Path