We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a802cfe commit 21fa5bcCopy full SHA for 21fa5bc
sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark.py
@@ -324,8 +324,7 @@ def _to_df_internal(self) -> pd.DataFrame:
324
return self.to_spark_df().toPandas()
325
326
def _to_arrow_internal(self) -> pyarrow.Table:
327
- """Return dataset as pyarrow Table synchronously"""
328
-
+ """Return dataset as pyarrow Table synchronously"""
329
return pyarrow.Table.from_pandas(self._to_df_internal())
330
331
def persist(self, storage: SavedDatasetStorage, allow_overwrite: bool = False):
0 commit comments