_constraint_propagation

Defines a visitor for propagating constraints through transformations.

Functions

propagate_unmodified()	Propagate a list of constraints through a transformation unmodified.
propagate_replace()	Propagate a list of constraints through replacement transformations.
propagate_rename()	Propagate a list of constraints through a Rename transformation.
propagate_select()	Propagate a list of constraints through a Select transformation.
propagate_map()	Propagate a list of constraints through a Map transformation.
propagate_flat_map()	Propagate a list of constraints through a FlatMap transformation.
propagate_join_private()	Propagate a list of constraints through a JoinPrivate transformation.
propagate_join_public()	Propagate a list of constraints through a JoinPublic transformation.

propagate_unmodified(_expr, constraints)

Propagate a list of constraints through a transformation unmodified.

Parameters

• _expr (Union[tmlt.analytics.query_expr.Filter, tmlt.analytics.query_expr.DropInfinity, tmlt.analytics.query_expr.DropNullAndNan]) –

• constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]

propagate_replace(expr, constraints)

Propagate a list of constraints through replacement transformations.

Parameters

• expr (Union[tmlt.analytics.query_expr.ReplaceInfinity, tmlt.analytics.query_expr.ReplaceNullAndNan]) –

• constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]

propagate_rename(expr, constraints)

Propagate a list of constraints through a Rename transformation.

Parameters

• expr (tmlt.analytics.query_expr.Rename) –

• constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]

propagate_select(expr, constraints)

Propagate a list of constraints through a Select transformation.

Parameters

• expr (tmlt.analytics.query_expr.Select) –

• constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]

propagate_map(expr, constraints)

Propagate a list of constraints through a Map transformation.

Parameters

• expr (tmlt.analytics.query_expr.Map) –

• constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]

propagate_flat_map(expr, constraints)

Propagate a list of constraints through a FlatMap transformation.

Parameters

• expr (tmlt.analytics.query_expr.FlatMap) –

• constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]

propagate_join_private(join_cols, overlapping_cols, left_constraints, right_constraints)

Propagate a list of constraints through a JoinPrivate transformation.

Parameters

• join_cols (Set[str]) –

• overlapping_cols (Set[str]) –

• left_constraints (List[tmlt.analytics.constraints.Constraint]) –

• right_constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]

propagate_join_public(join_cols, overlapping_cols, public_df, constraints)

Propagate a list of constraints through a JoinPublic transformation.

Parameters

• join_cols (Set[str]) –

• overlapping_cols (Set[str]) –

• public_df (pyspark.sql.DataFrame) –

• constraints (List[tmlt.analytics.constraints.Constraint]) –

Return type

List[tmlt.analytics.constraints.Constraint]