o QDi@snddlmZddlmZmZddlZddlmZddlmZddl m Z dZ ej d d d Gd d d eZ dS)) annotations)OptionalUnionN)Step)platformResourceinnerTF)kw_onlyreprc@seZdZUdZdZded< dZded< dZd ed < eZ d ed < dddZ dgdddgiddidgddiddZ e dddZ dS) table_joinzlJoin tables. This step can be added using the `steps` parameter for the `transform` function. z table-joinzUnion[Resource, str]resourceNz Optional[str] field_nameFbooluse_hashstrmoder c Cs|}|j}t|tr|jsJ|j|}||}|}|jdvr<|jj D]}|j |j kr;|jj | q*|jdkrV|jrHtjjntjj}||||j |_dS|jdkrp|jrbtjjntjj}||||j |_dS|jdkr|jr|tjjntjj} | |||j |_dS|jdkrtj|||j |_dS|jdkrtj|||_dS|jdkr|jrtjjntjj} | |||j |_dSdS)N)negater leftrightoutercrossr)r isinstancerpackage get_resourceinferto_petlrschemafieldsnamerappendto_copyrrpetlhashjoinjoindata hashleftjoinleftjoin hashrightjoin rightjoin outerjoin crossjoin hashantijoinantijoin) selfrtargetsourceview1view2fieldr%r(r*r.r5\/var/www/Datamplify/venv/lib/python3.10/site-packages/frictionless/steps/table/table_join.pytransform_resource2sB            ztable_join.transform_resourcetypeobjectstring)r rrrrr)r8enum)r fieldNamerhash)required propertiesr cCs|dkrtSdS)Nrr)clsr r5r5r6metadata_select_property_classesz)table_join.metadata_select_property_class)rr )r r)__name__ __module__ __qualname____doc__r8__annotations__rr DEFAULT_MODErr7metadata_profile_patch classmethodrAr5r5r5r6r s.     '  r ) __future__rtypingrrattrspipelinerrrr rGdefiner r5r5r5r6s