@@ -46,6 +46,7 @@ class TableType(Enum):
46
46
@attr .s
47
47
class JoinTypeEnum (Enum ):
48
48
"""Enum of Join types.
49
+
49
50
The Join comparator can be "INNER_JOIN", "LEFT_JOIN", "RIGHT_JOIN", "FULL_JOIN"
50
51
"""
51
52
@@ -58,6 +59,7 @@ class JoinTypeEnum(Enum):
58
59
@attr .s
59
60
class JoinComparatorEnum (Enum ):
60
61
"""Enum of Join comparators.
62
+
61
63
The Join comparator can be "EQUALS", "GREATER_THAN", "LESS_THAN",
62
64
"GREATER_THAN_OR_EQUAL_TO", or "LESS_THAN_OR_EQUAL_TO"
63
65
"""
@@ -87,15 +89,16 @@ class FeatureGroupToBeMerged:
87
89
catalog (str): A string representing the catalog.
88
90
database (str): A string representing the database.
89
91
table_name (str): A string representing the Athena table name of this FeatureGroup.
90
- record_dentifier_feature_name (str): A string representing the record identifier feature.
92
+ record_identifier_feature_name (str): A string representing the record identifier feature.
91
93
event_time_identifier_feature (FeatureDefinition): A FeatureDefinition representing the
92
94
event time identifier feature.
93
95
target_feature_name_in_base (str): A string representing the feature name in base which will
94
96
be used as target join key (default: None).
95
97
table_type (TableType): A TableType representing the type of table if it is Feature Group or
96
98
Panda Data Frame (default: None).
97
99
feature_name_in_target (str): A string representing the feature in the target feature group
98
- that will be compared to the target feature in the base feature group
100
+ that will be compared to the target feature in the base feature group. If None is
101
+ provided, the record identifier will be used in the join statement. (default: None).
99
102
join_comparator (JoinComparatorEnum): A JoinComparatorEnum representing the comparator used
100
103
when joining the target feature in the base feature group and the feature in the target
101
104
feature group (default: None).
@@ -134,6 +137,14 @@ def construct_feature_group_to_be_merged(
134
137
included in the output.
135
138
target_feature_name_in_base (str): A string representing the feature name in base which
136
139
will be used as target join key (default: None).
140
+ feature_name_in_target (str): A string representing the feature in the target feature group
141
+ that will be compared to the target feature in the base feature group. If None is
142
+ provided, the record identifier will be used in the join statement. (default: None).
143
+ join_comparator (JoinComparatorEnum): A JoinComparatorEnum representing the comparator used
144
+ when joining the target feature in the base feature group and the feature in the target
145
+ feature group (default: None).
146
+ join_type (JoinTypeEnum): A JoinTypeEnum representing the type of join between the base and
147
+ target feature groups. (default: None).
137
148
Returns:
138
149
A FeatureGroupToBeMerged object.
139
150
@@ -283,11 +294,19 @@ def with_feature_group(
283
294
"""Join FeatureGroup with base.
284
295
285
296
Args:
286
- feature_group (FeatureGroup): A FeatureGroup which will be joined to base.
297
+ feature_group (FeatureGroup): A target FeatureGroup which will be joined to base.
287
298
target_feature_name_in_base (str): A string representing the feature name in base which
288
- will be used as target join key (default: None).
299
+ will be used as a join key (default: None).
289
300
included_feature_names (List[str]): A list of strings representing features to be
290
301
included in the output (default: None).
302
+ feature_name_in_target (str): A string representing the feature in the target feature group
303
+ that will be compared to the target feature in the base feature group. If None is
304
+ provided, the record identifier will be used in the join statement. (default: None).
305
+ join_comparator (JoinComparatorEnum): A JoinComparatorEnum representing the comparator used
306
+ when joining the target feature in the base feature group and the feature in the target
307
+ feature group (default: None).
308
+ join_type (JoinTypeEnum): A JoinTypeEnum representing the type of join between the base and
309
+ target feature groups. (default: None).
291
310
Returns:
292
311
This DatasetBuilder object.
293
312
"""
0 commit comments