We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 70c7c24 commit 30117ecCopy full SHA for 30117ec
sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py
@@ -177,8 +177,7 @@ def get_table_query_string(self) -> str:
177
"""Returns a string that can directly be used to reference this table in SQL"""
178
if self.table:
179
# Backticks make sure that spark sql knows this a table reference.
180
- # return f"`{self.table}`"
181
- table = '.'.join(map(lambda x: f'`{x}`', self.table.split('.')))
+ table = ".".join([f"`{x}`" for x in self.table.split(".")])
182
return table
183
if self.query:
184
return f"({self.query})"
0 commit comments