dlt.dataset._incremental
parse_incremental_cursor_path
def parse_incremental_cursor_path(
cursor_path: str) -> Tuple[Optional[str], str]
Split table.column into parts, or return (None, column) for a bare field.
apply_incremental
def apply_incremental(
*,
incremental: Incremental[Any],
target_query: sge.Query,
column_ref: sge.Column,
column_lookup_columns: TTableSchemaColumns,
destination_capabilities: Optional[DestinationCapabilitiesContext] = None,
advance: bool = False,
fetch_aggregate_scalar: Optional[Callable[[sge.Query], Any]] = None
) -> Tuple[sge.Query, _RelationIncrementalContext]
Attach incremental WHERE to target_query; with advance=True, advance state.