Skip to content

Commit

Permalink
feat: Add load_from_parquet and save_to_parquet methods to Signatures…
Browse files Browse the repository at this point in the history
… class
  • Loading branch information
janezlapajne committed Aug 28, 2024
1 parent 47ccb2c commit ce30e67
Show file tree
Hide file tree
Showing 2 changed files with 20 additions and 0 deletions.
8 changes: 8 additions & 0 deletions siapy/entities/signatures.py
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,11 @@ def from_dataframe(cls, dataframe: pd.DataFrame) -> "Signatures":
signals = Signals(dataframe.drop(columns=[Pixels.coords.U, Pixels.coords.V]))
return cls._create(pixels, signals)

@classmethod
def load_from_parquet(cls, filepath: str | Path) -> "Signatures":
df = pd.read_parquet(filepath)
return cls.from_dataframe(df)

@property
def pixels(self) -> Pixels:
return self._pixels
Expand All @@ -109,3 +114,6 @@ def to_numpy(self) -> np.ndarray:

def filter(self) -> SignaturesFilter:
return SignaturesFilter(self.pixels, self.signals)

def save_to_parquet(self, filepath: str | Path) -> None:
self.to_dataframe().to_parquet(filepath, index=True)
12 changes: 12 additions & 0 deletions tests/entities/test_entities_signatures.py
Original file line number Diff line number Diff line change
Expand Up @@ -156,3 +156,15 @@ def test_signatures_from_dataframe():

with pytest.raises(ValueError):
Signatures.from_dataframe(df_missing_v)


def test_signatures_save_and_load_to_parquet():
df = pd.DataFrame({"u": [0, 1], "v": [0, 1], "0": [1, 2], "1": [3, 4]})
signatures = Signatures.from_dataframe(df)
with TemporaryDirectory() as tmpdir:
parquet_file = Path(tmpdir, "test_signatures.parquet")
signatures.save_to_parquet(parquet_file)
assert os.path.exists(parquet_file)
loaded_signatures = Signatures.load_from_parquet(parquet_file)
assert isinstance(loaded_signatures, Signatures)
assert loaded_signatures.to_dataframe().equals(signatures.to_dataframe())

0 comments on commit ce30e67

Please sign in to comment.