o
    SD©iê  ã                   @   sh   d dl mZmZ d dlmZmZ ddlmZ ddlm	Z	 ddl
mZmZ ddlmZ G dd	„ d	eƒZd
S )é    )ÚAnyÚOptional)ÚMetaDataÚ
SchemaItemé   )ÚCustomTableBase)ÚAsQueryOption)ÚClusterByOptionÚClusterByOptionType)ÚTableOptionKeyc                       sR   e Zd Zedee fdd„ƒZddœdedede	d	e
d
eddf‡ fdd„Z‡  ZS )ÚClusteredTableBaseÚreturnc                 C   s   |   tj¡S )N)Ú_get_dialect_optionr   Ú
CLUSTER_BY)Úself© r   úo/var/www/Datamplify/venv/lib/python3.10/site-packages/snowflake/sqlalchemy/sql/custom_schema/clustered_table.pyÚ
cluster_by   s   zClusteredTableBase.cluster_byN)r   ÚnameÚmetadataÚargsr   Úkwc                   sL   |  dd¡rd S t |¡g}| |  |¡¡ tƒ j||g|¢R i |¤Ž d S )NÚ_no_initT)Úgetr	   ÚcreateÚupdateÚ_as_dialect_optionsÚsuperÚ__init__)r   r   r   r   r   r   Úoptions©Ú	__class__r   r   r      s   ÿ zClusteredTableBase.__init__)Ú__name__Ú
__module__Ú__qualname__Úpropertyr   r   r   Ústrr   r   r
   r   r   Ú__classcell__r   r   r    r   r      s"    ûþýüûúùr   N)Útypingr   r   Úsqlalchemy.sql.schemar   r   Úcustom_table_baser   Úoptions.as_query_optionr   Úoptions.cluster_by_optionr	   r
   Úoptions.table_optionr   r   r   r   r   r   Ú<module>   s   