def get_failed_stream_ingestion_data_frame()

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

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

    def get_failed_stream_ingestion_data_frame(self) -> DataFrame:
        """
        Retrieve DataFrame which includes all records fail to be ingested via ``ingest_data`` method.

        :return: the DataFrame of records that fail to be ingested.
        """
        return self._call_java("getFailedStreamIngestionDataFrame")