@@ -37,24 +37,24 @@ def get_column_specification(self, column: DatabricksColumn, **kwargs): # TOD
3737 )
3838 )
3939
40- # Consider the 'liquid_cluster' attribute
41- if column .dialect_options and 'liquid' in column .dialect_options :
42- liquid_options = column .dialect_options ['liquid' ]
43- if 'liquid_cluster' in liquid_options and liquid_options ['liquid_cluster' ]:
44- colspec += " LIQUID_CLUSTER"
45- # TODO this else statement is a debugging line
46- else :
47- print (liquid_options )
40+ ## Consider the 'liquid_cluster' attribute
41+ # if column.dialect_options and 'liquid' in column.dialect_options:
42+ # liquid_options = column.dialect_options['liquid']
43+ # if 'liquid_cluster' in liquid_options and liquid_options['liquid_cluster']:
44+ # colspec += " LIQUID_CLUSTER"
45+ # # TODO this else statement is a debugging line
46+ # else:
47+ # print(liquid_options)
4848
4949# TODO: debugging lines
5050# print(type(colspec))
5151print (colspec )
5252try :
5353print (type (column .dialect_options ))
5454print (column .dialect_options )
55- print (type (column .dialect_options ['liquid ' ].__getitem__ ('cluster_key' )))
55+ print (type (column .dialect_options ['databricks ' ].__getitem__ ('cluster_key' )))
5656# TODO: THIS WORKS!!!!!
57- print (column .dialect_options ['liquid ' ].__getitem__ ('cluster_key' ))
57+ print (column .dialect_options ['databricks ' ].__getitem__ ('cluster_key' ))
5858except Exception as e :
5959pass
6060
@@ -182,8 +182,8 @@ def visit_create_table(self, create, **kw):
182182
183183# TODO: Apply Liquid Cluster Logic - column.dialect_options['liquid'].__getitem__('cluster_key')
184184
185- if column .dialect_options ['liquid ' ]is not None :
186- cluster_on = column .dialect_options ['liquid ' ].__getitem__ ('cluster_key' )
185+ if column .dialect_options ['databricks ' ]is not None :
186+ cluster_on = column .dialect_options ['databricks ' ].__getitem__ ('cluster_key' )
187187if cluster_on :
188188liquid_clustering = True
189189liquid_cluster_columns .append (column .name )