Skip to content

Commit

Permalink
Merge branch 'fds-add-vertical-even-partitioner' of github.com:adap/f…
Browse files Browse the repository at this point in the history
…lower into fds-add-vertical-even-partitioner
  • Loading branch information
adam-narozniak committed Dec 19, 2024
2 parents ed3ddde + 382fbd6 commit 664032d
Showing 1 changed file with 9 additions and 6 deletions.
15 changes: 9 additions & 6 deletions datasets/flwr_datasets/partitioner/vertical_even_partitioner.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
class VerticalEvenPartitioner(Partitioner):
"""Partitioner that splits features (columns) evenly into vertical partitions.
Enables selection of "active party" column(s) and palcement into
Enables selection of "active party" column(s) and placement into
a specific partition or creation of a new partition just for it.
Also enables droping columns and sharing specified columns across
all partitions.
Expand Down Expand Up @@ -63,18 +63,21 @@ class VerticalEvenPartitioner(Partitioner):
Examples
--------
>>> from flwr_datasets import FederatedDataset
>>> from flwr_datasets.partitioner import VerticalEvenPartitioner
>>>
>>> partitioner = VerticalEvenPartitioner(
... num_partitions=3,
... active_party_column="income",
... active_party_column_mode="add_to_last",
... active_party_columns="income",
... active_party_columns_mode="add_to_last",
... shuffle=True,
... seed=42
... )
>>> fds = FederatedDataset(
... dataset="scikit-learn/adult-census-income",
... partitioners={"train": partitioner}
... )
>>> partitions = [fds.load_partition(i) for i in range(partitioner.num_partitions)]
>>> partitions = [fds.load_partition(i) for i in range(fds.partitioners["train"].num_partitions)]
>>> print([partition.column_names for partition in partitions])
"""

Expand Down Expand Up @@ -178,7 +181,7 @@ def num_partitions(self) -> int:

def _validate_parameters_in_init(self) -> None:
if self._num_partitions < 1:
raise ValueError("column_distribution as int must be >= 1.")
raise ValueError("`column_distribution` as int must be >= 1.")

valid_modes = {
"add_to_first",
Expand All @@ -192,7 +195,7 @@ def _validate_parameters_in_init(self) -> None:
or self._active_party_columns_mode in valid_modes
):
raise ValueError(
"active_party_column_mode must be an int or one of "
"`active_party_column_mode` must be an int or one of "
"'add_to_first', 'add_to_last', 'create_as_first', 'create_as_last', "
"'add_to_all'."
)
Expand Down

0 comments on commit 664032d

Please sign in to comment.