
    XIg                         d dl mZmZmZ ddlmZ erddlmZ ddlm	Z	 ee
eeef   Zee   Z G d d      Z G d d	      Zd	dgZy
)    )TYPE_CHECKINGOptionalUnion   )
StructType	DataFrame)SparkSessionc                   $    e Zd ZddZdeddfdZy)DataStreamWriterc                     || _         y N)	dataframe)selfr   s     d/var/www/html/answerous/venv/lib/python3.12/site-packages/duckdb/experimental/spark/sql/streaming.py__init__zDataStreamWriter.__init__   s	    "    
table_namereturnNc                     t         r   )NotImplementedError)r   r   s     r   toTablezDataStreamWriter.toTable   s    !!r   )r   r	   )__name__
__module____qualname__r   strr    r   r   r   r      s    #"# "$ "r   r   c                   P    e Zd Zd
dZ	 	 	 ddee   dee   deeedf   deddf
d	Z	y)DataStreamReaderc                     || _         y r   )session)r   r!   s     r   r   zDataStreamReader.__init__   s	    r   Npathformatschemaoptionsr   r	   c                     ddl m} t        )Nr   r   )'duckdb.experimental.spark.sql.dataframer	   r   )r   r"   r#   r$   r%   r	   s         r   loadzDataStreamReader.load   s     	F!!r   )r!   r
   )NNN)
r   r   r   r   r   r   r   r   OptionalPrimitiveTyper(   r   r   r   r   r      s[    
 # $/3		"sm	" 	" j#t+,		"
 )	" 
	"r   r   N)typingr   r   r   typesr   r   r	   r!   r
   boolfloatintr   PrimitiveTyper)   r   r   __all__r   r   r   <module>r1      sV    1 1 $%dE3+, / " "" "  1
2r   