def ingest_data()

in pyspark-sdk/src/feature_store_pyspark/FeatureStoreManager.py [0:0]

• 2 lines of code
• 1 McCabe index (conditional complexity)

    def ingest_data(self, input_data_frame: DataFrame, feature_group_arn: str, target_stores: List[str] = None):
        """
        Batch ingest data into SageMaker FeatureStore.

        :param input_data_frame (DataFrame): the DataFrame to be ingested.
        :param feature_group_arn (str): target feature group arn.
        :param target_stores (List[str]): a list of target stores which the data should be ingested to.

        :return:
        """
        return self._call_java("ingestDataInJava", input_data_frame, feature_group_arn, target_stores)