index▶ScreeningCsvFileIngestSource
class ScreeningCsvFileIngestSource
implements [o.CsvFileIngestSource]<TableName, ddbo.DuckDbOrchGovernance, InitState, TERMINAL_STATE, ddbo.DuckDbOrchEmitContext>
import { ScreeningCsvFileIngestSource } from ".";

Constructors

new
 ScreeningCsvFileIngestSource(uri: string, tableName: TableName, govn: ddbo.DuckDbOrchGovernance)

Type Parameters

TableName extends string
InitState extends o.State

Properties

readonly
 nature: string

Methods

assuranceSQL(session: o.OrchSession<ddbo.DuckDbOrchGovernance, ddbo.DuckDbOrchEmitContext>, sar: sg.ScreeningAssuranceRules<TableName, ScreeningCsvColumnName>)
exportResourceSQL(session: o.OrchSession<ddbo.DuckDbOrchGovernance, ddbo.DuckDbOrchEmitContext>, sessionEntryID: string, targetSchema: string)
ingestSQL(
session: o.OrchSession<ddbo.DuckDbOrchGovernance, ddbo.DuckDbOrchEmitContext>
issac: o.IngestSourceStructAssuranceContext<InitState, ddbo.DuckDbOrchEmitContext>
sar: sg.ScreeningAssuranceRules<TableName, ScreeningCsvColumnName>
)
workflow(session: o.OrchSession<ddbo.DuckDbOrchGovernance, ddbo.DuckDbOrchEmitContext>, sessionEntryID: string): ReturnType<o.CsvFileIngestSource<TableName, ddbo.DuckDbOrchGovernance, InitState, TERMINAL_STATE, ddbo.DuckDbOrchEmitContext>["workflow"]>