File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -180,7 +180,7 @@ Streaming datasets can have a retention period which will let the system manage
180180```python
181181streaming_dataset_users = client.create_streaming_dataset(table_name = ' streaming_user_data' )
182182streaming_feature_group_users = client.describe_feature_group_by_table_name(table_name = ' streaming_user_data' )
183- streaming_feature_group_user.set_feature_group_record_attributes (record_timestamp_feature = ' update_timestamp' , record_id_feature = ' user_id' )
183+ streaming_feature_group_user.set_record_attributes (record_timestamp_feature = ' update_timestamp' , record_id_feature = ' user_id' )
184184streaming_dataset_users.set_streaming_retention_policy(data_retention_hours = 48 , data_retention_row_count = 2_000_000_000 )
185185```
186186
@@ -200,7 +200,7 @@ We can also create a streaming feature group which behaves like a log of events
200200```python
201201streaming_dataset_user_activity = client.create_streaming_dataset(table_name = ' streaming_user_activity' )
202202streaming_feature_group_user_activity = client.describe_feature_group_by_table_name(table_name = ' streaming_user_activity' )
203- streaming_feature_group_user_activity.set_feature_group_record_attributes (record_timestamp_feature = ' event_timestamp' , lookup_key_features = [' user_id' ])
203+ streaming_feature_group_user_activity.set_record_attributes (record_timestamp_feature = ' event_timestamp' , lookup_key_features = [' user_id' ])
204204```
205205
206206Data can be added to this dataset using the append_data api call. If the `recordTimestamp` attribute
You can’t perform that action at this time.
0 commit comments