apache-beam

View on PyPIReverse Dependencies (82)

2.40.0 apache_beam-2.40.0-cp39-cp39-manylinux2014_aarch64.whl
apache_beam-2.40.0-cp39-cp39-manylinux2010_x86_64.whl
apache_beam-2.40.0-cp39-cp39-manylinux2010_i686.whl
apache_beam-2.40.0-cp39-cp39-manylinux1_x86_64.whl
apache_beam-2.40.0-cp39-cp39-manylinux1_i686.whl
apache_beam-2.40.0-cp39-cp39-win_amd64.whl
apache_beam-2.40.0-cp39-cp39-win32.whl
apache_beam-2.40.0-cp39-cp39-macosx_10_9_x86_64.whl
apache_beam-2.40.0-cp38-cp38-manylinux2014_aarch64.whl
apache_beam-2.40.0-cp38-cp38-manylinux2010_x86_64.whl
apache_beam-2.40.0-cp38-cp38-manylinux2010_i686.whl
apache_beam-2.40.0-cp38-cp38-manylinux1_x86_64.whl
apache_beam-2.40.0-cp38-cp38-manylinux1_i686.whl
apache_beam-2.40.0-cp38-cp38-win_amd64.whl
apache_beam-2.40.0-cp38-cp38-win32.whl
apache_beam-2.40.0-cp38-cp38-macosx_10_9_x86_64.whl
apache_beam-2.40.0-cp37-cp37m-manylinux2014_aarch64.whl
apache_beam-2.40.0-cp37-cp37m-manylinux2010_x86_64.whl
apache_beam-2.40.0-cp37-cp37m-manylinux2010_i686.whl
apache_beam-2.40.0-cp37-cp37m-manylinux1_x86_64.whl
apache_beam-2.40.0-cp37-cp37m-manylinux1_i686.whl
apache_beam-2.40.0-cp37-cp37m-win_amd64.whl
apache_beam-2.40.0-cp37-cp37m-win32.whl
apache_beam-2.40.0-cp37-cp37m-macosx_10_9_x86_64.whl

Wheel Details

Project: apache-beam
Version: 2.40.0
Filename: apache_beam-2.40.0-cp39-cp39-win_amd64.whl
Download: [link]
Size: 4320478
MD5: ecf78d98123e2f44a97fd2ebff671fff
SHA256: 95fd05de546933b3f181c2e304ac771e22a04b8da8337f3b2c463a87be3d5223
Uploaded: 2022-06-27 21:52:36 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: apache-beam
Version: 2.40.0
Summary: Apache Beam SDK for Python
Author: Apache Software Foundation
Author-Email: dev[at]beam.apache.org
Home-Page: https://beam.apache.org
Download-Url: https://pypi.python.org/pypi/apache-beam
License: Apache License, Version 2.0
Keywords: apache beam
Classifier: Intended Audience :: End Users/Desktop
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Operating System :: POSIX :: Linux
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Topic :: Software Development :: Libraries
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Requires-Python: >=3.7
Requires-Dist: crcmod (<2.0,>=1.7)
Requires-Dist: orjson (<4.0)
Requires-Dist: dill (<0.3.2,>=0.3.1.1)
Requires-Dist: cloudpickle (<3,>=2.1.0)
Requires-Dist: fastavro (<2,>=0.23.6)
Requires-Dist: grpcio (<2,>=1.33.1)
Requires-Dist: hdfs (<3.0.0,>=2.1.0)
Requires-Dist: httplib2 (<0.21.0,>=0.8)
Requires-Dist: numpy (<1.23.0,>=1.14.3)
Requires-Dist: pymongo (<4.0.0,>=3.8.0)
Requires-Dist: protobuf (<4,>=3.12.2)
Requires-Dist: proto-plus (<2,>=1.7.1)
Requires-Dist: pydot (<2,>=1.2.0)
Requires-Dist: python-dateutil (<3,>=2.8.0)
Requires-Dist: pytz (>=2018.3)
Requires-Dist: requests (<3.0.0,>=2.24.0)
Requires-Dist: typing-extensions (>=3.7.0)
Requires-Dist: pyarrow (<8.0.0,>=0.15.1)
Requires-Dist: boto3 (>=1.9); extra == "aws"
Requires-Dist: azure-storage-blob (>=12.3.2); extra == "azure"
Requires-Dist: azure-core (>=1.7.0); extra == "azure"
Requires-Dist: pandas (<1.5,>=1.0); extra == "dataframe"
Requires-Dist: Sphinx (<2.0,>=1.5.2); extra == "docs"
Requires-Dist: docutils (==0.17.1); extra == "docs"
Requires-Dist: cachetools (<5,>=3.1.0); extra == "gcp"
Requires-Dist: google-apitools (<0.5.32,>=0.5.31); extra == "gcp"
Requires-Dist: google-auth (<3,>=1.18.0); extra == "gcp"
Requires-Dist: google-auth-httplib2 (<0.2.0,>=0.1.0); extra == "gcp"
Requires-Dist: google-cloud-datastore (<2,>=1.8.0); extra == "gcp"
Requires-Dist: google-cloud-pubsub (<3,>=2.1.0); extra == "gcp"
Requires-Dist: google-cloud-pubsublite (<2,>=1.2.0); extra == "gcp"
Requires-Dist: google-cloud-bigquery (<3,>=1.6.0); extra == "gcp"
Requires-Dist: google-cloud-bigquery-storage (>=2.6.3); extra == "gcp"
Requires-Dist: google-cloud-core (<2,>=0.28.1); extra == "gcp"
Requires-Dist: google-cloud-bigtable (<2,>=0.31.1); extra == "gcp"
Requires-Dist: google-cloud-spanner (<2,>=1.13.0); extra == "gcp"
Requires-Dist: grpcio-gcp (<1,>=0.2.2); extra == "gcp"
Requires-Dist: google-cloud-dlp (<4,>=3.0.0); extra == "gcp"
Requires-Dist: google-cloud-language (<2,>=1.3.0); extra == "gcp"
Requires-Dist: google-cloud-videointelligence (<2,>=1.8.0); extra == "gcp"
Requires-Dist: google-cloud-vision (<2,>=0.38.0); extra == "gcp"
Requires-Dist: google-cloud-recommendations-ai (<=0.2.0,>=0.1.0); extra == "gcp"
Requires-Dist: facets-overview (<2,>=1.0.0); extra == "interactive"
Requires-Dist: google-cloud-dataproc (<3.2.0,>=3.0.0); extra == "interactive"
Requires-Dist: ipykernel (<7,>=6); extra == "interactive"
Requires-Dist: ipywidgets (<8,>=7.6.5); extra == "interactive"
Requires-Dist: jupyter-client (<6.1.13,>=6.1.11); extra == "interactive"
Requires-Dist: timeloop (<2,>=1.0.2); extra == "interactive"
Requires-Dist: ipython (<8,>=7); python_version <= "3.7" and extra == "interactive"
Requires-Dist: ipython (<9,>=8); python_version > "3.7" and extra == "interactive"
Requires-Dist: nbformat (<6,>=5.0.5); extra == "interactive_test"
Requires-Dist: nbconvert (<7,>=6.2.0); extra == "interactive_test"
Requires-Dist: needle (<1,>=0.5.0); extra == "interactive_test"
Requires-Dist: chromedriver-binary (<101,>=100); extra == "interactive_test"
Requires-Dist: pillow (<8,>=7.1.1); extra == "interactive_test"
Requires-Dist: freezegun (>=0.3.12); extra == "test"
Requires-Dist: joblib (>=1.0.1); extra == "test"
Requires-Dist: mock (<3.0.0,>=1.0.1); extra == "test"
Requires-Dist: pandas (<2.0.0); extra == "test"
Requires-Dist: parameterized (<0.8.0,>=0.7.1); extra == "test"
Requires-Dist: pyhamcrest (!=1.10.0,<2.0.0,>=1.9); extra == "test"
Requires-Dist: pyyaml (<7.0.0,>=3.12); extra == "test"
Requires-Dist: requests-mock (<2.0,>=1.7); extra == "test"
Requires-Dist: tenacity (<6.0,>=5.0.2); extra == "test"
Requires-Dist: pytest (<5.0,>=4.4.0); extra == "test"
Requires-Dist: pytest-xdist (<2,>=1.29.0); extra == "test"
Requires-Dist: pytest-timeout (<2,>=1.3.3); extra == "test"
Requires-Dist: scikit-learn (>=0.20.0); extra == "test"
Requires-Dist: sqlalchemy (<2.0,>=1.3); extra == "test"
Requires-Dist: psycopg2-binary (<3.0.0,>=2.8.5); extra == "test"
Requires-Dist: testcontainers[mysql] (<4.0.0,>=3.0.3); extra == "test"
Requires-Dist: cryptography (>=36.0.0); extra == "test"
Provides-Extra: aws
Provides-Extra: azure
Provides-Extra: dataframe
Provides-Extra: docs
Provides-Extra: gcp
Provides-Extra: interactive
Provides-Extra: interactive_test
Provides-Extra: test
[Description omitted; length: 264 characters]

WHEEL

Wheel-Version: 1.0
Generator: bdist_wheel (0.36.2)
Root-Is-Purelib: false
Tag: cp39-cp39-win_amd64

RECORD

Path Digest Size
apache_beam/__init__.py sha256=uRxzNVamTXSh5rieygMGPRhG_4VSpk6bIl8SXGYy9-g 3815
apache_beam/error.py sha256=nf1M5DKMH7G7ijN23gR_culJ11KlUXJf6HFwo5y844c 1550
apache_beam/pipeline.py sha256=bt6g_3sjWeIXJVmtpza2TsslXMf_-hD2PUVSAQTw7LE 60548
apache_beam/pipeline_test.py sha256=QBWBS6p1WfD26vy9zw7-gbP8WIzMewc_dGLhWPHuTfo 47742
apache_beam/pvalue.py sha256=mdgS8RpYQdA79NF_FLxK5yWWrMmkGA2bCi0f78EMUIg 23701
apache_beam/pvalue_test.py sha256=RvYGN8M2cdSNNoj6Qh1GwqKezCxyU631njHNMyTJ2e4 1857
apache_beam/version.py sha256=Ox_-BBXy5Ce2OZqKhusDje1oqCK1Uvf04aqhp4shS7M 866
apache_beam/coders/__init__.py sha256=j_5z4c6cjaGs8V2JTRBsnyV4SI6BzpfbSc6W3lilQp0 918
apache_beam/coders/avro_record.py sha256=ZokF_9DO6byvIoA_HzF5x548kiTrnfdqh-nSg4SXlhg 1164
apache_beam/coders/coder_impl.cp39-win_amd64.pyd sha256=OGaGNBa7r1wx77hqkKKGxsZ3EmJqIO4SjQEQFxfgZP0 791040
apache_beam/coders/coder_impl.pxd sha256=w2s_Y_9uyeJR_6pRbWxTlshV1Rn78J4TnCQfiV8_ZLo 8259
apache_beam/coders/coder_impl.py sha256=m2gYRVO_18yh1s3AMUApU94foSzX_etdXl-kQzkxJM4 62980
apache_beam/coders/coders.py sha256=gfZiaW7pu2d1_19KyI_ykc09YyNGoVd_IUs9WIM7yLY 50762
apache_beam/coders/coders_test.py sha256=71QVCYSPDdDoV1lfK8mOapANZ4kG0ULHc_SQeY7crHU 8401
apache_beam/coders/coders_test_common.py sha256=Y9QHMGBCK3OPMnJ7iQfwNr74bEZb3FiIbwNPqgS9xhc 27390
apache_beam/coders/fast_coders_test.py sha256=VHJJPx71C8_jUvqRDzP9VYAAnwp3bZt4lGiHt1GbtYY 1471
apache_beam/coders/observable.py sha256=8lyUjQY-9dHuGwgUGxW-kZyIJSyt9huKE42JVxHODvY 1416
apache_beam/coders/observable_test.py sha256=7oKB8kVpbP6ZyGjFtd2hZh-jNMXjE--Crb0IDXA0vmY 1828
apache_beam/coders/proto2_coder_test_messages_pb2.py sha256=unn7bUztqWRU0LGw8ITt5d6oTZBo8yWLL31YwI_uRHM 11595
apache_beam/coders/row_coder.py sha256=XqAxlddj21FfG1txHuzcl-A_N1JX2c-ifb7Q2lzqkGI 7134
apache_beam/coders/row_coder_test.py sha256=mSBLKeFHfvshM4VumSDoglEQp7mXNpMsZcp3YwG2Nfc 14237
apache_beam/coders/slow_coders_test.py sha256=-BlDGTaWykORYOEa6wcLj7pSJDjqnJ57qTauU6mZ94Q 1653
apache_beam/coders/slow_stream.py sha256=X48Eq9N8orNOxr_cfM57_ZLK3Us4398J40tEx3TG9gU 4909
apache_beam/coders/standard_coders_test.py sha256=sCp29MrkaTkn2r_L_M0zXU_ACEApf1Fbm6NV_xAqkWg 11837
apache_beam/coders/stream.cp39-win_amd64.pyd sha256=BVUoi_4_N5ndS_OOIcZsSxAPVYTfQGDG89vnlRAMFbo 117248
apache_beam/coders/stream.pxd sha256=iQFzlsUt61bas8FOMycmv_a3_VOgOY4obTyCQPtGOms 2443
apache_beam/coders/stream.pyx sha256=_JGhs05FsE-N6iHLYKFYX0HGYdP1TT5ADlcC3JonNlo 7889
apache_beam/coders/stream_test.py sha256=sVNmc9jHjlErw3Yw0mulduYhP25SEqqcwo2ybs0JTnc 6010
apache_beam/coders/typecoders.py sha256=3JLKAB4cKlGkH8d7JhUCgH9FSO8vbgLjCLtvdE6qWN0 8883
apache_beam/coders/typecoders_test.py sha256=GkcBp5VAxoO0uhEh56q8sdiLYKOMAbyqdjclVw2VWYA 5878
apache_beam/dataframe/__init__.py sha256=nvvIETlOMpiU9VPIbG_OqzGfm7vVDzo_W9pYLBHkzIU 1470
apache_beam/dataframe/convert.py sha256=FD-IFM4V-kYDXAyOzRWF7hw4XiMmcbcdu1Iw_4hRT00 9567
apache_beam/dataframe/convert_test.py sha256=qmT0l8WUq-dAwwvBvHRyfcJmZswKtKnFqdZTzVFT2lI 6781
apache_beam/dataframe/doctests.py sha256=Mt9cTCT3UvNL1aBFFHJmq4PFasK0H9sQHfZf6Lj3BSY 24446
apache_beam/dataframe/doctests_test.py sha256=1I84U3hj-jnnX4sNJjPwYRHskFQ8BVMASAXWmXycrng 6816
apache_beam/dataframe/expressions.py sha256=EtSVXSTMQpjyvzXd2SOft-WHCqpmcq7WDULQju4Fruc 15002
apache_beam/dataframe/expressions_test.py sha256=D0gN5yBSJIwHyYO5ISmVtV_51QQ0XPJqMbQh-dQVLlE 4866
apache_beam/dataframe/frame_base.py sha256=_mGaL4rWDdJjUjoQT2NcUdvKG6MHhJmzv7sFXMJDvYA 22131
apache_beam/dataframe/frame_base_test.py sha256=1tsyZT9DgPTtsRdt740oy1p5yclcicai_19J42v1_QI 4444
apache_beam/dataframe/frames.py sha256=SWgoKnEOs9oD9BWxbpXK1rs_r1J_zFQ-PSyAhlVmr5s 213212
apache_beam/dataframe/frames_test.py sha256=9cClyDfw2-2KA33SnGhBaeagvw0fA93UUX_JxGefHYs 113671
apache_beam/dataframe/io.py sha256=OHOLkVigWoB0hkwfjAzD0AE7rW-AeIifxYh_kkwd4XQ 24858
apache_beam/dataframe/io_test.py sha256=DeQUGgPNpS3gylwMPC9gkWYogri1emOE59k1ZSiM0Aw 14652
apache_beam/dataframe/pandas_docs_test.py sha256=w0aQwn0z4TxMy4vp9eqbG6gpnr2ZE4MvDKZtsS_HAKQ 4559
apache_beam/dataframe/pandas_doctests_test.py sha256=JGRDaEQLYyKZ3Si3TwYPv-pPOua7WBOLa0giFmkKrI4 40731
apache_beam/dataframe/pandas_top_level_functions.py sha256=aZ5w1BA1sw0hw495XEuoshWmiXuIUQArCNGmrps1aa0 6118
apache_beam/dataframe/partitionings.py sha256=tSuh7U26xOm8p4XaWXkJYowm1ABeQGDzBMZy2y68mMk 7136
apache_beam/dataframe/partitionings_test.py sha256=Mp5-UuAZAh1YUYPS9tqvolxUdxlcALAV9Z3hqSFFLlU 3591
apache_beam/dataframe/schemas.py sha256=ts-wcN_eLHnzo-AbWY-bBcNjAM3Qua9OoiZ8P7cIAg8 11847
apache_beam/dataframe/schemas_test.py sha256=MFFin8iFU3chnIkfxf1LRZDqxVl0GWPn9f1H15JCEZg 10953
apache_beam/dataframe/transforms.py sha256=yVz0btmOFzURHUUSh7cRf_vNu5Uglrz7SrPscsJNJgM 22827
apache_beam/dataframe/transforms_test.py sha256=-YntqyWp1wlSywZsaUXxM5nM05ed3qS_39K3FrYGUro 15750
apache_beam/examples/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/avro_bitcoin.py sha256=37zXDiAIjhgKoao0UnN2kffo7VRA3nGA1aJrxvtBOig 5447
apache_beam/examples/fastavro_it_test.py sha256=cRQyfN9sOrZQXVwV9K1W6MTjaU568sIr9Irg_BkVbM8 5851
apache_beam/examples/matrix_power.py sha256=4jF6H5VlfdQnsPJ6qnshVkpYGtnqyUa5kLE4OulNR0c 3565
apache_beam/examples/matrix_power_test.py sha256=-PJDl-W5Ivu8ekeY4HTjSF71rHblRieGBZSib2PTvl8 1908
apache_beam/examples/sql_taxi.py sha256=SqSmfoYHDVkm8UfJRTT1NIibL3gveRBu7Fw56HqkYYo 3964
apache_beam/examples/streaming_wordcount.py sha256=DHFfWkO4dA-KzKpOjlwBUwI0BdBiVhQk08w0u2b1bw8 3801
apache_beam/examples/streaming_wordcount_debugging.py sha256=Dl9YnZMpIQpdv2CxROFEBgP69qIT4aMGfAI0VN6pJUY 7180
apache_beam/examples/streaming_wordcount_debugging_it_test.py sha256=NRivxInS8xnf1TJ0_x77mIGAHkhhu_viBzhTlRi_Hqg 4614
apache_beam/examples/streaming_wordcount_debugging_test.py sha256=kmHvfmisUIugugT47BIQYyN_IMP9kD7YWB--rgxHHtk 3558
apache_beam/examples/streaming_wordcount_it_test.py sha256=eOcnlw8uP8Fv3nKOcwV2U3POHnE-P2eHz4dVeqz4sII 4544
apache_beam/examples/windowed_wordcount.py sha256=8VM1UirhJMatCeeMpjGXFZB0zr7vSop_B7f6tI4pDVc 3217
apache_beam/examples/wordcount.py sha256=_92E6FbMf8eBxST4PtYwstP1q9jn_1j-eVwz48IptJg 3464
apache_beam/examples/wordcount_dataframe.py sha256=cR_yqxt0WgaH730Kqjt9q8cDWlFUV9OSradx_VK31Pk 1069
apache_beam/examples/wordcount_debugging.py sha256=s2El9x-cMokdbA7ORR6xYtWyiAe7Sk6XSZ4g56i3Z8Y 7021
apache_beam/examples/wordcount_debugging_test.py sha256=NyZh9EfKODmsvfqfhRj0zymsOsTSby-764qZZMSC5Bw 2180
apache_beam/examples/wordcount_it_test.py sha256=iQu4bcc4qt-E5i73sQQSSjVKIkLLHqo4dweA-xs_uZw 6455
apache_beam/examples/wordcount_minimal.py sha256=V99nHh22XBjtjWw26v_9fMGZvAqrQWCFBCjOUnU3VnE 5364
apache_beam/examples/wordcount_minimal_test.py sha256=PG4kVsFkgCW1Br1d7qTAS7NEk218e6xyK7FPA5Zrbnk 2417
apache_beam/examples/wordcount_test.py sha256=N5hyleGCKzj8tlDJJUHY3kZuvrutB2r2u8X-eZ-Fi3c 2384
apache_beam/examples/wordcount_with_metrics.py sha256=RtxOvBuUy8Fs8_TrJUkOIoQBL97fTU372uqH7f0fDKU 5241
apache_beam/examples/wordcount_xlang.py sha256=LL653QrcvtE7UOMmIjAPoNIyZfvpxs7oQTZJAdNn9_c 3942
apache_beam/examples/wordcount_xlang_sql.py sha256=RPqWcZ6FZZsUliVHn6sKPu_Amezt7VueVmktR-5ePUI 4064
apache_beam/examples/complete/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/complete/autocomplete.py sha256=4s7twbrod9YXXqkuK5SVcZhG5ZRXH_o5GqbtUuQY5eA 3159
apache_beam/examples/complete/autocomplete_it_test.py sha256=qk2KNXsVOV8X0EoZ-p0aquW2RL6mVxMSNehOXE3ma_E 3870
apache_beam/examples/complete/autocomplete_test.py sha256=mO6ZCVKv2KroeH-BlghTb-ustNwoIUOb1dmDdOWcMKw 2604
apache_beam/examples/complete/distribopt.py sha256=Y89tyv-Vw_mA6aFqql0HsCFwOZCRZ0oKKoo-syHbSaM 13426
apache_beam/examples/complete/distribopt_test.py sha256=325951TyOZYGHDFtze4Qs3_lCJAv9pvQO1NWWbfj2aA 3001
apache_beam/examples/complete/estimate_pi.py sha256=XBd68MVwnYd9tRZcx-s52vo2CXrZ-DrtPmMU6wNtIm4 4337
apache_beam/examples/complete/estimate_pi_it_test.py sha256=1ZcSAUbx4CWKTRXistItEzqgbSGGEIxTRTy2CYfjy-0 2340
apache_beam/examples/complete/estimate_pi_test.py sha256=qI6Zj9VHH6N5pEzC_VyuGzuiiJmNeTucbyydHRWWTQ8 1845
apache_beam/examples/complete/tfidf.py sha256=Vd_jwv7cogbulMDcTTEMyqL5KDUVCkeJ6TOs8gD9Obk 8625
apache_beam/examples/complete/tfidf_test.py sha256=5gdqMaUcaxV-rfbcsJdyOl82pIbqVJWPHqejZ_6DDPI 3487
apache_beam/examples/complete/top_wikipedia_sessions.py sha256=BG2WSF65LABmYNW9zCD0BQuWLnsGnh-xakSve24xyNc 6025
apache_beam/examples/complete/top_wikipedia_sessions_it_test.py sha256=adBV_g-UYuAc9dCfvYvlT8PYa1KSlxJ887mOdvUWLJQ 3942
apache_beam/examples/complete/top_wikipedia_sessions_test.py sha256=jqHuIfTlsF1WCOHCCF-0qPUwm05_yqs5v3rCllDlovc 2558
apache_beam/examples/complete/game/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/complete/game/game_stats.py sha256=BM5-zo89IMCEycU_o7kHudSOpQxFZABhIPj1NGGwz1Y 15053
apache_beam/examples/complete/game/game_stats_it_test.py sha256=gJDb0QqGs7afFN6uz9sQjUoRrXnBlxdeOkINpoHp4zE 5704
apache_beam/examples/complete/game/game_stats_test.py sha256=lXB8p1pae4M2-uDDSWtXkxlDx8NlrkZgmnLLP3adz_g 3301
apache_beam/examples/complete/game/hourly_team_score.py sha256=H1uGf0dVywiEWzj6Zi3_nBI2oQTc7ry25G9o3y062Io 11775
apache_beam/examples/complete/game/hourly_team_score_it_test.py sha256=WahK7GEZhNCs-IXUnnJD0plyBIJKo1SIGYuPJzSZCt0 4620
apache_beam/examples/complete/game/hourly_team_score_test.py sha256=FoPE_9b4oRn1GNR0KZXAq-eInlOqhXP2oiA0PJShmAk 2107
apache_beam/examples/complete/game/leader_board.py sha256=1x3613AAvmG6PNlBp-JkwVSsxkHT1KD2utH9QVTWuxk 13867
apache_beam/examples/complete/game/leader_board_it_test.py sha256=yqcaeGfQycCYCe2lNlsgHPvR7W0ZJILTmVuqwsBjrKE 5988
apache_beam/examples/complete/game/leader_board_test.py sha256=RB6U-Q_JCIkR18SGl9fkW-KqRCwgRpJFloPhHKcpOvA 2711
apache_beam/examples/complete/game/user_score.py sha256=hAtFDryJRje-PZh-dxeVKzwO2T-Jc489dVD4wqpdLac 6196
apache_beam/examples/complete/game/user_score_it_test.py sha256=76ShatiZYm4iLNjid-K-bIRmgqtR9SRKyrnWDVEtFSg 4281
apache_beam/examples/complete/game/user_score_test.py sha256=xKw6opdTwqKlSPKJu52CJhnU3vgh2nhY7wVuBqLDpMo 1995
apache_beam/examples/complete/juliaset/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/complete/juliaset/juliaset_main.py sha256=tZJD5Z16vTVrpZYV_SOHOPy1LL3Ot2Vx2LtdqjQnp74 2310
apache_beam/examples/complete/juliaset/setup.py sha256=sXBC2-gP29QdCpUU2VVU5gE5n1860-nUw--_ckhmhPU 4761
apache_beam/examples/complete/juliaset/juliaset/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/complete/juliaset/juliaset/juliaset.py sha256=LmhSzACqjjtI_SfOxTgukPxPyZQtU6lo1A2cmVl-jF4 4390
apache_beam/examples/complete/juliaset/juliaset/juliaset_test.py sha256=cjBPopV7zPQ_2_Djfw8L_eEy3Dd3hnRPl5nllMnUMmk 3033
apache_beam/examples/complete/juliaset/juliaset/juliaset_test_it.py sha256=oeLz3V19VhxiIVMrE_NNE9Z04bNmx46VeEGPKGtSJKQ 2097
apache_beam/examples/cookbook/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/cookbook/bigquery_schema.py sha256=nDpIqts2l1-i5ok8CU2US6g1oRwhg-ZzAdwsx6okxeE 4478
apache_beam/examples/cookbook/bigquery_side_input.py sha256=7dh5cMjhmwV3GNx9S0xuhls6KjTC6Z8iK4tCC0GEoMM 4340
apache_beam/examples/cookbook/bigquery_side_input_it_test.py sha256=jqVYYjwt6tQHAsYa5aQ46Ha6DCpMxVgUqghyG2n_obM 2373
apache_beam/examples/cookbook/bigquery_side_input_test.py sha256=AiVmdm9c6tvlH5RgPq2OIRzqq23mJc16PEWxiO-o9IA 2166
apache_beam/examples/cookbook/bigquery_tornadoes.py sha256=zWdAcgHKkhHvn4UIR1ou5-AXOL5oar1opqbIW4HllWU 3690
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py sha256=Do1eKOWtTfkPua5B8vSTbLnsJlsdNg2TouzlFG4I8eg 2753
apache_beam/examples/cookbook/bigquery_tornadoes_test.py sha256=6cD3UdJ6BoqcIjesJX61OZxGptYHh23qfXlhMqQ3Ulg 1887
apache_beam/examples/cookbook/bigtableio_it_test.py sha256=OQ6duKIgfg4t4f7-Ao4gN1ZGZS5gmyVWZ2-MkUPwTPk 7108
apache_beam/examples/cookbook/coders.py sha256=0PCZ-5S-YMUha_XPNNfWzTKH4Hopbp8b3MWnBM9mSUQ 3323
apache_beam/examples/cookbook/coders_it_test.py sha256=gSyzVmsZh4_OIoLr25YQC4cJyDu-KIyq6pSHu3TJGf4 3444
apache_beam/examples/cookbook/coders_test.py sha256=s26zIkZ7QdPfs4FHb8QHMIxMcd_p6QOfKwdwVtNztS4 1819
apache_beam/examples/cookbook/combiners_test.py sha256=hwRBQTEPRgwgyT-6Cwg0244bk6at5nEybFxlL28QVak 2826
apache_beam/examples/cookbook/custom_ptransform.py sha256=aU3q5UpzU5O18ruwxNM4ZJpjs3Z8tEJ5civqujnvYOk 3849
apache_beam/examples/cookbook/custom_ptransform_test.py sha256=BU-XGibTRBxNgTK4K87ZvFfE0yu5KiECrvFOP75Bf3Q 2804
apache_beam/examples/cookbook/datastore_wordcount.py sha256=E0XENOWtn5IC2o7F58xzqpNBH0iavy6yBdDdY_TQ7Dc 9693
apache_beam/examples/cookbook/datastore_wordcount_it_test.py sha256=qLS0FWTTBhRZZ9c4G2WCwk0_6ZqYQ6M0Ry5lk4tJnBY 2603
apache_beam/examples/cookbook/filters.py sha256=-pZS_H908FXnHGA41Y2jdNm0ZcLBrZMJEn3ZoAaowms 3928
apache_beam/examples/cookbook/filters_test.py sha256=1Zp6I8ZHF31Ue8mW3C1PUK8fjW6oUfg7O6Ge9S8cHAg 4582
apache_beam/examples/cookbook/group_with_coder.py sha256=PrO4pc11eAG43_NfsibRfbggyjmXh28kzjox7ZgGwKs 4724
apache_beam/examples/cookbook/group_with_coder_test.py sha256=Qn5-iqizX7LcUKi_p72CwFHidMtHjS6vShP5hSJuPbU 3589
apache_beam/examples/cookbook/mergecontacts.py sha256=74gcUqIbFhkfOp5mktBne37YskjhDI1tTUfY9VZYOuU 6014
apache_beam/examples/cookbook/mergecontacts_test.py sha256=TSZjBh68iC6O5E6i50w8y8-ICtRZs7hnwE5Tv4gR1UE 5239
apache_beam/examples/cookbook/multiple_output_pardo.py sha256=BpXPAXqT3l7CwSBaK8P2fYuR9wcdzo0nH8tPs8uVdWc 7320
apache_beam/examples/cookbook/multiple_output_pardo_test.py sha256=Gvpg0IEdANJR4BvbTh03u7FuV0z9rwZfCalkDynu6_8 2730
apache_beam/examples/dataframe/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/dataframe/flight_delays.py sha256=4KqMob2f-iKQQkhbyovDZLZge8bXrgFeXEanJMcgfVc 4773
apache_beam/examples/dataframe/flight_delays_it_test.py sha256=-T1F8y5-CQeRIGY3y6wrzBEzwbXxiqju6KTwKhhaQsc 5481
apache_beam/examples/dataframe/taxiride.py sha256=n1uU43qhgVIn7CRnKi3VyCTqv8om6MrBcyUwC0JBUzU 4366
apache_beam/examples/dataframe/taxiride_it_test.py sha256=1Mk-av7IWPWB_pt2w4vTbMSHWMXe-nPCtsk6hC2ZjJ8 3460
apache_beam/examples/dataframe/taxiride_test.py sha256=KpFMPSqyDBjbkCoUAOkZF7nxcd5Z67MML_1B4DdypiQ 5525
apache_beam/examples/dataframe/wordcount.py sha256=JG3hFfSHGIKYeT7kDjMF2XTs48idJS_ZYAd6ZUuASco 2925
apache_beam/examples/dataframe/wordcount_test.py sha256=DIZNqGFHw0dDfxDTOrzwK82jBfDd9Uupr8RatMQNHQQ 2200
apache_beam/examples/flink/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/flink/flink_streaming_impulse.py sha256=gX6V6q2fRpMAIwRuyzpW7kk1pUNNO3VSbRcPBxzIak0 2944
apache_beam/examples/inference/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/inference/pytorch_image_classification.py sha256=C05CHQofQ7gqFIToNlVB_LaX2SueCEtumyFlWfFDF68 5422
apache_beam/examples/inference/pytorch_image_segmentation.py sha256=qro4MMuH00ledgwgs3fW7q2aQ64ltHxDWbFhL3cH3TY 6789
apache_beam/examples/inference/pytorch_language_modeling.py sha256=jb55J0gPKTir_xP_hA_lbGSUdr4aHtiPR-f9rk_jaTI 8778
apache_beam/examples/inference/sklearn_mnist_classification.py sha256=mv4Dd9_h4WI3nNtEKMupcN4JmOchZzroFZD9GDASGQI 4128
apache_beam/examples/kafkataxi/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/kafkataxi/kafka_taxi.py sha256=CS4vTSSQV1GSzxp2j4j1lysmP5vHS6Gl9fMqXgttqX4 5990
apache_beam/examples/snippets/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/snippets/snippets.py sha256=7Rw_UUfTtoZ7WqeMVuuP4ySpN4g-zZUlJSJ6uVXSaj4 62506
apache_beam/examples/snippets/snippets_test.py sha256=z7ImYT8FmBj_fblkRpPdzzPk9afFq3aC3HNc9WSGatg 52480
apache_beam/examples/snippets/util.py sha256=aIbTMtwgtUuPB0iQKNVdyBHb6zoM5U_7jiegpM-Khx0 2317
apache_beam/examples/snippets/util_test.py sha256=47wsPX_WFmLPWPUCMKobXKv6qBLgjLLAYneiiYs1A2I 3224
apache_beam/examples/snippets/transforms/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/snippets/transforms/aggregation/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/snippets/transforms/aggregation/cogroupbykey.py sha256=zdlSwLfrf_mspA5xwOgTlJrpyKZAq7EWXgAIFICKSUs 1543
apache_beam/examples/snippets/transforms/aggregation/cogroupbykey_test.py sha256=kx5Vde6omXkOK3T6qTu-XYr9KmN4eovEfNTVoYs4x44 1975
apache_beam/examples/snippets/transforms/aggregation/combineglobally.py sha256=RQg83iVpCcxB-zIKBg7bode0vt2d0sXISdq8R00kYvY 7897
apache_beam/examples/snippets/transforms/aggregation/combineglobally_test.py sha256=nI48trjth4MK-egMqtURqhZAbU7jYtEY-5H8Iej9KPI 3136
apache_beam/examples/snippets/transforms/aggregation/combineperkey.py sha256=GUIGjMDAdQYlfQT9sbJPzPIFsqN_J5T9IxqZ_yL3SRY 7198
apache_beam/examples/snippets/transforms/aggregation/combineperkey_test.py sha256=3Q_N6SgpZrwBo_AyGvtvwJFT1_-lQtEFts2fwIVuZgg 2893
apache_beam/examples/snippets/transforms/aggregation/combinevalues.py sha256=3yJEETavTSf1j3GUnb5PtatMamWie_b3iDP4B_Zzrsg 7252
apache_beam/examples/snippets/transforms/aggregation/combinevalues_test.py sha256=2BO3QfRlLPQ1Zox_l9sNjI16eJLOlD_5DbL5n0oIL20 2986
apache_beam/examples/snippets/transforms/aggregation/count.py sha256=CBnyVJAMU9OR4C-XN8qMTS4s6OdFmsB1JY5Wgf6DWKY 2486
apache_beam/examples/snippets/transforms/aggregation/count_test.py sha256=CvkUyzDSxl8TEep1EdF1JLNREwFx-pURIzMHTGIoUqY 2128
apache_beam/examples/snippets/transforms/aggregation/distinct.py sha256=56FKkCxbsGNO_8Z-bgmKTi8C1bub-fLMRmHVoQT6S_Q 1291
apache_beam/examples/snippets/transforms/aggregation/distinct_test.py sha256=_Q6gB7K61dc0ZTgT2T3ehlemEeKUqzPfg8VujchTetY 1484
apache_beam/examples/snippets/transforms/aggregation/groupby_test.py sha256=Q03UEhoaxRq766I8Lz4jqFvQZBgAqH-cHqwXvMkhDKs 8333
apache_beam/examples/snippets/transforms/aggregation/groupbykey.py sha256=z5zvfUn-Eh4pzyCONmlIKiEN-e47S5X-IN-_JSm--Vw 1578
apache_beam/examples/snippets/transforms/aggregation/groupbykey_test.py sha256=Zed_xLu4NxlPdLtUxlT-d6_m7IHo6NvxtRuh3IeRd5g 1724
apache_beam/examples/snippets/transforms/aggregation/groupintobatches.py sha256=5zze9slQpscKZLZ67iweNrS2efbd4MFNm3dI1GChl9w 1501
apache_beam/examples/snippets/transforms/aggregation/groupintobatches_test.py sha256=VLSNfY5olUuOvdQAMBH0be4cRnEK1SbMbsJ9gVtUOTU 1762
apache_beam/examples/snippets/transforms/aggregation/latest.py sha256=YOOuj1TK7jq25m4REVK02Dc1njx7Jll8DW0fmHKy6m8 3835
apache_beam/examples/snippets/transforms/aggregation/latest_test.py sha256=TV15E6F__OVfi9LsEWNbyIX2zEL03-Ng5V-gkMgzPhs 1830
apache_beam/examples/snippets/transforms/aggregation/max.py sha256=zVZUM5k60vg4HHgdoB5qCcUGi5t6QyNZFXz73g0BOuk 1775
apache_beam/examples/snippets/transforms/aggregation/max_test.py sha256=748nS8E5J3S7lPTy1IXJXcWf7xu68qk3JikZt2n6IHc 1802
apache_beam/examples/snippets/transforms/aggregation/mean.py sha256=FjM8lj7eZJaCaJ6T2vxrYIlh3d67tQ_HsX6FMXwwaqQ 1752
apache_beam/examples/snippets/transforms/aggregation/mean_test.py sha256=BTsF8qZdtPVYimWID143nWATRPDNFcgGojYfTDCNduk 1805
apache_beam/examples/snippets/transforms/aggregation/min.py sha256=VmGXw1mMIlNdZAkbim2HyGkA_zAatmthw7JljnMoPnU 1752
apache_beam/examples/snippets/transforms/aggregation/min_test.py sha256=QUol9v6G97UrK8TUBCxZLIFl-7Ug1uhYT_-BtXcf6dM 1781
apache_beam/examples/snippets/transforms/aggregation/sample.py sha256=pMXWpeHKSrAhNw1bZjTtW6-vpgimx48tWFF5IWDEmQA 2110
apache_beam/examples/snippets/transforms/aggregation/sample_test.py sha256=bdWS5g9_lOuR6PvsSpYPt5w4Q9uVc5zXxvFuHXHYjJ8 2117
apache_beam/examples/snippets/transforms/aggregation/sum.py sha256=eFgzD5TsUnBA52_x_FPIO98wleqHvKJdd-_n-7luYDA 1657
apache_beam/examples/snippets/transforms/aggregation/sum_test.py sha256=YMF6b1pbzT70wmYxvlqh2Wu1XSrUO3jmK2o_oHvgTUM 1691
apache_beam/examples/snippets/transforms/aggregation/top.py sha256=D3UbNtXP-a8BDirhYtr9gog1id0NQjuxRLTEntUJiVg 4352
apache_beam/examples/snippets/transforms/aggregation/top_test.py sha256=jwCsnVfaVweYPmhqkyev-fC9kZvbrFqeW0W19Nl-nVg 3084
apache_beam/examples/snippets/transforms/elementwise/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/examples/snippets/transforms/elementwise/filter.py sha256=7rxlPG8al9BGN6gCanihMeWcAPeErzRSkT1QUt0OTi8 7277
apache_beam/examples/snippets/transforms/elementwise/filter_test.py sha256=fDQcGHAElxMVafczKKMOuldzO3V5vW8jLxgQ38bucTg 2513
apache_beam/examples/snippets/transforms/elementwise/flatmap.py sha256=jpFcl3TAuFXJ_i6XD1_cjXe21Ks0pEGFEwM7Xn_KUYo 7326
apache_beam/examples/snippets/transforms/elementwise/flatmap_test.py sha256=YBvKH6dVHOdkfnYfTxOJC8JfXtY-PrPCyEvXlIm4p44 2612
apache_beam/examples/snippets/transforms/elementwise/keys.py sha256=RH6fFRaq_9WHhB_atOQKDdzD5AR0G9zx8TNTeOeMk2o 1284
apache_beam/examples/snippets/transforms/elementwise/keys_test.py sha256=0nRSW8Lm-zdibdqaW09tNwE3gDgvH82je3XRBks3Irk 1430
apache_beam/examples/snippets/transforms/elementwise/kvswap.py sha256=mNe6qb_vdX5jNieZk_Rx6gC8pHkf15oNcXgp20N7pzs 1304
apache_beam/examples/snippets/transforms/elementwise/kvswap_test.py sha256=UZbZpSzr5yK94X6eF9RBTAY0MKfMJaZMmfUSnNOF0gQ 1522
apache_beam/examples/snippets/transforms/elementwise/map.py sha256=Z1QJQtZPNzhdA6CzveSyXnGWSl0dfJh7YhtIXf-CPFE 6185
apache_beam/examples/snippets/transforms/elementwise/map_test.py sha256=7Q8710L1-q15kS_dU_MDTO5-nyMPnYKSxxje_lya538 2481
apache_beam/examples/snippets/transforms/elementwise/pardo.py sha256=o77VedefW1PobSiD4f-PFXQHvEA2H-jHzkCP8Oheg9M 4056
apache_beam/examples/snippets/transforms/elementwise/pardo_test.py sha256=OqKqk-8vwHw33hgwqtgYKPOt4Ht6qa4GCajxajjaF0g 3610
apache_beam/examples/snippets/transforms/elementwise/partition.py sha256=Gsm-GabaphQpp6MRFKxXFDtpsojKYfqK0o0-GtEcKLM 4767
apache_beam/examples/snippets/transforms/elementwise/partition_test.py sha256=KgDQo7xOTGko_-uhY9KWHDwU1ySXbpuHfo_yoKZFyk8 3413
apache_beam/examples/snippets/transforms/elementwise/regex.py sha256=AaLf2CM6dxYi0Ik1VQs-LnVPeYmPMN01M0TyP496H5Y 7319
apache_beam/examples/snippets/transforms/elementwise/regex_test.py sha256=5uIadvfv0_ev6W5TpSytDaaBAO3F86mS1mH9hML3bb4 4583
apache_beam/examples/snippets/transforms/elementwise/tostring.py sha256=l9r4qYKyXK7ls1BK4HnNoydRCyCFAcdl6h02pLS6ca0 2509
apache_beam/examples/snippets/transforms/elementwise/tostring_test.py sha256=jYRcRSXp802lMTA1c9UZQwTF6oqYZABchfoqr0IeY5U 2253
apache_beam/examples/snippets/transforms/elementwise/values.py sha256=DCpZJE7iIHdIsK1nVmGv_cc3ODwXsdFeM2PYo0WzR34 1296
apache_beam/examples/snippets/transforms/elementwise/values_test.py sha256=e8cWv_rGASm1MR576r42nvANMA83K5WvVIC2CW44zhc 1462
apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py sha256=iEGmCfjGva9rvKWYls_FWMMjU6nnHYusU7T-38mU-oc 4281
apache_beam/examples/snippets/transforms/elementwise/withtimestamps_test.py sha256=eDXB2i08X27RjTrgeLyxVuJcBmFWQawpLwS5Zh1ZSQ0 3045
apache_beam/internal/__init__.py sha256=OpUu8TukLPlUn5MDBWLC8zD7Ow9RI9aC4kWRNbMsAUI 853
apache_beam/internal/cloudpickle_pickler.py sha256=EkY__715_380g5HcsExRyHKOB5Nj4C8BbtQjqYAyTfU 3455
apache_beam/internal/cloudpickle_pickler_test.py sha256=rPwIGn-yPvKQJ-VlFnOn_U4ljexhCV2GLRR-9_wX4Yo 4092
apache_beam/internal/dill_pickler.py sha256=iyJcYLffoEXxajzBmLpdRnEujHrUi5UPDWrZ-AofA_Q 10921
apache_beam/internal/http_client.py sha256=e5aekNmMcJg7LX1-iipnxfxjCmjEjU2Ag02O_QB10UI 2451
apache_beam/internal/http_client_test.py sha256=nrHv9zFuTVGeOucKgYekFjEe-4llXU-i-GhOUtcQQFM 4661
apache_beam/internal/module_test.py sha256=A3cAVr6CD-DmixKB1SJ8GyWgAWAKbMSOq1E2z6LZECg 2066
apache_beam/internal/pickler.py sha256=vNwVBNCjYEQJ8NMuJ0Vh5_iglBHUomLBawtoinWrtTo 2664
apache_beam/internal/pickler_test.py sha256=jSl3CrPBYok6Ng-xlRwz5-Adzb94X0j3CnAeZJunqMU 4039
apache_beam/internal/util.py sha256=dyuk9zr--xydLGIZ3xk6WLN7TUQFh2QMSGOS88qmU2Y 5629
apache_beam/internal/util_test.py sha256=NwOoTyeQh5GeMVaDVPM7q7i2O5Owk2c0f7VR22JuQp8 2287
apache_beam/internal/gcp/__init__.py sha256=OpUu8TukLPlUn5MDBWLC8zD7Ow9RI9aC4kWRNbMsAUI 853
apache_beam/internal/gcp/auth.py sha256=PGlqe8zfNLhvjmJYOBpaV5ARFiZHWL4py9ky3f1iQwc 6863
apache_beam/internal/gcp/json_value.py sha256=sX2uh6AJPUZE1dNaT60nQ3wNL-m7lLrvkh3bZcb1vo8 5978
apache_beam/internal/gcp/json_value_test.py sha256=R6XnNpTojTDmS57r4DmCCfwneMt3sM7j9benC_6Uv7M 3857
apache_beam/internal/metrics/__init__.py sha256=OpUu8TukLPlUn5MDBWLC8zD7Ow9RI9aC4kWRNbMsAUI 853
apache_beam/internal/metrics/cells.py sha256=MMrxm5UV8pJ5MgJ5HaKx4yxVr5QE9791ZnDNOCldGGA 5208
apache_beam/internal/metrics/cells_test.py sha256=-rgkdUFaDTYS3Usb51GFVRndPhfSFkxStrzNgcuBpts 2543
apache_beam/internal/metrics/metric.py sha256=Uk_xlmzb8VUN2LOn6rlQyiUoRreAoSr3u5-xtRcfYNk 9494
apache_beam/internal/metrics/metric_test.py sha256=7EK-xgDDATUxa7cEBwK88LFh7rtpJK0Te1PhwyBs-ew 3376
apache_beam/io/__init__.py sha256=MjitGRmUE5BXwlvLrn6uevVyxXSKzyI1Pb-ZRrrWLxA 1668
apache_beam/io/avroio.py sha256=XHza92-eTwFfE0QGNuM9ujPcYXJH0L2bnBR6YxdXggY 16823
apache_beam/io/avroio_test.py sha256=ywV_ptxNQoz17M_Uy7ADAogtOzUyaYyBGoqsqey3zMY 20337
apache_beam/io/concat_source.py sha256=3nSv_eiey2QA5VyOFUTJYGMbdz89KJvSgKZTM4MuN5Y 10439
apache_beam/io/concat_source_test.py sha256=Ehdq-qhbD8Mj6uafuW94Hp3jNIc6nKFLTeHF-a4SIjE 9400
apache_beam/io/debezium.py sha256=geAPvXqAb54zoc0YadzKbC_2lEJfOgsw1w4Tlm-s9y0 6270
apache_beam/io/filebasedsink.py sha256=0byhiyeBHAcPeK9TZLCTi8fvv0XB0nAFEpws3PAQjgA 15048
apache_beam/io/filebasedsink_test.py sha256=pdvpeFe6FhWMwxQkX_9yfFkL0unWHJBImoXdpmdlUfA 14584
apache_beam/io/filebasedsource.py sha256=141xHDJw5mrhsr-B0r_vtcClSlSN-2JWjiOshyrTYpc 18882
apache_beam/io/filebasedsource_test.py sha256=3EUqkJHATq4Y-51qbECl2cBmY0Cu6RqgfVK_T8CkYrY 28088
apache_beam/io/fileio.py sha256=FLNqyWQkInF56Mxh5B6KLIaI94SHwIW6LaLe5NMivRk 30944
apache_beam/io/fileio_test.py sha256=vIIgOSa0GkPdNh-89JKCstq89cUmBVrJNLcPZz_jSVU 28141
apache_beam/io/filesystem.py sha256=IheWmqBBFA4e7mNSyXz7rOU5A0HkbVNR09fCIJuEg9M 30115
apache_beam/io/filesystem_test.py sha256=QCud1JsVxWt6_WiHYPQb84VHjBpbpC_H43qrbeVWX3Q 19789
apache_beam/io/filesystemio.py sha256=WQkCPg1iR2Yu2Jfmi53bIWfGCIw7G9BBYbHNo3c8yFo 8297
apache_beam/io/filesystemio_test.py sha256=2L0qJfocuWvHri40bVci8J1K-pmkxQ7uS6iy2f3DtLI 7688
apache_beam/io/filesystems.py sha256=fwiOJXMRXApLUyvmVGeut5hG33hNUGmur46Q25XPxLA 11179
apache_beam/io/filesystems_test.py sha256=Nu7WjHGwBKRgds1ygDYHPHGhckFbIGczUG1Lw5_rcqU 8308
apache_beam/io/hadoopfilesystem.py sha256=idg4bvRPaVcSmky05Xf-g_NXg4qh-MEltWTaz8VDey4 14169
apache_beam/io/hadoopfilesystem_test.py sha256=V9p98IvKs45WDs2omQZ3Zsu-Yfo74YkxlfvDsh_NHlM 22460
apache_beam/io/iobase.py sha256=Tlh_-vcCuLIovNTy1r1Yac0a0QSUz7_vz6M-Fb6BERU 67518
apache_beam/io/iobase_test.py sha256=O4ZHQAnOyGoWz9Um_ZVhIGzCTB549L0gvDraEvTr2x4 9027
apache_beam/io/jdbc.py sha256=UkkcKgFpyV_GO-nCkMEDJIxEqODAs8Rw0F3Jrtvx5qg 12661
apache_beam/io/kafka.py sha256=pjpbILQ_p9rk63yDcMy4-Kq2WxSuJNTcXMlYpZiByJw 10084
apache_beam/io/kinesis.py sha256=vSNXtdU4wlX3fPz0WvynHvrF9G616sAuMiLbiKTVmiE 12085
apache_beam/io/localfilesystem.py sha256=drDiWGwOo38K2Z56TopOqJC55o8mr37lnp-9Zqq7d4g 11175
apache_beam/io/localfilesystem_test.py sha256=vQERrJGPryWEDRqMposArjDmywgMP3BB4e_14zkzgXQ 15436
apache_beam/io/mongodbio.py sha256=n46cEWM2EoRS8BzIA-XcrtVAHaxpHF3bDtUTR_ddvDk 28620
apache_beam/io/mongodbio_it_test.py sha256=TwYlpdXliG5eX3CRDRfQtM0_vYYkFY4cPI-uuabZado 5469
apache_beam/io/mongodbio_test.py sha256=1ZJhDyGVV4bv_bwWNl02EO3pzekdkIHUEdV58tk0Flc 26042
apache_beam/io/parquetio.py sha256=cjcX_67X6IM02GHEd_ExMSWfhOS5ljnIAHlNnnqw1Qo 21930
apache_beam/io/parquetio_it_test.py sha256=QLBKz0OyX6dwCRuEHXhiBwSjxHh5WA5Ws4bO0ISX8pA 4673
apache_beam/io/parquetio_test.py sha256=RYR0GDHLEeAXPGbBfofC8ebJ7aiNqtH6f0kZBy8xIUY 21314
apache_beam/io/range_trackers.py sha256=BZgryRS6VjuGXo0FhuNf8Lf6lFdFxyqeswInFbk9P4w 15449
apache_beam/io/range_trackers_test.py sha256=uQ0xKfDlRxbNIzOrlO5nX3YaWZLSPhGJW-wdGV2uf3M 19691
apache_beam/io/restriction_trackers.py sha256=vleRNOwJLDTpc6MQTYh91SbaaXNREf_dY2TP0_6lq7g 6167
apache_beam/io/restriction_trackers_test.py sha256=x6R9Tj9N2VPprfxT01UCoSO9uK9kFTeU1KJkkXJNb-8 7291
apache_beam/io/snowflake.py sha256=1H_0ZxgQDD5Q5WjPu7ztrjcIiicX18lG-BMLYbd1HTk 18521
apache_beam/io/source_test_utils.py sha256=Y2IwrzTdzEEnyG0SnBhDTn3mEiqCBCzhYZ3_kzxpJPQ 26148
apache_beam/io/source_test_utils_test.py sha256=QtiKW4adJhDLPRIWmiGGKHUu4ZorjJkDFRLQ3uy64qE 4925
apache_beam/io/sources_test.py sha256=3oUi5EPlubvzdIVl_KOGA4o0j7QUFEwdVWkuLT4cJcs 3979
apache_beam/io/textio.py sha256=AsyoSU26_uegt0yhCpnyv-hprtPUJBNUrRDZmanjR8o 33543
apache_beam/io/textio_test.py sha256=Bk77_GjlwPksXBXIpKX-z2W2y2_9ur_IoQe-J3NInrk 60484
apache_beam/io/tfrecordio.py sha256=P7jb7hsERYq0b9xWnxpoPGd9_gs-thASmEZydAL8M8g 12205
apache_beam/io/tfrecordio_test.py sha256=4HWQVB_VIl8CEG6APmE2MBBBYdCNfDCGbCOqVPJLR-g 19751
apache_beam/io/utils.py sha256=Nuvb2TcA_CrSvffJZifVC6l31R3DeZfCczoXbxUUvbw 2347
apache_beam/io/utils_test.py sha256=fjbIPphPr4oWNF5w9ddRjKQ3x65R3cFLiXX4MHYaBQM 2312
apache_beam/io/watermark_estimators.py sha256=2skfo35UAisjCftc2pna5Iyl0tEPwObOQHTUuUOfwI8 5425
apache_beam/io/watermark_estimators_test.py sha256=nzTu1TfvILK9yfgRJA_rXG0BNiBRVCZAxRqNZK7eQ40 4700
apache_beam/io/aws/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/aws/s3filesystem.py sha256=UClfjcbSKbGG2K4HfXrDqmr96gNaKvDdSpGq60yZ54A 10400
apache_beam/io/aws/s3filesystem_test.py sha256=ytjwncJ-2LK1h3vELMDMwI7Dgc3GfG66zllYtpaDtVc 10263
apache_beam/io/aws/s3io.py sha256=03lGjyz8D2o2GNUUw-CVec5DWpSmq6ttbeHv_p3TL18 22569
apache_beam/io/aws/s3io_test.py sha256=iOCqt4sXdhYskuuexxsPu8qQyTHiCZ9DcBtJBTb5F1E 26181
apache_beam/io/aws/clients/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/aws/clients/s3/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/aws/clients/s3/boto3_client.py sha256=NQdlK0pzrHchhSI56vbmCaQEV5Y5kI1doGnx4teGj_E 9687
apache_beam/io/aws/clients/s3/client_test.py sha256=ZyTb8LwoIKeW13Bvtmfu7AnDVZMUqP6GYFMJXtvoTN0 7543
apache_beam/io/aws/clients/s3/fake_client.py sha256=T_twQDgR5QIDltbkrTNM3v5ed3bG1ZZub-wfJRuh6mo 7762
apache_beam/io/aws/clients/s3/messages.py sha256=L62KFPLWvycUNt1rpzXMGeRnwDmCfHkUWlq_nOBk_i4 4023
apache_beam/io/azure/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/azure/blobstoragefilesystem.py sha256=36BEUItavw0gefdLILjt2Iw8BQ6kpBNQ4Dk-TbpOH08 10489
apache_beam/io/azure/blobstoragefilesystem_test.py sha256=dzeKS0tYauUPPJR0CpkptmIkb5Kokv5YbZ5M0mya3CQ 12919
apache_beam/io/azure/blobstorageio.py sha256=FYFQ14oSpOphkU5c0odsWlluRy553Zqu-uGhGwqHZjw 23125
apache_beam/io/azure/blobstorageio_test.py sha256=9bPH63-KcZSPEc_3iS_CH6r6dpwPwyDGBNNuMImo_8Q 3211
apache_beam/io/external/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/external/generate_sequence.py sha256=Zfs1F5TUC7-X0Uzj8spsbcRNz-U_eTh9dnod7-u3x9g 2467
apache_beam/io/external/generate_sequence_test.py sha256=Hx-h_LTlBTSkxVpWXSFl0Fh1VvSAYJ5N6H5vsW7ey-4 3329
apache_beam/io/external/kafka.py sha256=eUCG-8gp1q7ZZIJ88BXeUHywvawllis4qnATFH3_vH8 1175
apache_beam/io/external/snowflake.py sha256=YrzvY4LNeu3f3YVSyTFVnzesKzSl4lwNjS_UeLlZi2M 1207
apache_beam/io/external/xlang_debeziumio_it_test.py sha256=j-IdWmSGYl5bh8gJGODwr5NSjRxhuSU9ooldscPSJAA 4185
apache_beam/io/external/xlang_jdbcio_it_test.py sha256=MfbIsTlDlo3iwlFiEeok2uSHYKb5fmG1YnLIiPTJEiU 7390
apache_beam/io/external/xlang_kafkaio_it_test.py sha256=ceRiXvcESz-nInQfId15zLzYJxWyHuTcobcKcE976E4 6523
apache_beam/io/external/xlang_kinesisio_it_test.py sha256=V7byCFGBroLvgRtpwyHUgZRPi5qUTNC1plrElFk0CmE 11095
apache_beam/io/external/xlang_parquetio_test.py sha256=9pkNbd1UipIoMlYC00vbtyeWlRkuapRfqKhMmt4Ermk 3039
apache_beam/io/external/xlang_snowflakeio_it_test.py sha256=J7V83cErGNRYrMqFjMEInjwJuzZbd6VTcfsKb1B-zcg 9092
apache_beam/io/external/gcp/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/external/gcp/pubsub.py sha256=XF7G_dGluRRJ6iZkocL1Eg_QqTalENKyMu7ieaprBZ4 6496
apache_beam/io/flink/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/flink/flink_streaming_impulse_source.py sha256=5KETK5UZrHDKrCP8htcHyierwi-rp_P5cetBkbxzWcQ 2831
apache_beam/io/flink/flink_streaming_impulse_source_test.py sha256=ok1pfVDiqo4t3yo9IAP9ktOfNMYDI2U0q-8StHcX0h8 1428
apache_beam/io/gcp/__init__.py sha256=s0Fw5iYcpF1vtFqUVRiE6lvrsz7mPYADZs2afWdr-ys 1488
apache_beam/io/gcp/big_query_query_to_table_it_test.py sha256=HrpKqZfdecGsMKQAlbKgLQPSjTeq3a5ajQkrQ3KUOe4 12426
apache_beam/io/gcp/big_query_query_to_table_pipeline.py sha256=4pJ-Y5EgjJ9WqJhAPF5HXf5lmT7t__4UwohvXQRKla0 3693
apache_beam/io/gcp/bigquery.py sha256=7lonTH8r4TU5Lnlhml5WxWchEm26XAU3JcEyR1kvsuo 114212
apache_beam/io/gcp/bigquery_avro_tools.py sha256=giH4tD3a7GIGErhbv1m_ILbf6NYgELlKb5KPMhf0rr4 4388
apache_beam/io/gcp/bigquery_avro_tools_test.py sha256=uxBKtkHjVYtfuyq5gBEYmZuObu4hFsJ9SQpIW31B5U0 4519
apache_beam/io/gcp/bigquery_file_loads.py sha256=i2RLxkG9Rkk4ZiQVnmVdB0WZevoioUASoby6KlqfAwg 47486
apache_beam/io/gcp/bigquery_file_loads_test.py sha256=em2vUkU10DdTtmJSCpAHvGj1TuNc9icjMk8cZKnqkXo 37859
apache_beam/io/gcp/bigquery_io_metadata.py sha256=wIwsmTCK1Cp5usQ32nhuWk4c4jfef0qDxv_3MMcjKDI 3452
apache_beam/io/gcp/bigquery_io_metadata_test.py sha256=_goh9ltbGgPhlhk4DTvtLEesmuKUYftA5aMCh1BZsh4 2663
apache_beam/io/gcp/bigquery_io_read_it_test.py sha256=Qn7vcWseDWUuSRi9m1W7jj7tImfR8kyqb-OddjVmv24 2383
apache_beam/io/gcp/bigquery_io_read_pipeline.py sha256=Z8dwdTbaVIe12h053PVhJYKrV3iRj16_C_oDd7M8yLc 3134
apache_beam/io/gcp/bigquery_json_it_test.py sha256=gDagOlhEnZpfUISlMlntnpdojEg-q28vN7lO6XigpEM 15021
apache_beam/io/gcp/bigquery_read_internal.py sha256=CI4gneLD1EK9C_jpnAs9itl6977mVsxLVQSZIzkPJ-4 15098
apache_beam/io/gcp/bigquery_read_it_test.py sha256=TZQ_GcGjZDW27o2KUw2mT1xJd4gOSL4VqDZWeAdsRh8 24578
apache_beam/io/gcp/bigquery_read_perf_test.py sha256=e6Sibt4AAORcFXln6L0PQm2NBSi_nSUP-e7gFIlKLbs 5023
apache_beam/io/gcp/bigquery_test.py sha256=oa3eBwZK6VNL11_WU7DcJ7BJKQqyaIe7eo8Wm3BOZ64 80712
apache_beam/io/gcp/bigquery_tools.py sha256=ABZMiiA8RLQsS0XUPWRNUlMpPH-2auQn71H87c-Fh5Y 67052
apache_beam/io/gcp/bigquery_tools_test.py sha256=XVScdhbctAWbEa5XWO3yGcI_Mn2O_95pxUW2pUrhq_Q 48680
apache_beam/io/gcp/bigquery_write_it_test.py sha256=TwVIKjAhJXSxnhJAOUPB7AOJIjyQ6WeB_cPjzZsbZP0 18163
apache_beam/io/gcp/bigquery_write_perf_test.py sha256=c1UGneJaZnsSvrnS-BzSuZ7V3TjrNc3VpwAaAz08Iu4 3920
apache_beam/io/gcp/bigtableio.py sha256=flSmv-rnsHoJ9rM-I9_3ojbeF278pmIWqR2H_iJd-xo 8301
apache_beam/io/gcp/bigtableio_test.py sha256=kTXg999-wpxD2vBXBbATgWquL-jo1sbzlSfCaxpYTR8 5332
apache_beam/io/gcp/dicomclient.py sha256=C97oAme0jKJalHfSO6R6W_o_TrgvR7jYrGw8pmvOW3w 3893
apache_beam/io/gcp/dicomio.py sha256=OcdNFt32RvcoIUMOMustGR0z91Kuzu1Tnoh_G0_uHzU 20660
apache_beam/io/gcp/dicomio_integration_test.py sha256=wN6IROWj_cd0FwmlG2LgxzEDM9OfgeoLaa5iPDLEqec 8249
apache_beam/io/gcp/dicomio_test.py sha256=qeZVdOGLSZQmEYLaC6Jsk383FlHyNpOg7DEze8oVYQM 16883
apache_beam/io/gcp/gce_metadata_util.py sha256=t9-gumABjWwluEsLigzgQm7gAV2NTxj8cfi-d2jMnsY 1572
apache_beam/io/gcp/gcsfilesystem.py sha256=am6Vbd5qMETphqKo4nP0nXGYPonQ9m-lFDJHibKYjWc 12095
apache_beam/io/gcp/gcsfilesystem_test.py sha256=Ys1VzUEj5gZgCiYfgvMFuD9TbT8RR_C4iHS8kG4U688 12538
apache_beam/io/gcp/gcsio.py sha256=v1qL3P76YpomVaabbjL26g5zThs1tlFequw4K3M1my0 29203
apache_beam/io/gcp/gcsio_integration_test.py sha256=bTKXFN9819d6av8ErnXvAM6ITRg1Lqwj1Pq7-ARBnfo 7585
apache_beam/io/gcp/gcsio_overrides.py sha256=gxRyuEHoxh2Ol1uUlyNh_-iwCt13kA182ed81Wlr1DI 2063
apache_beam/io/gcp/gcsio_test.py sha256=IOtLovyxBFQclve8yz88yp0kRd4CAGH_kTJeetwcMpY 33236
apache_beam/io/gcp/pubsub.py sha256=Iu6cDrRRYcHT_8upxQMHLWuwkcyw4R3jhdy3heb76ME 22836
apache_beam/io/gcp/pubsub_integration_test.py sha256=OQGnU_DLQXqUXJFGaJvNafCNJXKUFCPEDbmXoYw_IJ8 8985
apache_beam/io/gcp/pubsub_io_perf_test.py sha256=MeVy6yTRsWVHxWXTTeUJoiEGRR7bYOGdFwfSCWY1Y70 7736
apache_beam/io/gcp/pubsub_it_pipeline.py sha256=ooh_Xp7izBBJtF0BScWVkzkOJjp_gS7kqc-F1ificNg 3206
apache_beam/io/gcp/pubsub_test.py sha256=HQIS389_NIr6LPXGw1GPkPH__oNmDkuBirxfleeLyew 37207
apache_beam/io/gcp/resource_identifiers.py sha256=1-OCaEjifUekZr9up0Vdc0Zhf79o-y1tj7coZ-amPJM 2145
apache_beam/io/gcp/spanner.py sha256=ookC6I6m6dX_OnS0Ub_d-UK7a2VWW-EalPY5CcIIJ20 21215
apache_beam/io/gcp/datastore/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/gcp/datastore/v1new/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/gcp/datastore/v1new/adaptive_throttler.py sha256=WBW6c2cJixGNeoMIaI4-yBRxLYsKaTTKM_h_XCXHkAQ 3713
apache_beam/io/gcp/datastore/v1new/adaptive_throttler_test.py sha256=dThx7qUY6P4LyDLSG-FiWjLyO9QbHx3J6JIyf3hrToI 3994
apache_beam/io/gcp/datastore/v1new/datastore_write_it_pipeline.py sha256=mtOLmV50_QjsfX1iB0tTRfzMgKGxOf1GrxAz1xYrR5A 6106
apache_beam/io/gcp/datastore/v1new/datastore_write_it_test.py sha256=lUrl8sJHqZ8V0h02ooqgD9vSwwiAGWs-kcp83Sm3-4Y 2570
apache_beam/io/gcp/datastore/v1new/datastoreio.py sha256=G6cJcVMrDgkhWiBUOiJCY6fK2rKaapjqudeD3g_K7mM 23818
apache_beam/io/gcp/datastore/v1new/datastoreio_test.py sha256=Jtzr1LVcACeMcZIZjfsPKHeLrsIYWg2Kr-kojAc8jxs 19813
apache_beam/io/gcp/datastore/v1new/helper.py sha256=ql3aERTPH-qQwtuw15jXyHPOxi1u6Ydl-_rk5WxVSbo 2996
apache_beam/io/gcp/datastore/v1new/query_splitter.py sha256=jf90_yWjg0W0EQ1o3o6xYBQ7bPn3MzNKw_5dC7_-xm4 9602
apache_beam/io/gcp/datastore/v1new/query_splitter_test.py sha256=86uTdeWmpGYWkaq2yEL2rLG7nzhDcK6xhywVD_9WTlU 9623
apache_beam/io/gcp/datastore/v1new/rampup_throttling_fn.py sha256=qwN6ogBKpGTeBp0APnKX5AXMZ1DpHIUDp2CXrq0QPhE 3682
apache_beam/io/gcp/datastore/v1new/rampup_throttling_fn_test.py sha256=MD5FNMhlm-4FvSVygSAlEBnxIDwucGtpfCn50rL6-Sk 3002
apache_beam/io/gcp/datastore/v1new/types.py sha256=JAOMUKhDCaGK5TWDBpDjSM21qy5BJa2rSZKTW-n2SG4 10154
apache_beam/io/gcp/datastore/v1new/types_test.py sha256=TrsOXswfQgzimW-ylTOHABsPxX6cWVhlFccAqFnKXRw 8703
apache_beam/io/gcp/datastore/v1new/util.py sha256=svm1HOBqxX2vOw_NLXGrHKgEV0rOHlCm8nDFYpTBYIc 5320
apache_beam/io/gcp/datastore/v1new/util_test.py sha256=UcS3igbb26yEozlvfea2dWfPJ-LCx5res4xTeiSuJro 3590
apache_beam/io/gcp/experimental/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/gcp/experimental/spannerio.py sha256=iZrOGY3TgKWxjqdF6DkyhVK__ZLFQK5-Q8z3zKg4_C4 48714
apache_beam/io/gcp/experimental/spannerio_read_it_test.py sha256=JL8R4y_qWMBMSFkreF7kj-5O4v0gKrzIiS5_gZvjUtk 12379
apache_beam/io/gcp/experimental/spannerio_read_perf_test.py sha256=GMZB3Iq44xk2w1UFAUUw34QI-4u1TOBdx67uAqj6Eqw 5583
apache_beam/io/gcp/experimental/spannerio_test.py sha256=rMlCJ1usSoWPYJ_qK0Oz2vBa2_Br0_onXorm-fmo_5M 21824
apache_beam/io/gcp/experimental/spannerio_write_it_test.py sha256=absuxhdJnz9nfPNxjJt1kN8xhwOhihSIK1w6oIeBSTE 9732
apache_beam/io/gcp/experimental/spannerio_write_perf_test.py sha256=D6LRoUOQrxCofLFCy13sokZhpm7igoxWhHvl9eFXMd4 4912
apache_beam/io/gcp/internal/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/gcp/internal/clients/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/gcp/internal/clients/bigquery/__init__.py sha256=luFMTp-voB7UzkxTVvldKSXT33vygo70o2qB8fSav7I 1381
apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py sha256=l9PdNsuPXJ7e5raf64bDV_2sxiyW7OIUqIWg0K0iyjM 43758
apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_messages.py sha256=aKwgYKEFShwq-bonq4DY5kBe8AWGEKtBaBNVhhpQuyQ 229519
apache_beam/io/gcp/internal/clients/storage/__init__.py sha256=rV-1ppLqbGu1YXAGwxz6JtOmQrck2l2Sp_mFBP7baGA 1376
apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py sha256=-pJBLUHww1iIJqMitgvAJbjekOggxWx71-THrQUak98 55771
apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py sha256=R9MT9zl0O-ID57IN4U631p5pMiMfjPwsabqyyITYG2o 115593
apache_beam/io/gcp/pubsublite/__init__.py sha256=7YrXItT9na2GTNSrNtc4V3ZXq4ct9k-MXU5I5j2qoi4 912
apache_beam/io/gcp/pubsublite/external.py sha256=h0Ia8ftvbA83LGP0BRs2vmduMS2prsxTYsz7US641dw 3667
apache_beam/io/gcp/pubsublite/proto_api.py sha256=qU3LmuG0zxDRRj4UDm8FMsbg8ypTvJzlxMN43aqKu1s 3438
apache_beam/io/gcp/tests/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/io/gcp/tests/bigquery_matcher.py sha256=CL3F-0KrQh2n922RGAvy8B9A5dCQW05l47cQdJxBUtk 9185
apache_beam/io/gcp/tests/bigquery_matcher_test.py sha256=a8raMfHmwKMDQXDeNm515oEshUWJkIQUM4ytsKHMCgc 6354
apache_beam/io/gcp/tests/pubsub_matcher.py sha256=O3Wdt7FxLngb88cdSeN3Rc5jShNbuhXx_JUSgy_UMiE 7766
apache_beam/io/gcp/tests/pubsub_matcher_test.py sha256=z5IS4gcCxLsPco65MbWz0dg6EG-6_W1_3lkxCVkkZwY 7870
apache_beam/io/gcp/tests/utils.py sha256=4SN7aLeFea46aFa47ek3LluFhpE2XiWVutEw6XRGjls 5322
apache_beam/io/gcp/tests/utils_test.py sha256=py24m4p0gNylTZ_jWCYnjVvSnmpUu4m54eFgnhhOTB4 9845
apache_beam/io/gcp/tests/xlang_spannerio_it_test.py sha256=HiRny3H9r1aquP5BkBqIOhMErhzTe7VS861BOZdMSH0 11063
apache_beam/metrics/__init__.py sha256=CvTQsEdzo72aQFZHhKkO9PUA2Ehb59MnHorwoUBIAHk 884
apache_beam/metrics/cells.cp39-win_amd64.pyd sha256=_goO0-SDyWiIFgsL24E8dAnf8CktoQnc6f8skdiF1hw 179200
apache_beam/metrics/cells.pxd sha256=r9F8HRULHwDh831b0Ms-03oIrnFsYAxyV30HiqOCK7c 1594
apache_beam/metrics/cells.py sha256=1clDLL0pOMQWzLEwO_mfhbCQukkZtmu-cIsjed3Jo9M 15051
apache_beam/metrics/cells_test.py sha256=dyPMpX9pD8B-TV-Kb92WKD9T1zsztLltvVoCb5KLLO8 4885
apache_beam/metrics/execution.cp39-win_amd64.pyd sha256=4AyHC-kvTeHY8MnftY4ypPvnZd00r200H_DInWYgBSY 130048
apache_beam/metrics/execution.pxd sha256=QNJO4BNDF6yuIa71JhSqW7eB2CV9yDHL4EPixDbkwOA 1432
apache_beam/metrics/execution.py sha256=f0hUiwU_dqQg2BbqA-f4a0oPJ62BA_l7eLhMGlyv5AQ 11705
apache_beam/metrics/execution_test.py sha256=7aRrSCXeKXvyUPvKOQolHXIcHJBdXnVTDrxkXJTe7VY 4592
apache_beam/metrics/metric.py sha256=n8DI4xqmQja4HLob6qI8wPfIWCu0YhTZsYUrOMT8d1Y 9696
apache_beam/metrics/metric_test.py sha256=V-5lUqSPOTGEqclc7gpm10N_886DUbDqvxvTwVVRX2I 9354
apache_beam/metrics/metricbase.py sha256=1mN6isrO2VUV55NOwheoot8wHdM7u4zhI_bFM2mpRww 4768
apache_beam/metrics/monitoring_infos.py sha256=1GfCUPUIZqA4m9juegf95LDc-IY-3RULJsRgCu47B00 17715
apache_beam/metrics/monitoring_infos_test.py sha256=p1XN_qxc_BlesTpURzYuRhmOTsFPrnIPf-2THmySZug 4444
apache_beam/ml/__init__.py sha256=bDEGYUq0x2IsxbmeHpUUum19PBCeuBLCxkxnYmnUZEU 852
apache_beam/ml/gcp/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/ml/gcp/cloud_dlp.py sha256=TgP0xD5TNTS7Ru5OyjfeZDHks9az9OxY5VHdPbKTI3I 8487
apache_beam/ml/gcp/cloud_dlp_it_test.py sha256=AvF_HVWdKoxC0E2LFbyFaYymkEmp-mo5QzJ1DyqNQ_s 3307
apache_beam/ml/gcp/cloud_dlp_test.py sha256=I_cICA6rzVbvLrHu5LLccfHWY33f640G9BUtan2MRJE 5040
apache_beam/ml/gcp/naturallanguageml.py sha256=QJS6tkOmCSBoj_L-dQ5JSS1cCc0QBmtFmy6kOiHpU7k 5180
apache_beam/ml/gcp/naturallanguageml_test.py sha256=YfmbC7JSc1ZKHOPSECZrIasuFfSgLrRTFy0VrFitMZ4 2983
apache_beam/ml/gcp/naturallanguageml_test_it.py sha256=yBk9OfiIEimjH6M9BHUfvuY1xc1BRL5LvdRPHVyXglo 2449
apache_beam/ml/gcp/recommendations_ai.py sha256=DNoI6CwgoGqTz13URZUnOBWTUNHPEh0_oGuuQkWeZAc 19554
apache_beam/ml/gcp/recommendations_ai_test.py sha256=AgNV-pNmi63keiJHC6WU86OwDq7sJMi0DSB3giik0Ig 7200
apache_beam/ml/gcp/recommendations_ai_test_it.py sha256=iMwDF82fQQs5ei9-i8o_FIVz6ed2FOWqUg_jVmFpEZU 4077
apache_beam/ml/gcp/videointelligenceml.py sha256=l35K2dHjH_trmxQsfxOipHSJj9Xk4Q4cShXXgNs4xOw 8222
apache_beam/ml/gcp/videointelligenceml_test.py sha256=kuzxHG3Sosz8ra4lHzNIuDHL-9ZmxYsbd_TMkf6NmFQ 7830
apache_beam/ml/gcp/videointelligenceml_test_it.py sha256=wwMwiMLk_uD0BU9N726Vj4DPZyvy11T9ARUkzF9kdJI 2790
apache_beam/ml/gcp/visionml.py sha256=7LQGicOVNOVA5h2hES5u54GS3uLcxtD2TsPje29iPfs 10626
apache_beam/ml/gcp/visionml_test.py sha256=PlWNM0hiq_fauQI85ciBP2zf7jeyS-qccpAmAoe9KNo 9297
apache_beam/ml/gcp/visionml_test_it.py sha256=Um0xC44rvn9cO2kcZ22b9NL7sLflUpAe8EE6bWDiBYo 2470
apache_beam/ml/inference/__init__.py sha256=GXg9gIEMaZ5rRJwyy2aLX9VTjmr3K9k7LmNxrN_TvwY 1042
apache_beam/ml/inference/base.py sha256=W9urbSs4_UZuqfacHM8vPEEdi55QFI0Kw3GLJdJPnTg 14695
apache_beam/ml/inference/base_test.py sha256=99SaB8veqeP57-x2zBsqO4jYodluKdzrDsbE43GnLjU 8255
apache_beam/ml/inference/pytorch_inference.py sha256=VKhz5yx9LSNgprSTANfGQfd6DEGSQaZK5Fzvx2Llyok 8853
apache_beam/ml/inference/pytorch_inference_it_test.py sha256=e2LN7A0R9DbzWNZ0-r0Bb4xpZe6LyrnS2B-HIg9NHzM 7484
apache_beam/ml/inference/pytorch_inference_test.py sha256=KQktUXsp9sAj9Em2CCwL8b3mtk9MuBYgAy-8Wf-valM 13756
apache_beam/ml/inference/sklearn_inference.py sha256=4nGRWPkfT4sSHKrxY4EH8f2XGxcjyiBzFkKl3uhCJ_I 6979
apache_beam/ml/inference/sklearn_inference_it_test.py sha256=5dxh60BYbFMjyl3_KwSIL_MCIinkTXuAPsf4Vu8RHh8 2873
apache_beam/ml/inference/sklearn_inference_test.py sha256=V3YXJ3n10hEaBg7VyHL-urQwbmHSeJQJgHWRaIhSHoQ 12058
apache_beam/options/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/options/pipeline_options.py sha256=sOOQIJnmLPD_RvGjCMUDNh4jR4sAnIgso8WB6HBrXHM 58908
apache_beam/options/pipeline_options_test.py sha256=sgqOG7bK9hH-aR2yT5AEaPTSJR-KzBgWqqbIs3Ucf9k 27421
apache_beam/options/pipeline_options_validator.py sha256=rHbD8KOqe1enD8oSEt8w7d3itsjpZdGvqvDEV1dQNUg 15946
apache_beam/options/pipeline_options_validator_test.py sha256=h5ZyCb8iz6RIcoRP6YW-jXPCfXBo-OCWjQ3gXQ9MYQ8 30916
apache_beam/options/value_provider.py sha256=qh89_kXQAVVDgiFjDmDwKOUv3EqE-2gqITEe70TI_Tk 5827
apache_beam/options/value_provider_test.py sha256=R7l5_cNmlQY9d45ErN1kvWBVRbbuD09hKTLFNuHLVfI 10494
apache_beam/portability/__init__.py sha256=OpUu8TukLPlUn5MDBWLC8zD7Ow9RI9aC4kWRNbMsAUI 853
apache_beam/portability/common_urns.py sha256=O54_kFZ5aAWALHOgigbtg222gx3iXK4HsNj8nD2zf4Q 3714
apache_beam/portability/python_urns.py sha256=CblqgDs2EVPCfdw4RYDxXFJjoz_GbFKxdnC4_yMOfgM 2698
apache_beam/portability/utils.py sha256=2IhTQ4RgfQjNBrewioze8ikK-KnDaAZXZjx9zmljxFw 1238
apache_beam/portability/api/__init__.py sha256=P2jSWBbgorkXEukzhEi-5fRs5KnicYpNUDfFBrstBjE 2653
apache_beam/portability/api/standard_coders.yaml sha256=COO1qXHgWix-iWLSRSpLovSQyMmiZKnOI2H7j8yU5N4 20962
apache_beam/portability/api/org/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/beam/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/beam/model/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/beam/model/fn_execution/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/__init__.py sha256=nMzzFAZIAD285KgxQrejeBrb6TPXSzxbT_xVIrVj-AA 928
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_fn_api_pb2.py sha256=NX_lJ7Tly5E2mI0y7VVEo5QV3bpElnVTXgDECDR7nJU 188618
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_fn_api_pb2.pyi sha256=c4wHRNlxkW09F1PEHDg4xESqp7k9erbbJW0-9SqIj8M 104935
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_fn_api_pb2_grpc.py sha256=DlqHhrNhI5FEpmvc-o_QjBLfDxYfhzyyZETEm1tlL-k 21746
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_provision_api_pb2.py sha256=JmjF9bivD-0fepreae4TcehVjBoBnMVi2LNeRCOukKA 15129
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_provision_api_pb2.pyi sha256=UlB2gjtSVZa5VUbi2RLEGjAtH196ztqJNaaPOK14DJU 8841
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_provision_api_pb2_grpc.py sha256=jve1riXN2u0kkZPBmbwGnxkmAga3cNz0U3XPbfFrJDM 3727
apache_beam/portability/api/org/apache/beam/model/interactive/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/beam/model/interactive/v1/__init__.py sha256=VaEVm2uzscuyKkz9bQ7Jk9Rigo3bWjiLId4U8MouLBU 867
apache_beam/portability/api/org/apache/beam/model/interactive/v1/beam_interactive_api_pb2.py sha256=9xQEB7f4U317J6zJP-8LDWic-aRm4MbO6qikmInQFtE 4842
apache_beam/portability/api/org/apache/beam/model/interactive/v1/beam_interactive_api_pb2.pyi sha256=Cvdbz3ctOUh_2tbnPfd4b_Q0qFVBinQf2woycBCWaMc 3241
apache_beam/portability/api/org/apache/beam/model/interactive/v1/beam_interactive_api_pb2_grpc.py sha256=1oboBPFxaTEXt9Aw7EAj8gXHDCNMhZD2VXqocC9l_gk 159
apache_beam/portability/api/org/apache/beam/model/job_management/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/beam/model/job_management/v1/__init__.py sha256=i4ABvam3TlXmN3YA2TaIf0zGbFK63Z1XmvQCtIZtt4g 1048
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2.py sha256=p23pLQZdM4CCGYDw2DiBS9Ejuj1m7D0ocBMKdDdIMpQ 47566
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2.pyi sha256=jPX9JbUJc2P19UAl3C9jmi9LkT4ZY9mj5TeaxThsD3c 26977
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2_grpc.py sha256=rrf23hhT7YKMA6ZLvkflI-mLl4PFrjTfLBOEcfkGXs4 20025
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2_urns.py sha256=CF_PcY6fNAcnG5FFiTe_5a27mX7viBkDDR-FLAlvSmA 444
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_expansion_api_pb2.py sha256=C4FTwHGTlcWseCIHkY1eASW_RLs_-_5RGXP7gHcdK5M 11638
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_expansion_api_pb2.pyi sha256=tvLVXDrCHGYQBwou8Er1jpppq31OtUiQP4TurxytnUQ 6634
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_expansion_api_pb2_grpc.py sha256=0ZkdaSx_bFcZI1Of8ixEGwqMsxuy0C4VOpxvwmxqH9E 3053
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_job_api_pb2.py sha256=xgR4v8Zs6m9fq8-dc-FBVG1ZQERruzUn6usVMBMTcXY 60115
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_job_api_pb2.pyi sha256=oGUoSpzuLQuePa4-vWhkdu-rq4y69p2g71d5u3Ye6Og 35048
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_job_api_pb2_grpc.py sha256=X_insVlWSmPtWiuSX6CjIv0Ozqp5M5gLen_2AokyGpk 21309
apache_beam/portability/api/org/apache/beam/model/pipeline/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/__init__.py sha256=mnRXG6sUywWxb0rXhnJ_c-KGKH9v4dKAi_YM2RXzXJM 1378
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2.py sha256=94oqgeAGWOXLvDe0uTuhJahYuNtDEw5dDeUyncLgjWk 298374
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2.pyi sha256=hWoYOCjRVBBDDRHTD1aMNnY0bLgxNFYq7lQ6RHtUWQI 170229
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2_grpc.py sha256=hjL96T9oaYlX5KIxUMVoaBQ_o-dAbSO0iqZ56ywUV9k 3040
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2_urns.py sha256=Rd1_oUkPMnMF1hhlHtOneeE0Iau8-Xq51lqwjMK2ltE 13822
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/endpoints_pb2.py sha256=1S1gLv8wzDFKHcAdCdPmy24-CNKJZKtomvUnuPeiuJ0 5218
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/endpoints_pb2.pyi sha256=bkIUd6SBZ_tvHHtKHSB1WFyGhU_cng6PrucBIovu0NA 3173
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/endpoints_pb2_grpc.py sha256=1oboBPFxaTEXt9Aw7EAj8gXHDCNMhZD2VXqocC9l_gk 159
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2.py sha256=iN5juP1m9ZThhkWEPonWEqnucwI99xoWIJt79K7xAMo 12331
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2.pyi sha256=X7NGkruVcrgsbRXKWjAbOHjPbuT-ijFPbK4SRiUbXQE 7799
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2_grpc.py sha256=1oboBPFxaTEXt9Aw7EAj8gXHDCNMhZD2VXqocC9l_gk 159
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2_urns.py sha256=MTyk0yuDVnMIOq2ESV8x9vGveoICPDNlg4I1XhJ79K8 432
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2.py sha256=_fmDzXPTlSNZ1U1WdpcPPdRx1eS1sAsno5DP7hq8s6w 52069
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2.pyi sha256=2Gwm0xMGX7Jrt4gpvxlqs2durvNC4ZAW5G-CtPO7R70 20542
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2_grpc.py sha256=1oboBPFxaTEXt9Aw7EAj8gXHDCNMhZD2VXqocC9l_gk 159
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2_urns.py sha256=w64cAkbHnB5q70Wq2HPIECY1VphWdX2tbcCHdeKF3YQ 14260
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2.py sha256=qws106A3bvvla6VDW5wgXczK1U9W4IUGMAqva66K_Iw 54641
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2.pyi sha256=Njx7Wi4PGS77XZVLrdPr16Nl-cBDtkUzP6zeuxhL6LU 30649
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2_grpc.py sha256=1oboBPFxaTEXt9Aw7EAj8gXHDCNMhZD2VXqocC9l_gk 159
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2_urns.py sha256=s2vtQ20rXgfI2Gmc9LC45PuRwppUBI4_BmhJh5F527o 570
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2.py sha256=hc0xn-uWQi5vVhhq9pdLKsooLTgieCBkqEEiVYQrhuw 13238
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2.pyi sha256=mc84BK5SaWD2pW86JIXGPdQiIT00qpDkWLWTjyUIEQo 9140
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2_grpc.py sha256=1oboBPFxaTEXt9Aw7EAj8gXHDCNMhZD2VXqocC9l_gk 159
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2_urns.py sha256=xIU41cgtqMs7HbXF_GuawMJTccrHov-3Eyxnu9tyWQg 1035
apache_beam/runners/__init__.py sha256=8vq4lBCWLwwNes-VxyEPgu9ZfPH5PEaBsxkBtZQp-ZU 1352
apache_beam/runners/common.cp39-win_amd64.pyd sha256=Mu2hI6tDhAuGl9UUj5c8JqYCHEigIxZUgYoMDOQSCak 664064
apache_beam/runners/common.pxd sha256=znNpXDJj2RtzSWrgjFe8jkpmxRDklvFCc7xq9Rl3RU0 6340
apache_beam/runners/common.py sha256=ehGcNB-hVWn9wVEtl9fR7w0TCLYrfhXxT6S9yAqfrQ8 73991
apache_beam/runners/common_test.py sha256=WI2SGr02plS5V9bh2gQaHszgtBy9jz_4EYJr-IHTSQo 21351
apache_beam/runners/pipeline_context.py sha256=-K-8sM2wAqJwK2Py9V45KeOVdDX8ueIFSDTS135djH8 11865
apache_beam/runners/pipeline_context_test.py sha256=yLtHsp2rcD_bAK2L3uC-GwZadTogfiLKN5-oYmTkAOM 3727
apache_beam/runners/runner.py sha256=QowmuMqZcIvxT-DsHEU24-MnNpyPwTUf99xZyiBbjW0 14441
apache_beam/runners/runner_test.py sha256=1r5HhuWpJzl9-J5Cogqmx9LpXRzgYlE82QgrmAvo_rU 3055
apache_beam/runners/sdf_utils.py sha256=pCSNWrVQmv_OIjPoBT2njf3Vcc7uycqqTR2InrN0Nhg 9250
apache_beam/runners/sdf_utils_test.py sha256=tAciF8vHDySh6llMsadxIFL2ylma7yCIF4-w8706ZEQ 5878
apache_beam/runners/dataflow/__init__.py sha256=dv78rRo_6vaEBhv3GeEHxM8vnDL59xoQt9_-aG1f0YI 1135
apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline.py sha256=0p7m91bYrZbNMjjg-m5XVDWjD8HWOjiBBBr5IaojPeY 5892
apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py sha256=yZDwZuZY-pbU9n1OKO6V4gzZnJgT4yLxbfL5d5sPxJE 2332
apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline.py sha256=Q0o0I-cOZKHt26uVB6qBVz44QwIRmqkURXdJ_UxcNo8 3403
apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py sha256=JtFOQ3zLx_Pgo2Ldyp9q_VReMkME-oXslzAFIjmuFxc 7061
apache_beam/runners/dataflow/dataflow_job_service.py sha256=OxTQEEx3OQxGEvKohRQbO4guRERyDHCXDCPbjcMzbQI 2806
apache_beam/runners/dataflow/dataflow_job_service_test.py sha256=rTEGzy-cvxyfpZZ4a-uH6zD3fcEIORs1DKO7UGPiD1U 2275
apache_beam/runners/dataflow/dataflow_metrics.py sha256=2PtXfpzLGeZYAz8mbFqVOS-G2mLS2oSh4QzbCdW5DKc 12996
apache_beam/runners/dataflow/dataflow_metrics_test.py sha256=OfQv4QMvpGHW6be1zWKkuniSpdj5elDSzmVHNkWD_ik 21108
apache_beam/runners/dataflow/dataflow_runner.py sha256=JEj1ibhV1p9sjeiBMg9-k3WnM98IfTFi3Xgw2Va53Lk 73282
apache_beam/runners/dataflow/dataflow_runner_test.py sha256=bLt4O9u-d-gZpAvxSoHHEkAdq0eWd_wfVOG7V5bjzZw 37267
apache_beam/runners/dataflow/ptransform_overrides.py sha256=WvJdtzzQTI1US_XdgDm_cJNcbz5E6gKBufWhpYgTSM0 14972
apache_beam/runners/dataflow/template_runner_test.py sha256=QJxW2uJwmFIKVkc-L0xCrm_0Z-4NJm4PHGx62Umnwwo 3213
apache_beam/runners/dataflow/test_dataflow_runner.py sha256=mCG5m12Xdw9KUN4ogumNEnQ0UGx80YIjh0RfKfBMscE 4214
apache_beam/runners/dataflow/internal/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/dataflow/internal/apiclient.py sha256=knqK1r30hAaPPxitNOJeZMIsMmLN4NxdXE0FBCmLmuw 58477
apache_beam/runners/dataflow/internal/apiclient_test.py sha256=ZYBFN0Gd-0kFgWNibnoDYVDFjmui4Qv9CToU2dWCUeA 71972
apache_beam/runners/dataflow/internal/names.py sha256=f_3BsjgL1pfLmx_jwjkcFh6hFuxiPOtRfKBvC0X-L3g 4580
apache_beam/runners/dataflow/internal/clients/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/dataflow/internal/clients/cloudbuild/__init__.py sha256=_GmG4HKl2j6L7iSpwe2Ct08YWf9CaaMguE1vj9qfiuE 1358
apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_client.py sha256=snUtqS3Kr8C-S0RBN4MkdOcChms9irrY7T0exYiyaUU 74956
apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_messages.py sha256=Nc6AHMvtGeDS7MzF-BK8RMuw5IzddormZaP2QEWAWSM 152512
apache_beam/runners/dataflow/internal/clients/dataflow/__init__.py sha256=_zjwqudQRemGcv9af8nN5W02CpKy2kDYJRFtXnRjFjE 1405
apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py sha256=5xTKQhLkkymMrEq_K4Ci4k6OJiyUtu8sPclrdmJDdUk 57195
apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py sha256=iYEM-rqDrG4ufo4aG7pqFmJB6sGiSr2lYqQQAnWZohg 276441
apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers.py sha256=hVfX5jnZA1-Li30nWbWO9vqR2L1JYkRwabsOrF-q0E0 4180
apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers_test.py sha256=9x-DGu3Q_O1PAlDyljoHPM5tQVOqpYNeTm9FWAJoHQk 2758
apache_beam/runners/dataflow/native_io/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/dataflow/native_io/iobase.py sha256=8lGMYLsXaxArX1DUhAS9M44gyjNNtaH6kO6M3-kiDIc 10746
apache_beam/runners/dataflow/native_io/iobase_test.py sha256=0jbtdJnl6eEuK0ZsOwfyVOdLY5IcHpIHRrKGEYG-0E8 6738
apache_beam/runners/direct/__init__.py sha256=fRghJezcQwdMwQw_HPXNLR3EihsO7JQ50y5EVqTYtlM 1049
apache_beam/runners/direct/bundle_factory.py sha256=oc7fP1zj7qZhSrNBPakKeilfVqZ3HckUhR36Qo8IW_g 7544
apache_beam/runners/direct/clock.py sha256=KHPn5OVwmMcexZjRjmPC2aKkZvG1v9mb9HrYfMQGejY 1619
apache_beam/runners/direct/consumer_tracking_pipeline_visitor.py sha256=-yy61s0AJ2b1-IAjop5U8E2AmzWc77MLLXPA1tou7SU 2709
apache_beam/runners/direct/consumer_tracking_pipeline_visitor_test.py sha256=hJl_3p28ywxSLIEQ7VxODyHqEVPnKGsDul0226xePwU 5863
apache_beam/runners/direct/direct_metrics.py sha256=kjAyBPOAyMVKPyICqTMSOCplVgZzYqipGoCOqFez598 4641
apache_beam/runners/direct/direct_metrics_test.py sha256=Ud7s4toZRK07f9lTD1246BsDgd19RWvL_3XhSAFYfJE 9444
apache_beam/runners/direct/direct_runner.py sha256=Bt9rDWRGsGnbBs1Gbm9LwcKAtGknFoqo-tJFGUlv3q0 23981
apache_beam/runners/direct/direct_runner_test.py sha256=EQZBR09rD0ZHXPDLxG_ZNw10QylGXlaS8oaUivi5CeU 8221
apache_beam/runners/direct/direct_userstate.py sha256=9GfVoI2bk-fis7NLymDf0G3SRMzZTlhLMRPLpFesNCw 11290
apache_beam/runners/direct/evaluation_context.py sha256=Xzdi0NUgfsBYvBLTK9WD3GCdVT2mxNXjkMCc7rItVNU 18031
apache_beam/runners/direct/executor.py sha256=voWfDihMFOaOTN9S6iXQ3FdUEyHuqr9dJhBF6VvKKS8 26472
apache_beam/runners/direct/helper_transforms.py sha256=PthQbCJEgp446VQr3RRmgEvaV-i92EtiFdxw7XnJS8o 4107
apache_beam/runners/direct/sdf_direct_runner.py sha256=XBVbOqC0rjWXJjKkn7U-z_x5ZMGVw4PxhKJwJMPpy-c 21173
apache_beam/runners/direct/sdf_direct_runner_test.py sha256=yJ8mVmSICzI_x7BbRy-BtyAAIJbNR5dvCYzqfhtD_hs 8833
apache_beam/runners/direct/test_direct_runner.py sha256=bXD9izjy3D4-ubRuSIF4mMFL5jLTB9nH79fjTO0SmT0 2141
apache_beam/runners/direct/test_stream_impl.py sha256=mBZfbWY0OnmftFMmgzrwF-zhRFYl4vBwezkHxgArIyg 13695
apache_beam/runners/direct/transform_evaluator.py sha256=m1zUlJ627rRlRZhuWX9LqWGMCK9IxkemLJ0O12cxFhg 47276
apache_beam/runners/direct/util.py sha256=PN50TzogaKTBZSDSxrCAevvIKtLsbbtsMDVv7x6_EZI 3318
apache_beam/runners/direct/watermark_manager.py sha256=Z7SNEXlqojI30L8uXin3jMhU21if76_eO3Hta8Hdj7I 13064
apache_beam/runners/interactive/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/augmented_pipeline.py sha256=2kD_bPHh_dO5bCFWcujLeQQDLmUbxdE7UP7kRz7qNZg 5164
apache_beam/runners/interactive/augmented_pipeline_test.py sha256=OjYT2rnJ0kuITV0YTTiHpUN6a4xywEW9fHkDrWY6Fpg 2773
apache_beam/runners/interactive/background_caching_job.py sha256=Jo6KwIXlPN9lLK2djCs7ONB1tjEctTf-Gfa1OUB9eeA 14387
apache_beam/runners/interactive/background_caching_job_test.py sha256=2nv6PNnip_xSIn4HX_TwQmvia6tjiaGNKrHGC9djR68 13983
apache_beam/runners/interactive/cache_manager.py sha256=5KBDmQGPF3_S2vryGib4foRnK22EQmoyT7V3YzGTFzs 12770
apache_beam/runners/interactive/cache_manager_test.py sha256=wsueIdak8x3aMYXmBVW_XghHU-MHFhabMzGIdZF0WKU 10745
apache_beam/runners/interactive/interactive_beam.py sha256=8CUGv8vSndqcnyQj-ClCZmJE61kuDO3W9g6c4FcEzo0 38550
apache_beam/runners/interactive/interactive_beam_test.py sha256=Kt17dLRUbAEih4Gd5ea6qKB_FggjNSYvgmT7_crtFj8 21933
apache_beam/runners/interactive/interactive_environment.py sha256=GDN5IP_ZGxFYemE7dVt1wlcQf_wEisH3g-0YtJs8jcY 31250
apache_beam/runners/interactive/interactive_environment_test.py sha256=VDI2k64k6l-gpMWtkaFdUEi76sr6_zijg5TLmQsPGro 14604
apache_beam/runners/interactive/interactive_runner.py sha256=WwoBJHKXzxskb93Gr-J1SHdXBCNjYWZcuE5UoslPy8Y 13964
apache_beam/runners/interactive/interactive_runner_test.py sha256=qHi6PwXLtNUmaA5kx7chSTYS80Bs6tLz8M40HTU9Lhk 25082
apache_beam/runners/interactive/pipeline_fragment.py sha256=_PSA2QL7sOGObtcoAhkD0xJTUplljA_sawg4bqo7xF8 10300
apache_beam/runners/interactive/pipeline_fragment_test.py sha256=nE9SY3vfZDgFlcQO1Fj3EY8UXek1hcfrODhMBqzgKQk 6418
apache_beam/runners/interactive/pipeline_instrument.py sha256=vjT2pAYvW8GoSyL9YQeolc0hXo88QVsy8lcXSOyGvBo 31754
apache_beam/runners/interactive/pipeline_instrument_test.py sha256=3bKbWcZjrSpsuSp3gk5KczOxMHEBrkKUz-2nZvjTJwo 34728
apache_beam/runners/interactive/recording_manager.py sha256=1XNbQNt-eSGu4WfqopXD7e6rk5a18V01vpwXPT-_9YQ 17220
apache_beam/runners/interactive/recording_manager_test.py sha256=-OobO4UZhpG_hOFrOQ05-rcv-e3VooBRShY-4H8E5Fk 22168
apache_beam/runners/interactive/user_pipeline_tracker.py sha256=4Do-7Xt2firQSXTg1XgYHAa9cdCJruIwbC_mP1nVqT4 5735
apache_beam/runners/interactive/user_pipeline_tracker_test.py sha256=fd8Fg17dU8WXtFhzFUXdDtr-FwU3ID2_aD8alI97ZmA 6087
apache_beam/runners/interactive/utils.py sha256=GpbWEhWaoZNtj1UsV5dJ1VXoBWMl68e1EUtY-QW0_6o 17345
apache_beam/runners/interactive/utils_test.py sha256=9J98wvbE84l0RxqEHirTyVOyTQt4eZPfCP0Nukfr1QI 15443
apache_beam/runners/interactive/caching/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/caching/cacheable.py sha256=ymJfKUGZPpZw2jGmi72wTC_JRqvWj0oDrC2FCB85ANo 2946
apache_beam/runners/interactive/caching/expression_cache.py sha256=gf4GKpGs_UZoLefE2cCVqLNT8QeRMv0jR9UKtKh8m3o 4205
apache_beam/runners/interactive/caching/expression_cache_test.py sha256=lCvrTXYYQXs_A3OsE9AmuovTVOt5Tkj45TWsYp_jh0c 4577
apache_beam/runners/interactive/caching/read_cache.py sha256=r9J_WRdulz6bP1cPFLlUriWig54drFS_FTDLO_4EQ54 6326
apache_beam/runners/interactive/caching/read_cache_test.py sha256=MTi2rqI1frJJmuvjGobK3nvuiOcc-HrE_x1CR7SdQQA 3497
apache_beam/runners/interactive/caching/reify.py sha256=ehNTj30AwDu_XW95_G3UQ1WERH9tWVf5IMNtU9K-fg4 4264
apache_beam/runners/interactive/caching/streaming_cache.py sha256=oevHFrrQwVp4IO4QAj8MoKyGK9LXOYPvA5yoWxHenE4 20037
apache_beam/runners/interactive/caching/streaming_cache_test.py sha256=AGfoy5IGA6JgB0FTJgEHtDTW_oLcEGqKOmwtTTPRRgc 23221
apache_beam/runners/interactive/caching/write_cache.py sha256=FgOq5IMBuEA065RkvifxiIVCjqqASZebRVUouYfziuU 7694
apache_beam/runners/interactive/caching/write_cache_test.py sha256=SmbRQMLPVTEz2vNvNLOyILxA_6ntgY6KGrXRZP8LmcM 3036
apache_beam/runners/interactive/dataproc/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py sha256=raigjvSDIHc0WM25IhQPR5Vb5cvVrHigFu1LziELjNM 11976
apache_beam/runners/interactive/dataproc/dataproc_cluster_manager_test.py sha256=bmURr69wkvuHU1iKlmGGV4rZ2qLh3ZAV1Uk8exDzF8w 14752
apache_beam/runners/interactive/dataproc/types.py sha256=azV-B6xNoxhsq_7zrlmzKoh1dWdr3OfASG7dVbLoOIM 2879
apache_beam/runners/interactive/display/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/display/display_manager.py sha256=L0za0MvzYUy9bmh0Dvgyi3X5oGxXeao4rrARMGwHpfM 6937
apache_beam/runners/interactive/display/interactive_pipeline_graph.py sha256=G1t1oxWleHv0JAJAgPdZLEcogMu50NZ_c9lI9OjUV7Y 5474
apache_beam/runners/interactive/display/pcoll_visualization.py sha256=lSULs2mAtZaWbZpCFu0hIwnQBrlq1SAXLim0lVrrNhI 21426
apache_beam/runners/interactive/display/pcoll_visualization_test.py sha256=H0bVa79FgPgOZr-4Qa9YTaph3cWGjO_sPbYmfXRXohY 8668
apache_beam/runners/interactive/display/pipeline_graph.py sha256=z9hWTOr-ltQNr0J2uNbu15dgmgnIR26yemsVJjoMMuM 11451
apache_beam/runners/interactive/display/pipeline_graph_renderer.py sha256=EOV7fEuHAn-MGYeQkH60uByK3NCkmiT3gaTGmwMu3xA 3809
apache_beam/runners/interactive/display/pipeline_graph_test.py sha256=BOQdgUSQYQ0RmwkDnev-F2DBbkA2OrVHexjA_XiTdwA 4845
apache_beam/runners/interactive/messaging/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/messaging/interactive_environment_inspector.py sha256=9roCsFW1nhegVu2aSJ9Lu3W5XLAHP2LPwfJtDa98D1w 8306
apache_beam/runners/interactive/messaging/interactive_environment_inspector_test.py sha256=HIeLVlbrT-eucVfUulxqLoPzIdtD3vfFWqk-uVMQS6o 8431
apache_beam/runners/interactive/options/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/options/capture_control.py sha256=mduSifJiId_BEkSPEuag9g70wBKBY2EYQjBnGZG-WQA 2748
apache_beam/runners/interactive/options/capture_control_test.py sha256=xAO3dA76hNwohggZCj4-EuX4p3MocrA8TKMTwyVO4tw 7209
apache_beam/runners/interactive/options/capture_limiters.py sha256=5kJeOocnqM4cyvHIETPgorWWsWKoN2wiLhX43BvqQEs 5069
apache_beam/runners/interactive/options/capture_limiters_test.py sha256=8ItAzVvhCmfBQ38d_ZVI1Z46jIsLxADxAd8ZvHNtcSo 2299
apache_beam/runners/interactive/options/interactive_options.py sha256=IZQWpRKVZO3Szn8UBdrO4KUjIrIfTH_Pb6Gr4EgaLcw 1696
apache_beam/runners/interactive/sql/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/sql/beam_sql_magics.py sha256=0pY9uD629g7tBxJ7Wvzq0aXxCCsaGNq8xcMBLv8TicY 18014
apache_beam/runners/interactive/sql/beam_sql_magics_test.py sha256=Ed6IhgCSBLT9RdOPhfJGs6kgFsp6coH32VYw5dkibFE 6880
apache_beam/runners/interactive/sql/sql_chain.py sha256=xRMwCCy4iJ1xNuQO4CEFGKyYNHdKM08zeVzOkaVrD84 8903
apache_beam/runners/interactive/sql/sql_chain_test.py sha256=Fb0_d6Xim47fG5m7dh4rHX7RwfCldZmkSde9Y1D6vbY 4146
apache_beam/runners/interactive/sql/utils.py sha256=EEoDJRreAqmfm62yGnBvBc9faR1vno_tNaPNgUEaESU 15304
apache_beam/runners/interactive/sql/utils_test.py sha256=g768NJbUDZ5hrRC9BWbCfHXkTzvXEYnffTp7_L_vleU 4679
apache_beam/runners/interactive/testing/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/testing/mock_env.py sha256=zbecrjUvx0t6l4UACNlQQD9TatvfVQsiDzX2EzrOWWY 3645
apache_beam/runners/interactive/testing/mock_ipython.py sha256=xfTbkmiodfae5mm22PrmKqh0SlFDu6yxzFxniJZq8Ho 2254
apache_beam/runners/interactive/testing/pipeline_assertion.py sha256=6FDB1LugpTAtOMo9bdIsA21cyCkWtWZVu_ctBRirYpg 4943
apache_beam/runners/interactive/testing/test_cache_manager.py sha256=4a6ZtlT3bTTXb-v1irhc0w7w7y_nIZnDnTLCFH0v-uE 4404
apache_beam/runners/interactive/testing/integration/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/interactive/testing/integration/notebook_executor.py sha256=lqICDqBXL-rgf_ko_bZ4L0tFbmdNjCKJNdIso80Szss 5699
apache_beam/runners/interactive/testing/integration/screen_diff.py sha256=8EKQflh88d8AVUAahemyJWouPkryxmPMMS2d81k8c0s 9220
apache_beam/runners/internal/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/internal/names.py sha256=ezwlBQVsGkhRi8EyW22PPLoMCma4HHhw7uyQD0Vw_qo 1427
apache_beam/runners/job/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/runners/job/manager.py sha256=yXstrWtZmexfSTzu_wltKllsoLeU_5NogJGjtQI-emQ 1848
apache_beam/runners/job/utils.py sha256=DlHkS19ZExosT4M6N6leW3HMsVKwFW4fMBd90PBKSOo 1353
apache_beam/runners/portability/__init__.py sha256=zoim8bDimguVYyFNKbQv0eyJaPdzF9oljnZaR3hEujc 859
apache_beam/runners/portability/abstract_job_service.py sha256=H-3h4Xnrr6OvpPF-Wta8zPa73kKH4l2BJkWNxbs5LNU 13988
apache_beam/runners/portability/artifact_service.py sha256=vRqeecSA70oWjvAIiOw-snL9nkTsVKrUeUW-d5Dm-iI 12056
apache_beam/runners/portability/artifact_service_test.py sha256=09MeB_eeR7K3aybaKHqUXTCIV2_nW0Et4nUL9oeqmyw 7263
apache_beam/runners/portability/expansion_service.py sha256=dAZnY9ymcOjbLCIUy8ScCLChxJtKIMPieG2pVVZ-N-A 4648
apache_beam/runners/portability/expansion_service_main.py sha256=CPm-qlL9r_JpNvB57M5OLdg2tVxlgQsW7JTouuTduVE 2830
apache_beam/runners/portability/expansion_service_test.py sha256=VuAG-rmYvmHw_-ZDLgzwl-YVxz2U_6TLbkrZnhCgjTA 13122
apache_beam/runners/portability/flink_runner.py sha256=7qxjFN01dEn5w-9Cdc3GslGdhzV2AgqdQlugKWNmW9E 4593
apache_beam/runners/portability/flink_runner_test.py sha256=ITvkSAHG0nkKA5G9NkdgrCmDBXhDjK0Sv97omm4rlD8 17105
apache_beam/runners/portability/flink_uber_jar_job_server.py sha256=TPFhG3v3121JaoOoKtpNyYBLsHkjZgJasLg8QowY4Nc 8970
apache_beam/runners/portability/flink_uber_jar_job_server_test.py sha256=v-0hhVl0qE5CbTRgkOPeNgb4znc_jNApb0aupLqamN8 8749
apache_beam/runners/portability/job_server.py sha256=3wjBG0LXJgkTUoVlHhDgegYry0o1_Bl50liyHVDCCK4 5109
apache_beam/runners/portability/job_server_test.py sha256=SveK9iUKBjOKak_Q7xnXpitm0IhQcx3HEgsR4ykRLVw 2481
apache_beam/runners/portability/local_job_service.py sha256=WMy0v9P8IKsXhuKX2XVNVQt4ewXkcGnhbZGA64rZGXw 16324
apache_beam/runners/portability/local_job_service_main.py sha256=duWQ5z_rC8DT6_mcBZqODFPEX6d4Y0-4Cb8yJDh4qGA 5787
apache_beam/runners/portability/local_job_service_test.py sha256=0dT5EuvHgrXw8_Y00hOE8Qz1mQPizQXAr2F_lb7RWac 4609
apache_beam/runners/portability/portable_metrics.py sha256=H11S5Va9QUQvUcHJfVIrFwdctuPIdDh_boKV5K2Tags 2368
apache_beam/runners/portability/portable_runner.py sha256=lYEjBpIAbGztgJiomsxYw2qf2OdGrRQP8yBY3Vs3gr0 24614
apache_beam/runners/portability/portable_runner_test.py sha256=1oB778aOTDRgc0_TfEX2t2kQPI22pZC359kurRSe8Kk 14952
apache_beam/runners/portability/requirements_cache_it_test.py sha256=vy8hs4Ehfcs4bhOldupqxDfXRXlWC5oFWFhcTVcmniQ 2888
apache_beam/runners/portability/samza_runner_test.py sha256=jQ0MCx1rztefBGFk1Rj_-Wpk2aAcRwk3e_u85XA5Rzs 6692
apache_beam/runners/portability/sdk_container_builder.py sha256=L8LnZY44A1zAjrZZBbC65irnWkyUMJMXNSzdMnBcbQQ 14836
apache_beam/runners/portability/sdk_container_builder_test.py sha256=YhMAOHe6huWqxZ4-mbum-saCoz7LxyKmUh-XumWfaOQ 3707
apache_beam/runners/portability/spark_java_job_server_test.py sha256=g1pz51UKDmgO-H3tu-KWVfCYWXvr4g9UC83gkNakmqU 2695
apache_beam/runners/portability/spark_runner.py sha256=ydxQyfFtT780tHG152hmrrnUbL-RmXZhDJEe1xOgWE0 4578
apache_beam/runners/portability/spark_runner_test.py sha256=YqvvTSeOqG4zAOXtbkKc3DFmBduLuff7oAPKdONzbu4 6742
apache_beam/runners/portability/spark_uber_jar_job_server.py sha256=sNJ62H5CmgPyfNmU19T41zI2CEpyyypW0aI5yiSfW0o 10200
apache_beam/runners/portability/spark_uber_jar_job_server_test.py sha256=74ISVlQ5ekwQUcqYd5yydy9Bj3IoZAMcy9FNaW5mXIs 8522
apache_beam/runners/portability/stager.py sha256=CufMkXuSqcGunUQbtVyW3SOv_enTPlhjsmIjb65AWK0 39565
apache_beam/runners/portability/stager_test.py sha256=_NAm3qhWy-1-lU5p8YruHYcRB4CXt6ciR7iPpaNpNU0 34708
apache_beam/runners/portability/fn_api_runner/__init__.py sha256=6kK5HbAKJBTyEGx7LmKPSuzAV41q3FYjZbfTaPspAhA 865
apache_beam/runners/portability/fn_api_runner/execution.py sha256=Z4ybubIdF7gf_edJjhk68ceT21CRklvhm3Bjptnri-M 51673
apache_beam/runners/portability/fn_api_runner/fn_runner.py sha256=oOzV8Tt5N50XdHBsSmNomqiZlzDaqOhLEyXlZ-iWNnw 65623
apache_beam/runners/portability/fn_api_runner/fn_runner_test.py sha256=14i5kDDpr8twS603AKYgk9kMtJUQ_GGggiqVbfxFLVo 85519
apache_beam/runners/portability/fn_api_runner/translations.py sha256=eRt-sp0yJp0snGebkxT-0aB_ZK1nhdxXpi_eR8xQrww 80842
apache_beam/runners/portability/fn_api_runner/translations_test.py sha256=3DJrGinkkjvskSSYvUEOLbnbTsTEZVY8wzG_Fq7dcyc 18000
apache_beam/runners/portability/fn_api_runner/trigger_manager.py sha256=wGStd9Vn4_Cf67kkxCr6SMg0ze-89XAOxKe_V7M1w0I 19106
apache_beam/runners/portability/fn_api_runner/trigger_manager_test.py sha256=gJ3aZzXpcpm4kA-KM5_H7cKF0LMe4OyzrTrtGI9Br-M 9616
apache_beam/runners/portability/fn_api_runner/visualization_tools.py sha256=79ypoMjoN_cf3w2ZPd2O4JrPITxTWSG1jpnS0OEy5bg 4469
apache_beam/runners/portability/fn_api_runner/watermark_manager.py sha256=rdUfq8UZRSzVP937XdUxdiRvDNLcE-rXcNadHO502Kc 8390
apache_beam/runners/portability/fn_api_runner/worker_handlers.py sha256=I0QkLHzti_052C4P0AH5RicAEIKjYsCTV9mVdItrZnc 42771
apache_beam/runners/test/__init__.py sha256=oX_1HNkWyj7Xu7NmcmMHz77NsnXU4nnfaS0nmsOJMm0 1320
apache_beam/runners/worker/__init__.py sha256=OpUu8TukLPlUn5MDBWLC8zD7Ow9RI9aC4kWRNbMsAUI 853
apache_beam/runners/worker/bundle_processor.py sha256=qH-DmGMPmdnGQ7uxT4YVC5H5oXQsidyd4Tpm6P2IqXo 72150
apache_beam/runners/worker/bundle_processor_test.py sha256=Q8eB8CLpqapV-pQ5ZzxIIDD-KiMrDZYTQsmmxKbGnrw 7423
apache_beam/runners/worker/channel_factory.py sha256=Bzt7qvI3dp-z31PYh63Fwoo9Rma5Z8GFrIpxntZd7dI 1522
apache_beam/runners/worker/crossplatform_time.h sha256=R7IWXFcNGlyyAMdmMdZRiXd9mrsDq8S8saQkVqhvy1k 2429
apache_beam/runners/worker/crossplatform_unistd.h sha256=PpqGz6_qGcs-GnNaKjSNnfKRmS8CidR8dKGque2Mc7c 1440
apache_beam/runners/worker/data_plane.py sha256=OEF4yGpTfRNfDx1YjHGDHhG2TzcPRMs0lzGR6rHZgg8 27966
apache_beam/runners/worker/data_plane_test.py sha256=dttpBt-f61t6C9VwoyrB3mJ7z31znrFdw52H5OgCids 5245
apache_beam/runners/worker/log_handler.py sha256=YSj5LuHUHIvPNIjBpnnDpOU3nfAUvumkJBKWBf-pcP0 7850
apache_beam/runners/worker/log_handler_test.py sha256=GxwY3D2ax8FThib29u7ZIb1FoVkm5FnaZLRBQ4IsxFE 5415
apache_beam/runners/worker/logger.cp39-win_amd64.pyd sha256=rorPJIBXU3vxpwzPvLe6nLAgtvIa2iwoOANP2Y73JFk 90112
apache_beam/runners/worker/logger.py sha256=qhjq3WFqwlgtAsW_1e8DXnbF7n0AXmL9lKFeQqMaA4s 6869
apache_beam/runners/worker/logger_test.py sha256=waHCwzVHTxzQrfpiafR-jbV7wmkkCUEd6Voaad8ttXw 8091
apache_beam/runners/worker/opcounters.cp39-win_amd64.pyd sha256=AM8emy4-fZQPCFrZLBpoFwYq6y7xb0sJhFX75Q9yAWI 231936
apache_beam/runners/worker/opcounters.pxd sha256=Fwh3k5xpp_v-_w1qzL6mV6epSxkp_-33eArKbWNeSjE 2467
apache_beam/runners/worker/opcounters.py sha256=GOzldRb6nvZm_MztXcSbHy_rgRtUBBmisrSOtqKEoe4 13572
apache_beam/runners/worker/opcounters_test.py sha256=_JXx4JSX7NVaDlFfyI_8G9SD_jQ5gJqT0PM-0gsojdw 8164
apache_beam/runners/worker/operation_specs.py sha256=iZuuYrhGLQts6LeFD-AvGys6_xMjSYhQhRnmXTrW2Es 14908
apache_beam/runners/worker/operations.cp39-win_amd64.pyd sha256=p-3cwa-emYXYTZ8YUxX857qAbd-8JLcLvR_-UVc9EF8 697344
apache_beam/runners/worker/operations.pxd sha256=tC4uHVMXm0Lb6xB4ZMbYQoQTQ_ZrHCJzk9HOz3ftTMY 4400
apache_beam/runners/worker/operations.py sha256=tkjaeg2tayQ4w5UN7MbvuZXlKUPZm8OVSkcHH6jaVIU 54640
apache_beam/runners/worker/sdk_worker.py sha256=ODH19uES-Ib-T3rCqvowcBBBV8mTcrDi0ThHmA5FTiA 50648
apache_beam/runners/worker/sdk_worker_main.py sha256=g7s1jrwSM4W0a39BIYGQEgGSG7_xdt9Kd0u0bo87hFE 10828
apache_beam/runners/worker/sdk_worker_main_test.py sha256=lzVXd6xKdoP4wXh_fK7T_P3qYwQSkK30beUnlzpAyl0 4187
apache_beam/runners/worker/sdk_worker_test.py sha256=NbsQL34waatBgXJYsuJ8MvamS6-uS0r8EgUTwORhAKg 25593
apache_beam/runners/worker/sideinputs.py sha256=voZDFf5g4URv4PRFZvgYxuwSbCSsNWRf_fBM30KVc_s 7705
apache_beam/runners/worker/sideinputs_test.py sha256=smH9uq6alxD631IA_gG17NJterPWDKBBleztjId_URs 5762
apache_beam/runners/worker/statecache.py sha256=oCivqBmfwOHisYKHndNBRBKqS48ZIPdHrqFPxhaq-OI 8513
apache_beam/runners/worker/statecache_test.py sha256=Z80j45O1DuesF64tMW1-IXd3SqDXuialkr5d4KMrCUE 7673
apache_beam/runners/worker/statesampler.py sha256=OCNR-qmuZl2hti9wjBjy1aawfsduTIdlzC5bBPKwpbE 5599
apache_beam/runners/worker/statesampler_fast.cp39-win_amd64.pyd sha256=uIQE5X5NiRm2Z6dCX--ZovHL0PSxXX48CXdStHbGOmg 122368
apache_beam/runners/worker/statesampler_fast.pxd sha256=C2q4i8i-crWDfmk67jwdfPwrVxo5dR5DQctELxaWbwA 2263
apache_beam/runners/worker/statesampler_fast.pyx sha256=8YBNFnjoZHFjX5FNc9b6BAtpjZ08yCoERIvB9phS3lo 9769
apache_beam/runners/worker/statesampler_slow.py sha256=0HFmp2Ed6CoPv9d0ngiksGE7gq3Li8ZtgWUpcQfs7aM 3480
apache_beam/runners/worker/statesampler_test.py sha256=XUpNUuGrKpQbPASuaQEZrP_uSfXLOj2_jZJJwK-2Yic 5281
apache_beam/runners/worker/worker_id_interceptor.py sha256=h_iPmpaHHNGSSk7AcCFzSlEBecaUQ6tuPeZUix9-DOk 2841
apache_beam/runners/worker/worker_id_interceptor_test.py sha256=BRskAtCR5zg2YFJSPn65NDh53j6MhTgDvz_mVCRKHdo 2362
apache_beam/runners/worker/worker_pool_main.py sha256=FPoPxYvwXfML-BgxMxzn3Yz7zjAFzEChVmAMdkPqt18 7789
apache_beam/runners/worker/worker_status.py sha256=2LnIjYAUTPIMvb8_7bk7Xpu-17G-CS0zJBjjczGo_ww 9119
apache_beam/runners/worker/worker_status_test.py sha256=SDAoP3qGjheykl1T3oDGKjnCf1ziatP7efyTo6Gdetw 5578
apache_beam/testing/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/datatype_inference.py sha256=rNMZqQEfMHwhdYprlUyZ_PwFKVrd4pYsuVgBb_bgVzE 3702
apache_beam/testing/datatype_inference_test.py sha256=G1VvxlRmRKi7hOlzB0WGej_rqNaJqPbxC-UlkywkolQ 6166
apache_beam/testing/extra_assertions.py sha256=3DqPj7UIPDtvDOOtFLOEdOiKmNgC9GjsFFpUfmCAEdM 1865
apache_beam/testing/extra_assertions_test.py sha256=78VemEVCvNmx8QFn5_oXFw99Q9ZR09qaIcQutzg2dN0 2185
apache_beam/testing/metric_result_matchers.py sha256=XLOQCEENpzp4bm2lDj7-nU7AnqAeXenuE2uQHQ0sfVk 6940
apache_beam/testing/metric_result_matchers_test.py sha256=3UGMrGEU5FZ69AtC7GPXA86hF45DchNpplRSpmv6ewE 8712
apache_beam/testing/pipeline_verifiers.py sha256=_bOWdiYPXzy9yhIlqtIusxbxjtTrdbQVj8ghUXk1NkI 5328
apache_beam/testing/pipeline_verifiers_test.py sha256=waPVAepBS0cXbzuoayP-3G5VXjQtcP7XqmtKCV59nkI 5894
apache_beam/testing/synthetic_pipeline.py sha256=4r5hiXlEeS0Pvuv22wIBtEBZ_ugV6PNA4ZXQgCDWlY4 34026
apache_beam/testing/synthetic_pipeline_test.py sha256=DTGTvfxODfKjB-a6hKuNEdKCRG38hf3wOSN9MQ72Qns 9433
apache_beam/testing/test_pipeline.py sha256=NS5ftNX9-Xb_jRoSWteY_cGVobGv7b6U2DB6mUQ3Z5E 7706
apache_beam/testing/test_pipeline_test.py sha256=ta1L7v7n7OSZxHW0qA9sPP34EHctfiB-nxBhLkae2lo 4610
apache_beam/testing/test_stream.py sha256=2oioi2IIMOAofNrkW5HvbvmIIfxob35KnCONS-TZgPY 26826
apache_beam/testing/test_stream_it_test.py sha256=61aJnHjxaIM9xjixHH0a2M0Qqjf7HRI2ojUPOE7ePTE 9042
apache_beam/testing/test_stream_service.py sha256=1eSYSL9D0O5e8ueE0RBHKeSt892gQr0VKzPXxLfHemQ 3142
apache_beam/testing/test_stream_service_test.py sha256=S-H5JAyukYzKUWZFYyGiKq-lV92JxBgfy3EOYz0sw28 6332
apache_beam/testing/test_stream_test.py sha256=9y_SVgtRlvuYaHI-zzG6udk6YzW7z7V9E-cnsJE35Zg 41025
apache_beam/testing/test_utils.py sha256=kJl64mWCbAblGr_xg-UzyDDCsw2QQsXt9MLzRwQRSpo 6189
apache_beam/testing/test_utils_test.py sha256=Dq7ss_F7qzrQXF9THuhKc-zH8sM_cp4wbR_tjuhBJtY 3274
apache_beam/testing/util.py sha256=q7pycll62l5B4aLTbWVfa6sBEns4tmHD3xiTT0t8gsg 11879
apache_beam/testing/util_test.py sha256=7pNuTe6Hf54n8ZjHKzijgZm9N8ZFNYQrUrvrduKX0fs 9234
apache_beam/testing/benchmarks/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/benchmarks/chicago_taxi/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/benchmarks/chicago_taxi/preprocess.py sha256=CBZ59eHzKHEEovzeTyNeX8cosokKbwL3kLfAI78C5xc 8976
apache_beam/testing/benchmarks/chicago_taxi/process_tfma.py sha256=tml_acd1YNaydJUPhAPKBmtSoBzFxqwmGJ8tj8BOhno 6265
apache_beam/testing/benchmarks/chicago_taxi/setup.py sha256=Aol6xyaoQuXrSamya9zMYU9NEcFAjQ13_sbE16_FqHY 1330
apache_beam/testing/benchmarks/chicago_taxi/tfdv_analyze_and_validate.py sha256=o9qYAwlKdkFPNft-ld9QWBX7waJuDDvxOc2zz3VhMic 7164
apache_beam/testing/benchmarks/chicago_taxi/trainer/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/benchmarks/chicago_taxi/trainer/model.py sha256=jQwY-NIyrK2vUrSwLaQhnRzGJrEbATiMHemHapcivNo 6137
apache_beam/testing/benchmarks/chicago_taxi/trainer/task.py sha256=1vaZl5YvEtS-BnaxSsFZgwsw7cAlLqzU6PWAlBI92vM 5362
apache_beam/testing/benchmarks/chicago_taxi/trainer/taxi.py sha256=7sj0vEjZBScDJgWBV4ymPDrctYfwey-EIXAI_eYzdi8 5747
apache_beam/testing/benchmarks/nexmark/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/benchmarks/nexmark/monitor.py sha256=Hv1vbgYUA5C6cnj8y-4pbUZGd9Lq075SDCpgdu0Ksrk 2238
apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py sha256=8egdyqQ3Up6Puc1R-7QnK2lQlQK-eEa2ErI0biIrGAA 15462
apache_beam/testing/benchmarks/nexmark/nexmark_perf.py sha256=mhu2S8cyJjEdm1fo014_f15_1Y2OiWT_9KBh2ULvzs8 1924
apache_beam/testing/benchmarks/nexmark/nexmark_util.py sha256=trHeSYAZfUJ3DvQN83kKnTMcTG_Xo5aKFOCqRjIpZRI 9744
apache_beam/testing/benchmarks/nexmark/models/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/benchmarks/nexmark/models/auction_bid.py sha256=YO4WH3YoAk3zFU4PV9VICNZpUjaGRS_WE_Ur92tH5Q4 2026
apache_beam/testing/benchmarks/nexmark/models/field_name.py sha256=d2aSF3mWosk-dQeMMvQiryLTmP3NwUGbTxR0Ey8dcD8 1273
apache_beam/testing/benchmarks/nexmark/models/nexmark_model.py sha256=q7hg4bKl0Svwp65GhnN5xhDLwug2_tfLfqPiRgsifLU 7717
apache_beam/testing/benchmarks/nexmark/queries/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/benchmarks/nexmark/queries/nexmark_query_util.py sha256=6fDr-FZY188RoTEjlohfH3hn-0EAjdM4Wj2RqcxA6MI 2348
apache_beam/testing/benchmarks/nexmark/queries/query0.py sha256=9kV-6Vxdhm6ZlhQlkupyfh5cpaZgSEmx_d2kIdip_hY 1488
apache_beam/testing/benchmarks/nexmark/queries/query1.py sha256=EJbrgfB60ZC5VjwJlu4nYUyfXpcCcMAkRp6bTHB7YTg 1608
apache_beam/testing/benchmarks/nexmark/queries/query10.py sha256=0dPQkr7XpUfrQiqAbEY2pRa9NMzHZmg1hvlYyHgplzw 5496
apache_beam/testing/benchmarks/nexmark/queries/query11.py sha256=Zg8tlEdS5fghHL0AxQsklboUfF-iZ_qybWYUDrd3GyM 2235
apache_beam/testing/benchmarks/nexmark/queries/query12.py sha256=kSkjyP5lA3WmlNUzo-QJs1ib_6OpcZpaRD95Cvks5C8 2039
apache_beam/testing/benchmarks/nexmark/queries/query2.py sha256=lZjJHH6YUglB5RlwHD4XrRGL1zPBObH93twzj8M6i10 1593
apache_beam/testing/benchmarks/nexmark/queries/query3.py sha256=GnRnHmSvgSzGeMJFgeqlI80a-GVL1y5YFhV8RiJuwvY 6027
apache_beam/testing/benchmarks/nexmark/queries/query4.py sha256=jLJ4PhvndxehiaZdYQyGdfrKqotULinN9K_wYqvKsS8 3268
apache_beam/testing/benchmarks/nexmark/queries/query5.py sha256=8rme_Zg_PvyhNcfWakq2YmFtJAjIhZ0mHFoQDh7alA4 3473
apache_beam/testing/benchmarks/nexmark/queries/query6.py sha256=xyzSyMf1kbJG5-pWkB5qQGAl_34sg2RICpPe3_4sm_E 3391
apache_beam/testing/benchmarks/nexmark/queries/query7.py sha256=YvZznFVbbavZT9rM03PhAK2ArcLhpfwpAwd4Duz6l70 2145
apache_beam/testing/benchmarks/nexmark/queries/query8.py sha256=pay-hCpMgRNzCHfZbfG_yGL3imFofq03eBCFFpIQzsA 2834
apache_beam/testing/benchmarks/nexmark/queries/query9.py sha256=fIzJ_Yd5hnFvVKf1wWIAVYno3q6f1aeTnmuJ0jOXL_4 1258
apache_beam/testing/benchmarks/nexmark/queries/winning_bids.py sha256=0VtFDNg2NLl7znc8vw5LXk1AXblFnGHFHXPc_PPfLAc 7124
apache_beam/testing/data/trigger_transcripts.yaml sha256=K19UEkwnfgVSdNS8y6EmsRyBaNCwpdAhA-mgdUvtjeo 8692
apache_beam/testing/load_tests/__init__.py sha256=c0bKYjIaffoqkm7ZgaR53O64pH33BYzSzFxNFPweSjU 784
apache_beam/testing/load_tests/co_group_by_key_test.py sha256=IwWJZo6f8m5Os1hE4vpqV4dsggRYKfLKhQ0MtLcg6W8 4791
apache_beam/testing/load_tests/combine_test.py sha256=AhO0NjK-Eh_yqFllN2Evds0Ctv8hR37KzrrRPa-SXsg 4396
apache_beam/testing/load_tests/group_by_key_test.py sha256=BQZssXaSyOcIEbOoH2g6tea9mim8VN4vZTfA6TmZxEI 4120
apache_beam/testing/load_tests/load_test.py sha256=c_t98ZYZJIVm_s1Za5KFOwZf5KVnq1lmbHqozFT8l7c 6816
apache_beam/testing/load_tests/load_test_metrics_utils.py sha256=ypISrcnvuZjKVeq02Mze5TDkLy2tC-8fVdZ1MPxt_ao 19612
apache_beam/testing/load_tests/microbenchmarks_test.py sha256=5I1lnUyobykhJ6KnN5Kl4jDUFv7wIpQ8B_SGuNvRjvo 3365
apache_beam/testing/load_tests/pardo_test.py sha256=XY2zhtkK_6Pnw9hzxLStfgisLmHbQ_V5yDx_G94GhU4 6209
apache_beam/testing/load_tests/sideinput_test.py sha256=oZ-b9Xg-y1yaHh-6qC-_Jz-OoSB2KMVP8NeCW7mMjWY 7885
apache_beam/tools/__init__.py sha256=P07SBh7y1EvaW9Cox1tH6-nMjYn1rvjlPv5c3TGPswU 892
apache_beam/tools/coders_microbenchmark.py sha256=4EwrRs-w6ZWi1MHSsABX5M1EB4ZXaYPXYwZyoNhQLCI 8785
apache_beam/tools/distribution_counter_microbenchmark.py sha256=8ZCECDy1SFIVbflU6L7quYfPKuYiMmC8jN2DURyma9E 2394
apache_beam/tools/fn_api_runner_microbenchmark.py sha256=zU1o1mU1AMeh5TSgzfpn8yjgVrKyRgFDDwZav-3tSDI 5039
apache_beam/tools/map_fn_microbenchmark.py sha256=e9aQRkCqsQUXfsteZP489DI-qSlthhKFLaOBa6Mq2cY 2527
apache_beam/tools/microbenchmarks_test.py sha256=MkKRYWwtFwH0xlsFraCq7AiZU5lw9hlibwq8gapIoho 1997
apache_beam/tools/runtime_type_check_microbenchmark.py sha256=-D8KA_4Q_hq7qBBETU5QdqSqM05jwfe0O2cVaS3qqEQ 4547
apache_beam/tools/sideinput_microbenchmark.py sha256=LTqbAq2MarVGiIRL-L7cLVptv61aJZMOLWWDc5o64TA 2776
apache_beam/tools/teststream_microbenchmark.py sha256=uqYymN7vlSWhnAYXXwBuo8JhfkhwEGj5zcxkxstyQG4 4182
apache_beam/tools/utils.py sha256=4i_-fI0F3jK0EtBH1go0cQC4rVgjmz4_OMxJJJV64HI 6441
apache_beam/transforms/__init__.py sha256=5mPvmePiPfRoYrXiK3DT5y45dwbAvSKb40zpgOg2DiE 1439
apache_beam/transforms/batch_dofn_test.py sha256=n9UKfg1QJhqnkXwzF4VkrzjiKjRMI56pXevJaS1S1AY 7006
apache_beam/transforms/combinefn_lifecycle_pipeline.py sha256=Gg6nU7AMOIajuKrFy0Ag1aY31mMOiBTXY-Oug9z4siU 5265
apache_beam/transforms/combinefn_lifecycle_test.py sha256=7ZPtGX_F1Yrxe6o9Km3SoNohV3yB17KVqMCSaKvdRVk 3799
apache_beam/transforms/combiners.py sha256=E7BJ68-W7klwozqKcQzioNgMUMWiWP3FpEmjgQK_-q8 31117
apache_beam/transforms/combiners_test.py sha256=42B3nEv1p0pHJnfDYJi6Py8pCs7kr2Vv1qSLsjaG718 35289
apache_beam/transforms/core.py sha256=Gx8gi6aPYmNmzi6qMFJ0RJLFx9nCh6Nqr5Ml7aDFljg 128031
apache_beam/transforms/create_source.py sha256=bHo5A9STMh2IEiNbZ0fQqkCMxnU_V-9PNZBax9fPnqk 3407
apache_beam/transforms/create_test.py sha256=a3Dctww9aKhUm8e8jD9lgDebJg1aSqb28F_56GHOZ2Y 6864
apache_beam/transforms/cy_combiners.cp39-win_amd64.pyd sha256=Fvp6lGO_0Kyb1dP3NNxH0885ifi-HEaD0kVpp3MTNDE 253440
apache_beam/transforms/cy_combiners.pxd sha256=tjOvBQI_YS0yB67B_9UqNEMTF5wDJhD805JVrI7_Ip0 3579
apache_beam/transforms/cy_combiners.py sha256=0L6prTOXBtMTSHEZCZOZ3FR_rS3S-OrLXuGKNgC0GbY 11217
apache_beam/transforms/cy_dataflow_distribution_counter.cp39-win_amd64.pyd sha256=GSeXvjkDHUPLOXwt18GAVm5R85bxRMZqhoa-gUHVE5o 88064
apache_beam/transforms/cy_dataflow_distribution_counter.pxd sha256=ssd6uw1K-4iFe_7qz85iASXH7_Z8mc2mzhFcn-9esZM 1767
apache_beam/transforms/cy_dataflow_distribution_counter.pyx sha256=BNczYrFV-A3POL8bTlL-twB53oGlJBEDtQWDKMN-IEE 5474
apache_beam/transforms/dataflow_distribution_counter_test.py sha256=WlRYljYuuIsMpln_4dF_xHOawrOjPn49wjussQYPKIY 2898
apache_beam/transforms/deduplicate.py sha256=yUoMCRgnxZSioWWfZpeiLxXetgKSvPN7-_dI3pZMDY4 5142
apache_beam/transforms/deduplicate_test.py sha256=nr5RGiu1rYXw9D3RHQ53bCIo4FvHiWmGEnYY4RPQVIM 6786
apache_beam/transforms/display.py sha256=UfD9k8_3I1bsZcUWeSgZSSKG7C565_8BcVyifEzpf50 14364
apache_beam/transforms/display_test.py sha256=ECuI0vIrOZdPC6DgvnAq1Q8VOI_Pag9VHolR8TR8eR0 8914
apache_beam/transforms/dofn_lifecycle_test.py sha256=wzw3c3OVOjY_wjeuDL4qU4OAmTWngt0X_MKjGJsIDhc 4075
apache_beam/transforms/environments.py sha256=E2hovrdUfCPeMv5BZPNX-Ue6lS-pt9nEWreT7DZ3R9A 27951
apache_beam/transforms/environments_test.py sha256=OhV1wWaltTd9QRVIPJpzt_XJKT6ZvcOxOqKD9MHA0vw 5731
apache_beam/transforms/external.py sha256=JhFZXqZCXW3HlPo_-8RY6jHxszYxZluKQcNk1As8NzE 29512
apache_beam/transforms/external_it_test.py sha256=bW1GMHsSfdBL4v2ReS9eVawV5dk5Cfil6h48_28dX2I 2299
apache_beam/transforms/external_java.py sha256=shaSydDiCxIsE0Fs6J96iKXbTokZxWygiV6e-DMsehQ 6559
apache_beam/transforms/external_test.py sha256=EPb4OarfxCBWiD_smSzicU5lZ6nDulhZhCviKg9as3U 25308
apache_beam/transforms/fully_qualified_named_transform.py sha256=LWzWfxb2mTZpH7P9vj5zSetM0FjL4tQpocvigdH94Yk 4753
apache_beam/transforms/fully_qualified_named_transform_test.py sha256=AA8N8nmTHp13H0evlnXUUiuQBQKa-gBEARhVX3b0Fdk 8183
apache_beam/transforms/periodicsequence.py sha256=kLpg8JL_YiRuj1eZx8_4XXzlfGagFIV5ZwCGpw1czEI 6461
apache_beam/transforms/periodicsequence_test.py sha256=UGOKFIEBek1Inyl4eiBG00bAD2UQW2mbVoi2Yym5hjE 3960
apache_beam/transforms/ptransform.py sha256=AVBYtsCZ_K9S-aGCSEkvqOu1F1A3y6LUmPv_lfeQTfQ 40192
apache_beam/transforms/ptransform_test.py sha256=CKEFk-uVykxJxh2ovF_e6BPsjPw-wUTPJaRhDw7HNQ4 103515
apache_beam/transforms/py_dataflow_distribution_counter.py sha256=yoZxAohSu4d1ndOTdbi3NF-fhFXvShRG3ntCHIjadvc 4851
apache_beam/transforms/resources.py sha256=4-Vlm4pvfsFAKuhK_I8sZmDBq42iNSKRZQVhvpH-X2Q 6997
apache_beam/transforms/resources_test.py sha256=yOwP8T5cA7Pjr8j2qEnsme07_MQu65fRZNgTECMKWnA 2233
apache_beam/transforms/sideinputs.py sha256=zdypiNVWGv2e9K-FtSwAjjxbe5evCm1k6GxlRlckLVg 3853
apache_beam/transforms/sideinputs_test.py sha256=g7q7kXUQ661nM9yk7WFbQoChrSdVyTOR4MCgyLfeFh8 16740
apache_beam/transforms/sql.py sha256=K3CCGloEq5S-xZF7mV-tmUC5YLgDPyfKTfuw2p0zqHk 3854
apache_beam/transforms/sql_test.py sha256=WPPR1UjnXqwYoF1CsTH-GXG8HQDN3GOlYng3zyTHkw0 6956
apache_beam/transforms/stats.cp39-win_amd64.pyd sha256=tNnSXtek5rws0c2_x_vBImdimdutXJS012tKBIhze4o 276992
apache_beam/transforms/stats.pxd sha256=csXc9B1supgw_GAqvRu18Xuec-q7P0Rx7EduFTgPNow 2119
apache_beam/transforms/stats.py sha256=ns2FI1arUVoj3No3LsYSO4kD80KBQ_qUuQ0qUocCkhI 36173
apache_beam/transforms/stats_test.py sha256=PGK178ZFxmf9UQOW9QJM80AUkQDsRLAJL8t6svVxN20 25074
apache_beam/transforms/timeutil.py sha256=yr1nPiypmzN75G0R4hM7Ki5XSkAumU5jDnF5r36D9BM 4546
apache_beam/transforms/transforms_keyword_only_args_test.py sha256=hybM9ZfvGVEZlp62HQ9dSk8Se4iPe4LPzrFxoiT1Tu0 5612
apache_beam/transforms/trigger.py sha256=dq5gOHn3Bc_KYLtn6kqHK00NQhYR13Dj7J6a3IVdnHs 54613
apache_beam/transforms/trigger_test.py sha256=F3kI-1XisTu1HIQYpSAjT5B9H_N0r3AGu0QSHaCHemU 45446
apache_beam/transforms/userstate.py sha256=NNLJ-xLbkDmh-2veGxIx_HPR8U6JHB0vyMcgqco3Uus 14299
apache_beam/transforms/userstate_test.py sha256=0hEFQpf7IwY924juq5ud7ksVb23y_Ez3Arw339d84GI 43769
apache_beam/transforms/util.py sha256=DOadqn9-GwlRNK6p9gC9S7Wupx779MmBiMCg1MqdUJ8 49991
apache_beam/transforms/util_test.py sha256=nEOD6b_BKtahLh9CniKHdUGMQnWWRQdgkK6h2_xSjqU 56302
apache_beam/transforms/validate_runner_xlang_test.py sha256=5Q1H8WrOaunz3NeoZCk9o8XogNxUT7hqTRpqnKKdLek 12191
apache_beam/transforms/window.py sha256=XdaVrTSoV6yj-bpOX-xxJGZLTX8FDoMiEI_mvjm7t_I 20516
apache_beam/transforms/window_test.py sha256=M2GaJP-i0r2hxFEvhbt9sqB3pJf2_783LxjZMid6e1Y 15527
apache_beam/transforms/write_ptransform_test.py sha256=FSb5BCaYqyHyAlJcWvuZC9A-jwtOySsedx1AaxzhJy0 4233
apache_beam/typehints/__init__.py sha256=wPjHlkjXwEVxx3rRmqQfJJClopy3nOwe6yBRPMQBRNc 989
apache_beam/typehints/batch.py sha256=bCz3xWKqxCW4FrC7uAhsa8CQCFijp-z0Ih42rBqhhZ8 8647
apache_beam/typehints/batch_test.py sha256=TWTzFBGRDnxuomLegpapn4KwEQujI6_hAC9qRoi5Ym0 5494
apache_beam/typehints/decorators.py sha256=Hpgyp18NMVvi6MNbTNJ9gJ8iQrzRGD9hVjtWWi1_swo 34195
apache_beam/typehints/decorators_test.py sha256=GjKvWttTkl2Xt2RSDqLiLxeYaR4F3IXucbtuqLGF5MQ 14001
apache_beam/typehints/native_type_compatibility.py sha256=WtRmzLtHM_dlhJBRItQFipJBRaJ55foMA4eGSKNLn3s 12808
apache_beam/typehints/native_type_compatibility_test.py sha256=30mrKePEHBsP0SbK0YZ8D6t81XLo-AN3j1mdBArA2JQ 9228
apache_beam/typehints/opcodes.py sha256=YDuKDsLuHx2xxQ5P1NA6GHbTuPlijcUaDOGElrTul14 14564
apache_beam/typehints/row_type.py sha256=1YHiyPx2QXJFbjcda6dx3qrIL6CJXO0z9ByrDJ1PCA4 1642
apache_beam/typehints/schemas.py sha256=EEb7rhrVpl_ESAXlJESr3SGTGBYGmgiL0GMaD39K91k 19821
apache_beam/typehints/schemas_test.py sha256=eyeAvP5DM9QgHldWIK_3O0gDAsgvGdLPr30ZWcOuU3E 13004
apache_beam/typehints/sharded_key_type.py sha256=etfCtB8JdXucHB8qdc01CVu1nL1LVEN8a4ALvavm52Q 3226
apache_beam/typehints/sharded_key_type_test.py sha256=9B8BQvOYMBwmGDBre92FK-_8AgFGbJRkYXh9J3VJHIM 3513
apache_beam/typehints/trivial_inference.py sha256=wDFJNKw56BmKiVXah8m7jVyOW1SVKhLTSLAaZCwVye4 16348
apache_beam/typehints/trivial_inference_test.py sha256=gua2H1om4bSfZUW7UW5h9Q4o7Xm5kg45XplOE8bmWD0 14508
apache_beam/typehints/typecheck.py sha256=asxasuDVSU_xrGP6MaOM2fgL4RKQze_E5Ow_EmWBD5Y 12423
apache_beam/typehints/typecheck_test.py sha256=nWNoYLW4EN7AT0Ue24Y17QBalgRv-WNnjBAWVU0QqI0 11298
apache_beam/typehints/typed_pipeline_test.py sha256=6iWxE5iFvFFH0CEUc8pRAULfSpY8CCOz7WuWN6UCHyQ 37310
apache_beam/typehints/typehints.py sha256=DhaFJy1DpVcFAJzvkkXjHzys27cAZQEoj-QURDyb60Q 44362
apache_beam/typehints/typehints_test.py sha256=BeIdUXnAdE5Jnu42SJSpM9aDSlB-_QcCu_R-wjfc6SU 56558
apache_beam/utils/__init__.py sha256=NgPWyxWoEhc8tszKvXZcMS-nrEk3pGmIAcS2eONdZco 896
apache_beam/utils/annotations.py sha256=mPjNplJluyZXMruRMhp6djosh33ujalMqVGd8Aqt6wM 5756
apache_beam/utils/annotations_test.py sha256=TcDWLJInO-7IEA6Er6Qav_xW8c4sP5FeMgHoWyTKkYU 11245
apache_beam/utils/counters.cp39-win_amd64.pyd sha256=RWT0duVvtsi-rB5FLuUT7YaqlPEwcbVds3Pma7vAA3g 127488
apache_beam/utils/counters.pxd sha256=bk6iQpQxYAI8cxPkd_D0jDVBC4i6SPMtFMkEjA8vrRc 1171
apache_beam/utils/counters.py sha256=pFlNSIL_KoSKWw21XOvVJQfVzh5t4lSy_umkW6Zvu-I 8828
apache_beam/utils/counters_test.py sha256=45MDX9Jl1VE_yhAR-4WV7XVOWxQbtELrIbhbxHnSh1o 5202
apache_beam/utils/histogram.py sha256=m5if1mkmrfHGmkyWy2RHXgGN55XZ9ffz1RxeuXPWKmY 8379
apache_beam/utils/histogram_test.py sha256=uXMHKKZ_F58nOFMI7THyNaTHLTF6drkn_VbFp_-7u1w 6261
apache_beam/utils/interactive_utils.py sha256=SrTvKyfMjbBkgsFtWTjZvvVDvsLvOvNHRtbPyTMuxzI 3807
apache_beam/utils/interactive_utils_test.py sha256=AoNnzRnGjFfGhL3J4fPcawekt6A1cN5nqIpy86D52Ng 2287
apache_beam/utils/plugin.py sha256=eHHCGwFFdZx_VpPxE0kmDr1LMUi8OM0Vmio7A1i0j8M 1612
apache_beam/utils/processes.py sha256=UpwsviNku4VeIx9U-RYo6aV1TKcByUNo5YSn2zN-VXw 3871
apache_beam/utils/processes_test.py sha256=V4s91dqTizTfz9xQT8GddEQXS3GMPrcpJ4GixIiewHI 8149
apache_beam/utils/profiler.py sha256=INHSbTS1dKB9GrwIk2Pc_rJSR1KMQMJS-8-vG2nPD5E 5960
apache_beam/utils/profiler_test.py sha256=KmuUAjjITUvSPzPXxwjPlLf2Fe8lzEtWQfTAS-JsxBk 2089
apache_beam/utils/proto_utils.py sha256=boZPBYpdxjSRDwCkUaEDF9Uf-CPv28eU7djATKobYis 3605
apache_beam/utils/python_callable.py sha256=ebaRwyc_jlGo1XpK-jfL0fOGK_wzHC9dkKqwwvoh_AI 3874
apache_beam/utils/python_callable_test.py sha256=eJVW4ykxy3muK4-tbcf8o1eWpqZce5GmnAWk2eYGT5Q 2515
apache_beam/utils/retry.py sha256=lSc2U10UwKAQ8xaVEzYA2sRvCRN5YcJGTnVyIrLwO3Q 12102
apache_beam/utils/retry_test.py sha256=DUfjtDR-N4wVYEVz-4wKosCu8lTZ5TG_0N31D6VR04Q 8147
apache_beam/utils/sentinel.py sha256=3mU817FrF4XThSvNkAur9A_ZiZV8wcwUZT3on6D_etE 911
apache_beam/utils/sharded_key.py sha256=52PC9DvPPBdUnt0y29475t5Q33u5wUk__ZezQxlYK80 1656
apache_beam/utils/shared.py sha256=BSwPfJzdv8sGEGdkG5o2FNsY0OfuUuyuPcCrxG5_oXg 11683
apache_beam/utils/shared_test.py sha256=uKEhg_7fN3Qwd6Tuxfurary9XXEyUmy8pwRC-Abyf7w 7278
apache_beam/utils/subprocess_server.py sha256=IbmN58TKEz0TfZYypr8hp0G3PE6J5kMhD8UFawKzDmk 12287
apache_beam/utils/subprocess_server_test.py sha256=hPJP4lrQptCy05RZ4mI3S4ixXpcr-UF_YvRNymVZxic 6170
apache_beam/utils/thread_pool_executor.py sha256=8l9KIiT5OjQCNZgn7wBeQu-phXWFk2gkr5gEnAkLPp8 4067
apache_beam/utils/thread_pool_executor_test.py sha256=ENBZXR_DMmHX_8Nw14kD1yKxS7lAG3YSVdZS5IPJM4M 3818
apache_beam/utils/timestamp.py sha256=YnQlncBP0SHCO5sKYgs9vCq5dfmVPIFHXUJ9-JB7qAE 14078
apache_beam/utils/timestamp_test.py sha256=mENh3Pkrjc-Ow42KwAFKLiiZ_L-TGjfPsawNLm6b37U 10327
apache_beam/utils/urns.py sha256=WHBGbjW6qVq7suZuH7jH7chEGgjbnDbEJfUkJXBEuBg 6325
apache_beam/utils/windowed_value.cp39-win_amd64.pyd sha256=MNdFGBFlqKhIjYIctoTNhx1gn5BDvd6pM8GklbTNfhk 189952
apache_beam/utils/windowed_value.pxd sha256=pbualj5JhsmUrdL87zMyMRbDP_YY-wYKKloRPYvF-PY 1938
apache_beam/utils/windowed_value.py sha256=-w_LPkGOIskp-L6_qiwnt8e_iWc6w2urVqJjeOaDlrI 13901
apache_beam/utils/windowed_value_test.py sha256=HxwGSowHWC5WSxshnlz_cSxLXHZlJ4gU4zs_D2C_wEg 6410
apache_beam-2.40.0.dist-info/METADATA sha256=CZ0zLW6z_x3bgT8l1PrN392R5Z4th94mBqoktVBRZVE 5384
apache_beam-2.40.0.dist-info/WHEEL sha256=jr7ubY0Lkz_yXH9FfFe9PTtLhGOsf62dZkNvTYrJINE 100
apache_beam-2.40.0.dist-info/top_level.txt sha256=2l9i5YxBH6F1hAR5jRU0p-gPlkbVbQUYliY0xqf8qwo 12
apache_beam-2.40.0.dist-info/RECORD

top_level.txt

apache_beam