@@ -52,9 +52,9 @@ def get_column_specification(self, column: DatabricksColumn, **kwargs): # TOD
5252try :
5353print (type (column .dialect_options ))
5454print (column .dialect_options )
55- print (type (column .dialect_options ['liquid' ].__getitem__ ('cluster ' )))
56- # TODO:BLOODY BINGO - YOU'VE GOT IT SON!! !!!!!
57- print (column .dialect_options ['liquid' ].__getitem__ ('cluster ' ))
55+ print (type (column .dialect_options ['liquid' ].__getitem__ ('cluster_key ' )))
56+ # TODO:THIS WORKS !!!!!
57+ print (column .dialect_options ['liquid' ].__getitem__ ('cluster_key ' ))
5858except Exception as e :
5959pass
6060
@@ -176,15 +176,17 @@ def visit_create_table(self, create, **kw):
176176# print(type(column))
177177#print(column)
178178# print(dir(column))
179- print (column .__dict__ )
179+ # print(column.__dict__)
180180
181181# Check column.kwargs
182182
183- # if column.liquid_cluster is not None:
184- # liquid_cluster = column.liquid_cluster
185- # if liquid_cluster:
186- # liquid_clustering = True
187- # liquid_cluster_columns.append(column.name)
183+ # TODO: Apply Liquid Cluster Logic - column.dialect_options['liquid'].__getitem__('cluster_key')
184+
185+ if column .dialect_options ['liquid' ]is not None :
186+ cluster_on = column .dialect_options ['liquid' ].__getitem__ ('cluster_key' )
187+ if cluster_on :
188+ liquid_clustering = True
189+ liquid_cluster_columns .append (column .name )
188190
189191const = self .create_table_constraints (
190192table ,