
    h8                       % S SK Jr  S SKJrJrJrJr  S SKJr  S SK	J
r
JrJrJrJrJrJrJrJr  \(       a  S SKrS SKrS SKJrJrJrJr  S SKJr  S SKJrJr  S S	KJr  S S
K J!r!J"r"J#r#J$r$  S SK%J&r'  S SK%J(r)  S SK%J*r+  S SK%J,r,  S SK-J.r.J/r/J0r0J1r1  S SK2J3r3  S SK4J5r5  \Rl                  " \75         S SK8J9r9  SSS5        \Rt                  S:  a  S SK	J;r;  OS SK<J;r;   " S S\5      r= " S S\5      r> " S S\5      r?\S   r@S\AS'   \\BS   S4   rCS\AS'   \\BS    S 4   rDS\AS!'   \\@\\@   4   rES\AS"'   \\B\F   \B\G   \B\H   \B\I   \BS#   \BS$   \BS%   \BS&   \B\J\      \B\K\S'4      \B\L   \B\M   \BS(   \BS   4   rNS\AS)'   \\\I\\@\NS4   4   \\\I\K\I\\@\NS4   4   4      4   rOS\AS*'   \\I\@4   rPS\AS+'   \\F\GS(4   rQS\AS,'   \S-   rRS\AS.'   \\Q\R\I\H\L4   rSS\AS/'   \\SS0\J\   4   rTS\AS1'   \S2S3\I4   rUS\AS4'   \\T\US4   rVS\AS5'   \S6   rWS\AS7'   S8rXS\AS9'   \\I\X4   rYS\AS:'   \S;   rZS\AS<'   \S=   r[S\AS>'   \S?   r\S\AS@'   \SA   r]S\ASB'   \SC   r^S\ASD'   \K\SE   SF4   r_S\ASG'   \K\SH   \`\F\S3\I4   4   4   raS\ASI'   \K\SJ   \`\F\J\I   4   4   rbS\ASK'   \SL   rcS\ASM'   \SN   rdS\ASO'   \SP   reS\ASQ'   \SR   rfS\ASS'   \ST   rgS\ASU'   \SV   rhS\ASW'   \SX   riS\ASY'   \SZ   rjS\AS['   \S\   rkS\AS]'   \S^   rlS\AS_'   \S`   rmS\ASa'   \Sb   rnS\ASc'   \Sd   roS\ASe'   \Sf   rpS\ASg'   \Sh   rqS\ASi'   \Sj   rrS\ASk'   \Sl   rsS\ASm'   \Sn   rtS\ASo'   \Sp   ruS\ASq'   \Sr   rvS\ASs'   \St   rwS\ASu'   \Sv   rxS\ASw'   \Sx   ryS\ASy'   \Sz   rzS\AS{'   \S|   r{S\AS}'   \S~   r|S\AS'   \S   r}S\AS'   \S   r~S\AS'   \S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \S   r\S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \S   r\S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \S   rS\AS'   \\\I\\\M   \\I\\M   4   S34   4   \\   S0SSSSS4   rS\AS'   \\\Y\K\YS'4   4   \\I\\I\I4   4   4   rS\AS'   \\\Y\\I   4   \\I\\\I\4   \\\I\\I\4   4      4   4   4   rS\AS'   \\\\Y\K\Y   4   \I4   \\I   \H4   rS\AS'   \\\Y\\K\IS'4   \F4   4   \F4   rS\AS'   \\\I\\I\\I   4   4   \\I   \H4   rS\AS'   \S   rS\AS'   \" SSSS3S25      r\" SSS5      r\K\F\F\F4   rS\AS'   \S   rS\AS'    " S S\5      r " S S\5      r " S S\5      r " S S\5      r\S   rS\AS'   \\\\\4   rS\AS'   \FrS\AS'   \\\\\F   S3S04   rS\AS'   \IrS\AS'   \\\\I   S3S04   rS\AS'   \\\H   S3S04   rS\AS'   \\\4   rS\AS'   \\\\4   rS\AS'   \\S   S4   rS\AS'   \S   rS\AS'   \\I\\
\L   \L\J\I   \J\   \J\
\L      \J\L   4   rS\AS'   \\\/\L4   \\/\I4   4   r\S   rS\AS'    " S S5      r/ SQr " S S5      r\\/\`\I\I4   4   rS\AS'   \\`\I\I4   \4   rS\AS'   g! , (       d  f       GN= f)    )annotations)
CollectionIterableMappingSequence)Path)	IOTYPE_CHECKINGAnyCallableLiteralProtocol	TypedDictTypeVarUnionN)datedatetimetime	timedelta)Decimal)
ConnectionEngine)Session)	DataFrameExpr	LazyFrameSeries)numpy)pandas)pyarrow)torch)DataTypeDataTypeClassIntegerTypeTemporalType)	GPUEngine)Selector)PyPartitioning)   
   )	TypeAliasc                  .    \ rS rSrSr S   SS jjrSrg)ArrowArrayExportable,   zGType protocol for Arrow C Data Interface via Arrow PyCapsule Interface.Nc                    g N selfrequested_schemas     H/home/james-whalen/.local/lib/python3.13/site-packages/polars/_typing.py__arrow_c_array__&ArrowArrayExportable.__arrow_c_array__/   s     #    r1   r0   )r4   object | Nonereturnztuple[object, object])__name__
__module____qualname____firstlineno____doc__r6   __static_attributes__r1   r8   r5   r-   r-   ,   s$    Q 15$ -$	$ $r8   r-   c                  &    \ rS rSrSrSSS jjrSrg)ArrowStreamExportable4   zIType protocol for Arrow C Stream Interface via Arrow PyCapsule Interface.Nc                    g r0   r1   r2   s     r5   __arrow_c_stream__(ArrowStreamExportable.__arrow_c_stream__7   s    TWr8   r1   r0   )r4   r9   r:   object)r;   r<   r=   r>   r?   rE   r@   r1   r8   r5   rB   rB   4   s    SWWr8   rB   c                  "    \ rS rSrSrSS jrSrg)ArrowSchemaExportable:   zIType protocol for Arrow C Schema Interface via Arrow PyCapsule Interface.c                    g r0   r1   r3   s    r5   __arrow_c_schema__(ArrowSchemaExportable.__arrow_c_schema__=   s    Cr8   r1   N)r:   rG   )r;   r<   r=   r>   r?   rM   r@   r1   r8   r5   rI   rI   :   s    S/r8   rI   )r#   r"   r+   PolarsDataTyper%   PolarsTemporalTyper$   PolarsIntegerTypeOneOrMoreDataTypesr   r   r   r   .r   PythonDataTypeSchemaDefinition
SchemaDictNumericLiteral)r   r   r   r   TemporalLiteralNonNestedLiteralznp.ndarray[Any, Any]PythonLiteralr   r   IntoExprColumnIntoExpr)eqneqgtltgt_eqlt_eqComparisonOperatorr'   SelectorTypeColumnNameOrSelector)earliestlatestraisenull	Ambiguous)uncompressedsnappydeflateAvroCompression)	necessaryalwaysnon_numericneverCsvQuoteStyle)physicallexicalCategoricalOrdering)utf8z
utf8-lossyCsvEncodingziceberg-column-mappingz	pa.SchemaColumnMappingicebergDefaultFieldValuesziceberg-position-deleteDeletionFiles)forwardbackwardminmaxmeanzerooneFillNullStrategy)fullmixedFloatFmt)cfortran
IndexOrder)rj   lz4zstdIpcCompression)zm:mzm:1z1:mz1:1JoinValidation)leftright	datapointLabel)noner   r   
left_right
right_leftMaintainOrderJoin)rg   rh   NonExistent)ignoredropNullBehavior)autocolumns
row_groupsprefilteredr   ParallelStrategy)r   rj   rk   gziplzobrotlir   ParquetCompression)r~   r   firstlastsumr   medianlenPivotAgg)nearesthigherlowermidpointlinearequiprobableQuantileMethod)averager~   r   denseordinalrandom
RankMethod)rg   r|   r}   Roll)half_to_evenhalf_away_from_zero	RoundMode)binaryjsonSerializationFormat)littlebig
Endianness)
bkbmbgbtbbytes	kilobytes	megabytes	gigabytes	terabytesSizeUnit)	windowr   mondaytuesday	wednesdaythursdayfridaysaturdaysundayStartBy)dataallSyncOnCloseMethod)nsusmsTimeUnit)NFCNFKCNFDNFKDUnicodeForm)r   r   anyr   UniqueKeepStrategy)vertical
horizontalUnstackDirection)thread_local	threadingMapElementsStrategy)r}   r|   r   AsofJoinStrategy)r   r   bothr   ClosedInterval)r   r   InterpolationMethod)innerr   r   r   semianticrossouterJoinStrategy)first_non_null	max_widthListToStructWidthStrategy)
r   vertical_relaxeddiagonaldiagonal_relaxedr   align
align_fullalign_inner
align_leftalign_right)pearsonspearmanCorrelationMethod)adbc
connectorxDbReadEngine)
sqlalchemyr   DbWriteEngine)replaceappendfailDbWriteMode)r   r   r   sd)arraydictJaxExportType)colrowOrientation)r   r   r   SearchSortedSide)tensordatasetr  TorchExportType)hexbase64TransferEncoding)group_to_rowsjoinexplodeWindowMappingStrategy)plaintreeExplainFormatzpa.Tablezpd.DataFrameztorch.TensorFrameInitTypesColumnFormatDictConditionalFormatDictColumnTotalsDefinitionColumnWidthsDefinitionRowTotalsDefinition)fastbalanced	expensiveParametricProfileNames
PolarsTyper   r   	FrameType
BufferInfo)calamineopenpyxlxlsx2csvExcelSpreadsheetEnginec                  8    \ rS rSr% SrS\S'   S\S'   S\S'   Srg	)
SeriesBuffersi  zUnderlying buffers of a Series.r   valueszSeries | Nonevalidityoffsetsr1   N)r;   r<   r=   r>   r?   __annotations__r@   r1   r8   r5   r0  r0    s    )Nr8   r0  c                      \ rS rSrSS jrSrg)BasicConnectioni  c                    g)zReturn a cursor object.Nr1   r3   argskwargss      r5   cursorBasicConnection.cursor      r8   r1   Nr9  r   r:  r   r:   r   )r;   r<   r=   r>   r;  r@   r1   r8   r5   r6  r6    s    &r8   r6  c                      \ rS rSrSS jrSrg)BasicCursori  c                    g)zExecute a query.Nr1   r8  s      r5   executeBasicCursor.execute  r=  r8   r1   Nr>  )r;   r<   r=   r>   rB  r@   r1   r8   r5   r@  r@    s    r8   r@  c                  (    \ rS rSrSS jrSS jrSrg)Cursori   c                    g)zFetch all results.Nr1   r8  s      r5   fetchallCursor.fetchall!  r=  r8   c                    g)zFetch results in batches.Nr1   r8  s      r5   	fetchmanyCursor.fetchmany$  r=  r8   r1   Nr>  )r;   r<   r=   r>   rG  rJ  r@   r1   r8   r5   rE  rE     s    !(r8   rE  )r   r   r   AlchemyConnectionConnectionOrCursorSingleIndexSelectorMultiIndexSelectorSingleNameSelectorMultiNameSelectorBooleanMaskSingleColSelectorMultiColSelector)r   z	in-memory	streaminggpur&   
EngineType)irrs   	PlanStage
FileSource)functionrenamed_parameterstreaming_parameternonkeyword_argumentsparameter_as_multi_positionalDeprecationTypec                  :    \ rS rSr    SS jr\SS j5       rSrg)PartitioningSchemeib  c                    Xl         g r0   _py_partitioning)r3   py_partitionings     r5   __init__PartitioningScheme.__init__c  s
     !0r8   c                .    U R                   R                  $ r0   )re  	base_pathrL   s    r5   
_base_pathPartitioningScheme._base_pathi  s    $$...r8   rd  N)rf  r(   r:   None)r:   z
str | None)r;   r<   r=   r>   rg  propertyrk  r@   r1   r8   r5   rb  rb  b  s-    0'0 
0 / /r8   rb  )\ri   r-   rB   r   rm   rR  r*  ru   r   r  rd   r!  r"  rb   ConcatMethodr   rM  r   rw   rr   rE  r  r  r  r`  r   rW  EpochTimeUnitr.  r  rZ  r   r   r  r)  r   r   r[   rZ   r   JSONEncoderr  r   r   r   r   r   r   rT  rO  rQ  r   rX   r   rV   rR   r  r   r'  r   rb  r   rO   rQ   rP   r(  rS   rY   r   r   r   r#  rT   rU   r  rc   r   r0  rS  rN  rP  r   r   r   rW   r   r  r  r   r   r   r  c                  .    \ rS rSr% SrSS jrS\S'   Srg)	ParquetMetadataContexti  z
The context given when writing file-level parquet metadata.

.. warning::
    This functionality is considered **experimental**. It may be removed or
    changed at any point without it being considered a breaking change.
arrow_schemastrc                   Xl         g r0   rt  )r3   rt  s     r5   rg  ParquetMetadataContext.__init__  s    (r8   rw  N)rt  ru  r:   rm  )r;   r<   r=   r>   r?   rg  r4  r@   r1   r8   r5   rs  rs    s    ) r8   rs  ParquetMetadataFnParquetMetadata)
__future__r   collections.abcr   r   r   r   pathlibr   typingr	   r
   r   r   r   r   r   r   r   
contextlibsysr   r   r   r   decimalr   sqlalchemy.enginer   r   sqlalchemy.ormr   polarsr   r   r   r   polars._dependenciesr   npr   pdr    par!   polars.datatypesr"   r#   r$   r%   polars.lazyframe.engine_configr&   polars.selectorsr'   suppressImportErrorpolars._plrr(   version_infor+   typing_extensionsr-   rB   rI   rO   r4  typerP   rQ   rR   intfloatboolru  listtupler   rG   rS   rT   rU   rV   rW   rX   rY   rZ   r[   rb   rc   rd   ri   rm   rr   ru   rw   rx   r  rz   r{   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   ro  r   r  r  r  rp  r  r  r  r  r  r  r  r  r  r   r!  r"  r#  r'  r(  r)  r*  r.  r0  r6  r@  rE  rL  rM  rN  slicerangerO  rP  rQ  rR  rS  rT  rW  rY  rZ  rq  r`  rb  __all__rs  ry  rz  r1   r8   r5   <module>r     s
   " C C 
 
 
 884&99012*SS8)			[	). 
* 7"$/$8 $XH X0H 0 ""=>	 > %d>&:N&J K I K$T-%8-%GH 9 H %nh~6N&N O I O!IKJILLcOsCxKLOJ	 " $C~~t;<<=U3c5)M#NNOOPQS )   ^ 34
I 4!#ui"78	 8"#JK K#NOS$PU$UV ) V !13I4PS9!TUy U!&(C"78	 8M>4?@) @ '(Q R I R %i $"'\(9": i : DE	9 E$%HI I"#PQy Q!()>!? Y ? !56Y 6 )A!BK!OPy P %IS%#"6677! I  !%&S$s)^(<<y  &> )  o.) ./
I /#$AB	 B#$>?	 ?78y 8&7  9  !1Y 1!"23i 3%: )  !(D! I  A)  $F	    UV
I V89i 9DE	9 E!()9!: Y :0
I 0	)  
 
  '}5 9 5./) / !=>Y > '(F G I G%&>? ) ?!()D!E Y E &&FG ) G#$CD	 D!()<!= Y =!Fi  (//L'M 9 M 	  ''<= 9 =!"67i 7"#78y 8 !<=Y =23"?3y 3 .Y .%&<= ) =$%@A A%o6 ) 6#*+M#N y N"?3y 3 "Cx'hv6F1F)GQRRSSM		 	 &	
&:C&? @
@A	#wsCx 
 !# ) 
 $+	

3
/0	#uWS#X&sGCH<M7M1N(OOP
PQS$ y 
 %*E&.B(CCDcIJSM
% 	  %* %c3h(<"==>C% 	  "'CsJsO+,,-sO
" Y  %,,K$L 	 L \;XvN
Kk:	c3m,
I , %,,N$O 	 OI &h &
( 
([ (  %%FG 9 G %[&*;;! I 
 "% Y $ %		SM	! I  !$ I #$	SM  9  TNY 
  %%8:L%LM 9 M#$68I;$VW ) W 34kA
I  /0	9 0uI	IJEOK	
I 	 HcUE\*HcUCZ,@@A$% 	/ 	/]@   ()?(@$sCx.(PQ 9 Q"4S>3D#DE Ew 
*	)s   -Y88
Z