informatica.infacore.dataframe.dataframe.DataFrame.udf

DataFrame.udf(path: str, field_mapping: dict = None)

Chains the UDF to the data pipeline.

Parameters:

  • path (str) – The path of the UDF.

  • field_mapping (dict) – Map of UDF input field and incoming field as “key, value” pair.

  • optional (dict) – Map of UDF input field and incoming field as “key, value” pair.

Returns:

The INFACore DataFrame object.

Return type:

DataFrame

Example

>>> import informatica.infacore as ic
>>> orcl_do = ic.get_data_source("Oracle").get_connection("Oracle Prod").get_data_object("Customers")
>>> infa_df = orcl_do.read().udf("Default/EmailMask", field_mapping={"Input_Email": "Email Id"})