Feathr APIs for Internal Developers

feathr.constants module

feathr.repo_definitions module

class feathr.repo_definitions.RepoDefinitions(sources: Set[feathr.source.Source], features: Set[feathr.feature.Feature], transformations: Set[feathr.transformation.Transformation], feature_anchors: Set[feathr.anchor.FeatureAnchor], derived_features: Set[feathr.feature_derivations.DerivedFeature])[source]

Bases: object

A list of shareable Feathr objects defined in the project.

feathr.job_utils module

feathr.job_utils.get_result_df(client: feathr.client.FeathrClient, format: Optional[str] = None, res_url: Optional[str] = None) → pandas.core.frame.DataFrame[source]

Download the job result dataset from cloud as a Pandas dataframe.

format: format override, could be “parquet”, “delta”, etc. res_url: output URL to download files. Note that this will not block the job so you need to make sure the job is finished and result URL contains actual data.

feathr.feathr_pyspark_driver_template module

feathr.protobuf.featureValue_pb2 module

Generated protocol buffer code.