We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1992851 commit e90c329Copy full SHA for e90c329
src/dataflow_pipeline.py
@@ -119,7 +119,7 @@ def get_silver_schema(self):
119
).selectExpr(*select_exp)
120
raw_delta_table_stream = self.__apply_where_clause(where_clause, raw_delta_table_stream)
121
return raw_delta_table_stream.schema
122
-
+
123
def __apply_where_clause(self, where_clause, raw_delta_table_stream):
124
"""This method apply where clause provided in silver transformations
125
0 commit comments