Commit 67e3ca3 1 parent 8eb0c59 commit 67e3ca3 Copy full SHA for 67e3ca3
File tree 1 file changed +30
-0
lines changed
sdk/python/feast/infra/offline_stores/contrib/spark_offline_store
1 file changed +30
-0
lines changed Original file line number Diff line number Diff line change @@ -185,6 +185,36 @@ def get_table_query_string(self) -> str:
185
185
186
186
return f"`{ tmp_table_name } `"
187
187
188
+ def __eq__ (self , other ):
189
+ if other is None :
190
+ return False
191
+
192
+ if not isinstance (other , SparkSource ):
193
+ raise TypeError ("Comparisons should only involve SparkSource class objects." )
194
+
195
+ if (
196
+ self .name != other .name
197
+ or self .timestamp_field != other .timestamp_field
198
+ or self .created_timestamp_column != other .created_timestamp_column
199
+ or self .field_mapping != other .field_mapping
200
+ or self .date_partition_column != other .date_partition_column
201
+ or self .description != other .description
202
+ or self .tags != other .tags
203
+ or self .owner != other .owner
204
+ ):
205
+ return False
206
+ if self .table != other .table :
207
+ return False
208
+ if self .query != other .query :
209
+ return False
210
+ if self .path != other .path :
211
+ return False
212
+
213
+ return True
214
+
215
+ def __hash__ (self ):
216
+ return super ().__hash__ ()
217
+
188
218
189
219
class SparkOptions :
190
220
allowed_formats = [format .value for format in SparkSourceFormat ]
You can’t perform that action at this time.
0 commit comments