spark-expectations

View on PyPIReverse Dependencies (1)

2.2.1 spark_expectations-2.2.1-py3-none-any.whl

Wheel Details

Project: spark-expectations
Version: 2.2.1
Filename: spark_expectations-2.2.1-py3-none-any.whl
Download: [link]
Size: 1022944
MD5: 878feac7a0553814c876f8f47aba3d28
SHA256: ca551d21fcfd1452897ecda5acce150b4f70d0ce3412375eaf40fa3116305517
Uploaded: 2024-11-11 18:11:07 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: spark-expectations
Version: 2.2.1
Summary: This project helps us to run Data Quality Rules in flight while spark job is being run
Author: Ashok Singamaneni
Author-Email: ashok.singamaneni[at]nike.com
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Requires-Python: >=3.9,<3.13
Requires-Dist: pluggy (>=1)
Requires-Dist: pyspark (<4.0.0,>=3.0.0)
Requires-Dist: requests (>=2.28.1)
Description-Content-Type: text/markdown
[Description omitted; length: 7559 characters]

WHEEL

Wheel-Version: 1.0
Generator: poetry-core 1.9.1
Root-Is-Purelib: true
Tag: py3-none-any

RECORD

Path Digest Size
spark_expectations/__init__.py sha256=XsOcV4FqJUVD-Xx1H1xUjZ4jLFRDGy49V8p5lkYXHXU 788
spark_expectations/config/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
spark_expectations/config/user_config.py sha256=1-vRQcD0F4B6qk4PMFtMeDFdalFhlpI3UzdPlGZCTuk 3858
spark_expectations/core/__init__.py sha256=zh_8zWGVtPTnhic0CNem2XbDWxZCgEovjQiUKsOX4Mo 1478
spark_expectations/core/context.py sha256=nVaC0N7goAJ4C8albn3MDmeLXSdrpnVIQPKSsYGREKw 63204
spark_expectations/core/exceptions.py sha256=ta-MlWUpIydZHRD-G_KRmIPz2GsoNBfVFCRGd7raQB0 1822
spark_expectations/core/expectations.py sha256=KQonKME_J63yYPJK5Oj-D9QXDsp7GI4vcCcgXpdUOxg 35411
spark_expectations/examples/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
spark_expectations/examples/base_setup.py sha256=1jSDsC30_9USWa9ZjHs1wwErgM3MequI91i-JnpeThw 8627
spark_expectations/examples/docker_scripts/Dockerfile sha256=JEj-TSMKH1rHypclRdciEfvV3P61HccbLmt-eBMQ7E4 870
spark_expectations/examples/docker_scripts/create_kafka_topic.sh sha256=whOxwY3CYd_9g3_YQMykfuw_I3mXKurWD-Kc4Z2BvV4 966
spark_expectations/examples/docker_scripts/delete_kafka_topic.sh sha256=nLOW2lzjQMs66BewjJ_UMJImT9bEDiMPMN9vuZ2c-Uc 1034
spark_expectations/examples/docker_scripts/docker_kafka_start_script.sh sha256=aTlzprDj9EXqhB81SDlMSmhxroRXOFjD5BxGQ8Vx8UI 919
spark_expectations/examples/docker_scripts/docker_kafka_stop_script.sh sha256=OUaFRa5LgDCMEVkWTR7DHtcn-6zYtVXZRZlNNibrIT4 330
spark_expectations/examples/docker_scripts/kafka_cluster_start.sh sha256=xObUGH61EWkeQDAKmLzjUDMslhSFf4Br_kX-dlJI9uk 218
spark_expectations/examples/docker_scripts/kafka_cluster_stop.sh sha256=ATiVC6fF5Mw_wqe25UjTxN6kyP6u4k3BmZ5VrnqyTIg 141
spark_expectations/examples/docker_scripts/start-kafka.sh sha256=DbNlxVTYUvfaCMc_-mQbG1df_Z_lVTFwVCt8GpSjmxw 433
spark_expectations/examples/read_example_dataset.py sha256=DYvDC5LJvVo8uo_YrZPrT0n-gEG7pLF2o3TJoWe44hk 1366
spark_expectations/examples/resources/customer.csv sha256=rBbE73udc6Vh1_huASBImfFp6ncQY1SHxsFekWfKNCE 385487
spark_expectations/examples/resources/customer_source.csv sha256=ldDA5rJMP30-IvI6bTq_uRIVFiRpm6-5lHHW27AsU94 394
spark_expectations/examples/resources/customer_target.csv sha256=iy7lR0m_d38AC_Eug88YbDnxCpMQKvD8lmxztvs6y84 474
spark_expectations/examples/resources/employee.csv sha256=jG7VLhYvZa3IIYXotO5YlqlK1Yo4MYHmkZq2LOFu80M 122408
spark_expectations/examples/resources/order_1.csv sha256=-SC_Z3nb7UH585Yo3LsULPU2kbDeBwL_ytQWZZYw1Rw 981149
spark_expectations/examples/resources/order_s.csv sha256=t3xrU0p-_j6Cprh-bmomBe0YC2OnBkx94BP9p0c3ZkY 585
spark_expectations/examples/resources/order_t.csv sha256=GHAOVqIgSfTZVC5d-vYHytOVC2ehmSwHE8TQu6XyKrs 486
spark_expectations/examples/resources/product.csv sha256=0Z8hko_H-zLMvLb_Yse03tnpzCdUdj9hU5IHhqvwGcc 145357
spark_expectations/examples/resources/superstore.csv sha256=cg_jAgUrxcaToJ8a1HOmKG0THVwFE8VpPijCCfBO3AY 2288625
spark_expectations/examples/sample_dq_bigquery.py sha256=Abi81aYqpp094VIPuLWTn7tWC3C9Jus-hrJf8soLUNI 4693
spark_expectations/examples/sample_dq_delta.py sha256=lkAHg4D2lR3FucRFfHnaaiRbA44ZU0RlyEWQTXmgthc 4963
spark_expectations/examples/sample_dq_iceberg.py sha256=9BMZnfl_7xyrsAO7Mw_Cz8rouMGNoRztjO8oilZj5Qw 5318
spark_expectations/notifications/__init__.py sha256=hSwzA5YO03s-ALT7aC_IBc0ejQ8naECzcWOyCHzCiFQ 1738
spark_expectations/notifications/plugins/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
spark_expectations/notifications/plugins/base_notification.py sha256=vRG3HBtOdaPnPK-lg2c_FzTjmHj4tDOLYJqm39HIHnA 1001
spark_expectations/notifications/plugins/email.py sha256=5nPwsObIstEN-oYq6ORguLV9BrimM_76u5mBkm373Xg 2361
spark_expectations/notifications/plugins/slack.py sha256=JTmGrt_lVHdf34A-5ErlKXmfkMb5ZBlV7-FMsNcpkX0 1907
spark_expectations/notifications/plugins/teams.py sha256=KYmdw9B7zwDuqjvOCS-NM26Do7eK0G_s5i9HH3elCnY 2252
spark_expectations/notifications/plugins/zoom.py sha256=B_Du_VJIYL7bzQtvWEik9xICXExLayUMd6rkkXpMFlc 2401
spark_expectations/notifications/push/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
spark_expectations/notifications/push/spark_expectations_notify.py sha256=gGxFOix-465ygw8vO6jMWAipTAx16HoODEZuX0UHLQg 11818
spark_expectations/secrets/__init__.py sha256=BMNZBsi17XZ7ml6w3dbwi4_pwi2ya5cXHiAu11z9NCs 4363
spark_expectations/sinks/__init__.py sha256=N3kFmxOIg7c4IpwA4nziQo9hHaAk6ZvHzq95v8Qg0Zs 1000
spark_expectations/sinks/plugins/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
spark_expectations/sinks/plugins/base_writer.py sha256=qMTyQQnyVvNAKec3yEQ_DWDZXDj4gElDQrlPlM_OmB0 705
spark_expectations/sinks/plugins/kafka_writer.py sha256=E7MkA1tQ1nZwR8OGndvx48XmTFPIIfpKHaDmA6W00zY 1616
spark_expectations/sinks/utils/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
spark_expectations/sinks/utils/collect_statistics.py sha256=CqH7af6LRC5FXIo1GkaVBzGi-RtOHsECFr-LJ_dmf5I 1686
spark_expectations/sinks/utils/writer.py sha256=LMdfxA07fsCZCS3Qi2oJPT_6fEiXOfSuV8wiy0ynxQM 43200
spark_expectations/utils/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
spark_expectations/utils/actions.py sha256=O1agi8ODzZZCpF7B-R6DJxGJokim3MEJRp-Zcb7eLEQ 29164
spark_expectations/utils/reader.py sha256=Xx3PZYZ_vL7KxAjSr9sSt2lqITGsTysDy93KqRLmDbE 18394
spark_expectations/utils/regulate_flow.py sha256=5nYMvEeDvwYuxar8ulr9-DvMPFZTflVMGfmvDHIOXwU 6966
spark_expectations/utils/udf.py sha256=uoyIhN4YZEBhDo6E1KYwD-J7NHElVkSXGn5Hm-ExLgQ 1164
spark_expectations-2.2.1.dist-info/LICENSE sha256=xx0jnfkXJvxRnG63LTGOxlggYnIysveWIZ6H3PNdCrQ 11357
spark_expectations-2.2.1.dist-info/METADATA sha256=I2SKZcRqtuXrVe1pkQd965di4lbCKRatfvKEj88PkHE 8208
spark_expectations-2.2.1.dist-info/WHEEL sha256=Nq82e9rUAnEjt98J6MlVmMCZb-t9cYE2Ir1kpBmnWfs 88
spark_expectations-2.2.1.dist-info/RECORD