tabsdatak.conn.stream.stage
logger | |
ManifestStageConn | Connection for ManifestStageSrc -- one stage backend. |
ManifestStageSrc | Stream-stage source -- materialises the files in one manifest. |
ManifestStageSrcPlugin |
logger
attributelogger = logging.getLogger(__name__)
ManifestStageSrcPlugin
classclass ManifestStageSrcPlugin
Bases: SrcPlugin
method
read_indef read_in(
ctx: SrcPluginCtx,
conn: ManifestStageConn,
src: ManifestStageSrc,
) -> list[list[TableFileInput]]
Parameters:
parameter
ctxSrcPluginCtxparameter
parameter