Skip to content

Commit

Permalink
add dot
Browse files Browse the repository at this point in the history
  • Loading branch information
jalencato committed Nov 6, 2024
1 parent e1d6cb9 commit 8c3c79e
Showing 1 changed file with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,15 +36,15 @@ def apply_transform(
Parameters
----------
cols : Sequence[str]
List of column names to apply normalization to
List of column names to apply normalization to.
separator: str, optional
The separator for string input value. Only required when input value type is string
The separator for string input value. Only required when input value type is string.
spark: SparkSession
The spark session
The spark session.
input_df : DataFrame
The input DataFrame to apply transformation to
The input DataFrame to apply transformation to.
edge_mapping_dict: dict
The mapping dictionary contain mapping file directory and edge type
The mapping dictionary contain mapping file directory and edge type.
"""
column_type = input_df.schema[cols[0]].dataType
if isinstance(column_type, StringType):
Expand Down Expand Up @@ -86,11 +86,11 @@ class DistHardNegativeTransformation(DistributedTransformation):
Parameters
----------
separator: str, optional
The separator for string input value. Only required when input value type is string
The separator for string input value. Only required when input value type is string.
spark: SparkSession
The spark session
The spark session.
edge_mapping_dict: dict
The node type and mapping directory
The node type and mapping directory.
"""

def __init__(
Expand Down

0 comments on commit 8c3c79e

Please sign in to comment.