Wheelodex » Projects » quixstreams

quixstreams

View on PyPI — Reverse Dependencies (4)

3.5.0 quixstreams-3.5.0-py3-none-any.whl

Wheel Details

Project: quixstreams
Version: 3.5.0
Filename: quixstreams-3.5.0-py3-none-any.whl
Download: [link]
Size: 238464
MD5: f6af7ec9f7d92a37d493ba6ac85f7714
SHA256: b942fe0564a59fde03231f6ddee0c9dbedcc5f185dcb6925d83eabdd13858dc6
Uploaded: 2024-12-19 14:06:59 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt

METADATA

Metadata-Version: 2.1
Name: quixstreams
Version: 3.5.0
Summary: Python library for building stream processing applications with Apache Kafka
Author-Email: Quix Analytics Ltd <devs[at]quix.io>
Project-Url: Homepage, https://github.com/quixio/quix-streams
License: Apache License Version 2.0, January 2004 http://www.apache.org/licenses/ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION 1. Definitions. "License" shall mean the terms and conditions for use, reproduction, and distribution as defined by Sections 1 through 9 of this document. "Licensor" shall mean the copyright owner or entity authorized by the copyright owner that is granting the License. "Legal Entity" shall mean the union of the acting entity and all other entities that control, are controlled by, or are under common control with that entity. For the purposes of this definition, "control" means (i) the power, direct or indirect, to cause the direction or management of such entity, whether by contract or otherwise, or (ii) ownership of fifty percent (50%) or more of the outstanding shares, or (iii) beneficial ownership of such entity. "You" (or "Your") shall mean an individual or Legal Entity exercising permissions granted by this License. "Source" form shall mean the preferred form for making modifications, including but not limited to software source code, documentation source, and configuration files. "Object" form shall mean any form resulting from mechanical transformation or translation of a Source form, including but not limited to compiled object code, generated documentation, and conversions to other media types. "Work" shall mean the work of authorship, whether in Source or Object form, made available under the License, as indicated by a copyright notice that is included in or attached to the work (an example is provided in the Appendix below). "Derivative Works" shall mean any work, whether in Source or Object form, that is based on (or derived from) the Work and for which the editorial revisions, annotations, elaborations, or other modifications represent, as a whole, an original work of authorship. For the purposes of this License, Derivative Works shall not include works that remain separable from, or merely link (or bind by name) to the interfaces of, the Work and Derivative Works thereof. "Contribution" shall mean any work of authorship, including the original version of the Work and any modifications or additions to that Work or Derivative Works thereof, that is intentionally submitted to Licensor for inclusion in the Work by the copyright owner or by an individual or Legal Entity authorized to submit on behalf of the copyright owner. For the purposes of this definition, "submitted" means any form of electronic, verbal, or written communication sent to the Licensor or its representatives, including but not limited to communication on electronic mailing lists, source code control systems, and issue tracking systems that are managed by, or on behalf of, the Licensor for the purpose of discussing and improving the Work, but excluding communication that is conspicuously marked or otherwise designated in writing by the copyright owner as "Not a Contribution." "Contributor" shall mean Licensor and any individual or Legal Entity on behalf of whom a Contribution has been received by Licensor and subsequently incorporated within the Work. 2. Grant of Copyright License. Subject to the terms and conditions of this License, each Contributor hereby grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free, irrevocable copyright license to reproduce, prepare Derivative Works of, publicly display, publicly perform, sublicense, and distribute the Work and such Derivative Works in Source or Object form. 3. Grant of Patent License. Subject to the terms and conditions of this License, each Contributor hereby grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free, irrevocable (except as stated in this section) patent license to make, have made, use, offer to sell, sell, import, and otherwise transfer the Work, where such license applies only to those patent claims licensable by such Contributor that are necessarily infringed by their Contribution(s) alone or by combination of their Contribution(s) with the Work to which such Contribution(s) was submitted. If You institute patent litigation against any entity (including a cross-claim or counterclaim in a lawsuit) alleging that the Work or a Contribution incorporated within the Work constitutes direct or contributory patent infringement, then any patent licenses granted to You under this License for that Work shall terminate as of the date such litigation is filed. 4. Redistribution. You may reproduce and distribute copies of the Work or Derivative Works thereof in any medium, with or without modifications, and in Source or Object form, provided that You meet the following conditions: (a) You must give any other recipients of the Work or Derivative Works a copy of this License; and (b) You must cause any modified files to carry prominent notices stating that You changed the files; and (c) You must retain, in the Source form of any Derivative Works that You distribute, all copyright, patent, trademark, and attribution notices from the Source form of the Work, excluding those notices that do not pertain to any part of the Derivative Works; and (d) If the Work includes a "NOTICE" text file as part of its distribution, then any Derivative Works that You distribute must include a readable copy of the attribution notices contained within such NOTICE file, excluding those notices that do not pertain to any part of the Derivative Works, in at least one of the following places: within a NOTICE text file distributed as part of the Derivative Works; within the Source form or documentation, if provided along with the Derivative Works; or, within a display generated by the Derivative Works, if and wherever such third-party notices normally appear. The contents of the NOTICE file are for informational purposes only and do not modify the License. You may add Your own attribution notices within Derivative Works that You distribute, alongside or as an addendum to the NOTICE text from the Work, provided that such additional attribution notices cannot be construed as modifying the License. You may add Your own copyright statement to Your modifications and may provide additional or different license terms and conditions for use, reproduction, or distribution of Your modifications, or for any such Derivative Works as a whole, provided Your use, reproduction, and distribution of the Work otherwise complies with the conditions stated in this License. 5. Submission of Contributions. Unless You explicitly state otherwise, any Contribution intentionally submitted for inclusion in the Work by You to the Licensor shall be under the terms and conditions of this License, without any additional terms or conditions. Notwithstanding the above, nothing herein shall supersede or modify the terms of any separate license agreement you may have executed with Licensor regarding such Contributions. 6. Trademarks. This License does not grant permission to use the trade names, trademarks, service marks, or product names of the Licensor, except as required for reasonable and customary use in describing the origin of the Work and reproducing the content of the NOTICE file. 7. Disclaimer of Warranty. Unless required by applicable law or agreed to in writing, Licensor provides the Work (and each Contributor provides its Contributions) on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied, including, without limitation, any warranties or conditions of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A PARTICULAR PURPOSE. You are solely responsible for determining the appropriateness of using or redistributing the Work and assume any risks associated with Your exercise of permissions under this License. 8. Limitation of Liability. In no event and under no legal theory, whether in tort (including negligence), contract, or otherwise, unless required by applicable law (such as deliberate and grossly negligent acts) or agreed to in writing, shall any Contributor be liable to You for damages, including any direct, indirect, special, incidental, or consequential damages of any character arising as a result of this License or out of the use or inability to use the Work (including but not limited to damages for loss of goodwill, work stoppage, computer failure or malfunction, or any and all other commercial damages or losses), even if such Contributor has been advised of the possibility of such damages. 9. Accepting Warranty or Additional Liability. While redistributing the Work or Derivative Works thereof, You may choose to offer, and charge a fee for, acceptance of support, warranty, indemnity, or other liability obligations and/or rights consistent with this License. However, in accepting such obligations, You may act only on Your own behalf and on Your sole responsibility, not on behalf of any other Contributor, and only if You agree to indemnify, defend, and hold each Contributor harmless for any liability incurred by, or claims asserted against, such Contributor by reason of your accepting any such warranty or additional liability. END OF TERMS AND CONDITIONS APPENDIX: How to apply the Apache License to your work. To apply the Apache License to your work, attach the following boilerplate notice, with the fields enclosed by brackets "[]" replaced with your own identifying information. (Don't include the brackets!) The text should be enclosed in the appropriate comment syntax for the file format. We also recommend that a file or class name and description of purpose be included on the same "printed page" as the copyright notice for easier identification within third-party archives. Copyright [2022] [Quix Analytics Ltd.] Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Keywords: streaming,processing,pipeline,event,real-time,time series,DataFrame,Kafka,Quix
Classifier: Development Status :: 5 - Production/Stable
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Operating System :: Microsoft :: Windows
Classifier: Operating System :: POSIX :: Linux
Classifier: Operating System :: MacOS :: MacOS X
Classifier: Programming Language :: Python :: 3
Requires-Python: <4,>=3.9
Requires-Dist: confluent-kafka (<2.5,>=2.4)
Requires-Dist: requests (>=2.32)
Requires-Dist: rocksdict (<0.4,>=0.3)
Requires-Dist: typing-extensions (>=4.8)
Requires-Dist: orjson (<4,>=3.9)
Requires-Dist: pydantic (<2.11,>=2.7)
Requires-Dist: pydantic-settings (<2.7,>=2.3)
Requires-Dist: jsonschema (>=4.3.0)
Requires-Dist: jsonlines (<5,>=4)
Requires-Dist: fastavro (<2.0,>=1.8); extra == "all"
Requires-Dist: protobuf (<6.0,>=5.27.2); extra == "all"
Requires-Dist: influxdb3-python (<1.0,>=0.7); extra == "all"
Requires-Dist: pyiceberg[glue,pyarrow] (<0.8,>=0.7); extra == "all"
Requires-Dist: google-cloud-bigquery (<3.27,>=3.26.0); extra == "all"
Requires-Dist: google-cloud-pubsub (<3,>=2.23.1); extra == "all"
Requires-Dist: psycopg2-binary (<3,>=2.9.9); extra == "all"
Requires-Dist: boto3 (<2.0,>=1.35.65); extra == "all"
Requires-Dist: boto3-stubs (<2.0,>=1.35.65); extra == "all"
Requires-Dist: redis[hiredis] (<6,>=5.2.0); extra == "all"
Requires-Dist: azure-storage-blob (<12.25,>=12.24.0); extra == "all"
Requires-Dist: fastavro (<2.0,>=1.8); extra == "avro"
Requires-Dist: boto3 (<2.0,>=1.35.65); extra == "aws"
Requires-Dist: boto3-stubs (<2.0,>=1.35.65); extra == "aws"
Requires-Dist: azure-storage-blob (<12.25,>=12.24.0); extra == "azure"
Requires-Dist: quixstreams[azure]; extra == "azure-file"
Requires-Dist: google-cloud-bigquery (<3.27,>=3.26.0); extra == "bigquery"
Requires-Dist: pyiceberg[pyarrow] (<0.8,>=0.7); extra == "iceberg"
Requires-Dist: pyiceberg[glue,pyarrow] (<0.8,>=0.7); extra == "iceberg-aws"
Requires-Dist: influxdb3-python (<1.0,>=0.7); extra == "influxdb3"
Requires-Dist: quixstreams[aws]; extra == "kinesis"
Requires-Dist: psycopg2-binary (<3,>=2.9.9); extra == "postgresql"
Requires-Dist: protobuf (<6.0,>=5.27.2); extra == "protobuf"
Requires-Dist: google-cloud-pubsub (<3,>=2.23.1); extra == "pubsub"
Requires-Dist: redis[hiredis] (<6,>=5.2.0); extra == "redis"
Requires-Dist: quixstreams[aws]; extra == "s3"
Provides-Extra: all
Provides-Extra: avro
Provides-Extra: aws
Provides-Extra: azure
Provides-Extra: azure-file
Provides-Extra: bigquery
Provides-Extra: iceberg
Provides-Extra: iceberg_aws
Provides-Extra: influxdb3
Provides-Extra: kinesis
Provides-Extra: postgresql
Provides-Extra: protobuf
Provides-Extra: pubsub
Provides-Extra: redis
Provides-Extra: s3
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 7693 characters]

WHEEL

Wheel-Version: 1.0
Generator: setuptools (75.3.0)
Root-Is-Purelib: true
Tag: py3-none-any

RECORD

Path Digest Size
quixstreams/__init__.py sha256=Q74_IHVCWDbmlECA8RuqRW40nKP93_bhTIcxhr13d1g 222
quixstreams/app.py sha256=g6Ym7W8_bIXh-R3LdBAm-GLga5oJjWX-GJyWxEdK4uY 41481
quixstreams/context.py sha256=-lSrtvhgKv67g-5fKjv5M5-EFXCULu0NC-WywoHap2o 2144
quixstreams/error_callbacks.py sha256=fKwc2iKCMX8pbxsMsuhKpGfyCxIUmQLt27Jbm8NJvDI 1571
quixstreams/logging.py sha256=GQzq1m42w5chRzQ7gd693CzacYK_KVScKAFFeTfQceU 2215
quixstreams/rowconsumer.py sha256=raUekT3h-tkd4u9DyCJr347p1gVCm_6riPDUhY69388 5970
quixstreams/rowproducer.py sha256=vO937mKf944KZogfvZfaDMZ4uFmxIbibCBG1FcRc6Zs 12248
quixstreams/types.py sha256=xX1rTm6VaaPABGo1KkDlaaw-t45ssEHX3oGkW9X8Tp4 112
quixstreams/checkpointing/__init__.py sha256=2bLcGRFRx_ePSPH9BKcZscPZh0uH5rbMbgPQ_piY57w 162
quixstreams/checkpointing/checkpoint.py sha256=0bL5VSpS2I5EYC-v1hnTYnGO_YHhDsE6awnwcWOWauA 11489
quixstreams/checkpointing/exceptions.py sha256=noDPmQ1ycCg8iAjyn2XJR85E_waGD7EgrPN_tQxo7rw 282
quixstreams/core/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
quixstreams/core/stream/__init__.py sha256=OqWrOwbP7sHzhA282Kpe22bFhPM0qbb6RAISwy4sYZ0 66
quixstreams/core/stream/stream.py sha256=JuDK0WaXS6Xrh9p98WaCMmhx4mUjdjepPfJOxg9FYFk 18606
quixstreams/core/stream/functions/__init__.py sha256=enivaV7D2-WNvrRDOCOFWV6FD_qhcgP2f2MeU31KNbs 150
quixstreams/core/stream/functions/apply.py sha256=oG21-xgudc4O70Lhi0vvgkWx6t4Fj6n5zaVLb9S_VM8 2874
quixstreams/core/stream/functions/base.py sha256=p1eMn-ai5rZXnJhsJ9vewOgyvlSz3SHuStKoliGREFA 1971
quixstreams/core/stream/functions/filter.py sha256=EnWmU56-5kBOYR5P53tdIUM-pdaK4A3UpjRtNlnfJ9g 1834
quixstreams/core/stream/functions/transform.py sha256=k_hMxF6LXebZyPYnDRkD9_3puMysqDL30wf3d5gMq-Q 2029
quixstreams/core/stream/functions/types.py sha256=0QYT2Ch5sCNkPMQKoB7lh80iwYVgOiD1QdtOvdMLcj0 1812
quixstreams/core/stream/functions/update.py sha256=qsUUyFtWyLbCWQPXcnOqYzjbIjvJtWsB_xs6T8Wyru8 1864
quixstreams/core/stream/functions/utils.py sha256=Z7SW--0aCUZ70zPROsU_vlzzxIG_SjJxRzTXkaJ1c3Q 653
quixstreams/dataframe/__init__.py sha256=75Z9a5Z4UA_6xMp5tbLvPiXMejHrLgu3XoEMVEJYzQ8 555
quixstreams/dataframe/base.py sha256=Jo2OpGXNw7gr99fpIYZLC-SY3ehAgQYBHl9kxaxYxrE 491
quixstreams/dataframe/dataframe.py sha256=GizLq9LtnJ5b5PJt-iXfLOV417TtkjM1VnsnS6xSmiY 46061
quixstreams/dataframe/exceptions.py sha256=47Ztj2mf9r4VkE6U9SMYnC_Rqr8wW_D76qC_J4wFvoQ 527
quixstreams/dataframe/registry.py sha256=OozFnCmrCwSwLvANkVBS3Yd5CQF_-RDulysA3jN7Qqc 3018
quixstreams/dataframe/series.py sha256=OPQe1ofyJNbbb-mbNzS0_dK2M9pmWhH_B_1VUC3EUW0 19431
quixstreams/dataframe/utils.py sha256=6clRYg-QJ6N1R2IDN1TB03ktZbIi6M7cOG38rxMfSCk 754
quixstreams/dataframe/windows/__init__.py sha256=Q42uXGwqpbWMkebK3qJh3LLrnWTk6zRo5YB_QZA7mfA 277
quixstreams/dataframe/windows/base.py sha256=-D9h1GxtgtJ-0Aj-5uF6Cckmz2lo80YhDXHH2cxtvBU 1169
quixstreams/dataframe/windows/definitions.py sha256=UvZsEN-0rqO8B1WjRb8ZCxXvJ-lsfTu5CA5UIEv8pzY 9547
quixstreams/dataframe/windows/sliding.py sha256=sGr7APoXfJO-pAeyQRS6oLu4RSJxt6QAf_l6wWlX5hA 9787
quixstreams/dataframe/windows/time_based.py sha256=IAtK3lWLD6DLzJVXSw-zu4y_o9PPqyUB49cNGRICeLU 8519
quixstreams/exceptions/__init__.py sha256=dJH6bDyVfDKRGXRPTk2-gtKAvYEl0Nyx1ci6O_59V9k 65
quixstreams/exceptions/assignment.py sha256=35VZbpdAZiaKGBgRS9PYMCqdEbEI0B7MhO5xHJJ54LU 322
quixstreams/exceptions/base.py sha256=2sxMDcShtqCaehXyw6Hq7KqyTzBnCu_iiezfNpjJ77Y 41
quixstreams/kafka/__init__.py sha256=DfzSNKVkZ1Mj-0BmOMBXV8Xz437hXULmsOZ0_j30wkY 96
quixstreams/kafka/configuration.py sha256=ZAmylWaRUNtGFeW9vDTSIuJVJjVJYI2fqOGJF84yfQc 5544
quixstreams/kafka/consumer.py sha256=_IPvsK4IaDQOwV2SXyDGhgTiM3tHznv0xtYqnSVOQMw 23266
quixstreams/kafka/exceptions.py sha256=QI9jwdCEs_b83L8BmYAPhj8oo2N9ToInjFAPB9TaFYI 695
quixstreams/kafka/producer.py sha256=yEleTPWXymy0M8yWazTJ1E5lfhzG7bmsZYSQrnpUa9U 8376
quixstreams/models/__init__.py sha256=GbD8Pg_K6vCit4431OzFbheFbFexVExEQAifff07vOI 165
quixstreams/models/messagecontext.py sha256=r8G414XXGWG6YtQDV-SEY-Z2zZeug3qmQkpnqiiSqns 1109
quixstreams/models/messages.py sha256=e0x1zxfppvM9I9qXYF3lGJP_ikpjbR_6Vb7ZORjsu-0 475
quixstreams/models/rows.py sha256=IwdzKxdR9bjBQ6qBj7hmSytA2giT4LHVxULTWcb-Pjc 987
quixstreams/models/timestamps.py sha256=HLpLWOlzp23pEeEBOLO4HXI19_qJ9H2e8ddb0Fki_TM 1813
quixstreams/models/types.py sha256=cbiebzA9pCIVTyXo7dSeWQr8VyFn4nLkZEstSJQ05UQ 2488
quixstreams/models/serializers/__init__.py sha256=5oHLgBBQI4MyPL2H8xm9S_lqNvq-np5etDy1xJgg57Y 1065
quixstreams/models/serializers/avro.py sha256=ZqIj80vIcjjL6Uf_-GcJdAv5EKDxu0hVKMl0JgTJlKE 9793
quixstreams/models/serializers/base.py sha256=Nt_3mipQlhrMtvGHUQB-yDxaykow960dC4fe75ATFjE 2406
quixstreams/models/serializers/exceptions.py sha256=dR87OriHCBZcs-UcG-a24QWGJRvDVtkfpKiHdp9lWnc 1522
quixstreams/models/serializers/json.py sha256=J3F5D1K6UrSHZBDVEkkVfm8wwNjLTI65dz3id7V46V0 7279
quixstreams/models/serializers/protobuf.py sha256=tPGzoH2j4r8BJzsViYTU9E3oRqbLaFpo_y6IbHVwR38 8432
quixstreams/models/serializers/quix.py sha256=dvtNtXb1NU_0j73eiWEJCYl7WZ6nusPtUIl8AGHX5cU 16654
quixstreams/models/serializers/schema_registry.py sha256=YexjW51_CylfUa-IVWCp8Cxq1KI-d5dR49VCnMadLO8 3932
quixstreams/models/serializers/simple_types.py sha256=k5bW7mk-BpR5Kx1Dv-zD6MDdycX2uvH225D22XCQFm0 4398
quixstreams/models/topics/__init__.py sha256=LWokuDe5pa064pbv0CtPWXAHgBYuLNUOTHkuSJeQM6M 84
quixstreams/models/topics/admin.py sha256=oS3frESPT7Ov0APt8XSRWiY-hE-BOP6ToGlgWQbd1pY 7429
quixstreams/models/topics/exceptions.py sha256=BmJQiWvxIdhr15IKov_oDB1uKtxGP3Rarrqc2Lgnjwk 297
quixstreams/models/topics/manager.py sha256=nEX84528xiA4stBohJrWu7NKE93_mCB4QjCGwepPtug 19707
quixstreams/models/topics/topic.py sha256=6w6LptL2B9ULn40pXsFbpi9H4IWN1nT4gGN_H48h8rA 12810
quixstreams/models/topics/utils.py sha256=7FKrKhPK_g5o6UdQNPzyz5MQY99zdLsGsZoTId8UZJM 1250
quixstreams/platforms/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
quixstreams/platforms/quix/__init__.py sha256=w5DeTyl6N7k8m5C5kajsjUydJitJ7JI5ghYPUL4FeYc 137
quixstreams/platforms/quix/api.py sha256=thcOJgFTvCV3m3goNL_Bs4s902kr_XoV0VE-ImsYwA0 7057
quixstreams/platforms/quix/checks.py sha256=EwYSHLq3Y5b0o_LNmqWMqlQ63vEwSdXQNF0ikAEref8 1526
quixstreams/platforms/quix/config.py sha256=F34hOVAkE_tJ7FyKZ4ugpEheNGAQR7bqQLgmiIeLNGA 19211
quixstreams/platforms/quix/env.py sha256=1P5A9xsr9qZQxOCkYolSNKP_2flqQVSDAtWqnBB8YcU 1787
quixstreams/platforms/quix/exceptions.py sha256=Modb_xU2PegEYpmxz47gRxqqfJ38H3oUFHzhOyEE9XU 1035
quixstreams/platforms/quix/topic_manager.py sha256=CO1xq7KFtcwoOEKPKZ31B0WbTBvcLD58RsIfrRywGcc 3967
quixstreams/processing/__init__.py sha256=zWq0WyJFsmfhFrTnqf7v0jMsHOdwV6B60PFp3i5TKOM 114
quixstreams/processing/context.py sha256=VT2LvjgatdWUzAq1wFAGjzSbEPgp8prUkR7CXO5BOLA 3519
quixstreams/processing/pausing.py sha256=QRcJ08Qv7uHI_lRzrgGizkEjKWAoqdNxvognI_JawKI 3639
quixstreams/sinks/__init__.py sha256=PbGxOXVP983Qi4gjmAlrf9_ltMGU0ETFbMETmYsGv80 204
quixstreams/sinks/base/__init__.py sha256=1MyzeUaxEOkF21g04aFMtLU_6cogj9tye_SU9wkp2Uw 265
quixstreams/sinks/base/batch.py sha256=vb-Ratlj7U-wfwWal7Zwu4wBRnIY5y6R7vPBiC3VWSM 1908
quixstreams/sinks/base/exceptions.py sha256=QQ-6gCwfxLMbgx6x68Q0NAIc8t3YlgipmD6vYlOGZUU 773
quixstreams/sinks/base/item.py sha256=QCxx51KGzq4o803oqq_Hw67XpHoWsjk2JCMRJcmA_eQ 567
quixstreams/sinks/base/manager.py sha256=G8Q0MuYbDBMyeXVUSXW9F5HxLFdnT956TQbs4z2bC0Y 394
quixstreams/sinks/base/sink.py sha256=N1nDH1MO0jnlhd1rg6mfwRUMqU5B_yQGdqQuuv8cZwU 4177
quixstreams/sinks/community/__init__.py sha256=oSAGlRjrNcqIkiZwEf3b0lfuJt05YX5n1M9bC_D59Kg 102
quixstreams/sinks/community/bigquery.py sha256=C6QpTGWSTRO-uWlPSSXaS1hkAb21yOqjQSzrmcC5I_o 11082
quixstreams/sinks/community/iceberg.py sha256=QtOEPBysapWSKahw8jMzyBXmnPWBoGFQGEq8zW3Abjc 11026
quixstreams/sinks/community/kinesis.py sha256=yaeDRAUYyDlp_q1MYMI_KphdoaBkBlCwEf6scjDlfIs 5329
quixstreams/sinks/community/postgresql.py sha256=j4k0KExXpLQ-I7iLrlxWM4CTxMUakLq6wWwGPs5LOy8 6052
quixstreams/sinks/community/pubsub.py sha256=fp65EwRvy4jsGb7Uzrvd9uF-9M5OiRcqgp8w84lvXzY 4569
quixstreams/sinks/community/redis.py sha256=rHwYYH3eX_IA_UXWFar5ilgkb9u4ZB_OZ-HE_Gm6Bl4 2767
quixstreams/sinks/community/file/__init__.py sha256=cwzk_WT9gkAHkwkhwQuUF91aAGRm7L6BiOVSVOEW40c 90
quixstreams/sinks/community/file/sink.py sha256=rZcXf8GbBfypatRVvAOlmjmft1vYib8C30oxWmASMiw 2617
quixstreams/sinks/community/file/destinations/__init__.py sha256=G1olpwVBmR8uCtCwMP0zEcI5WiqaPGKJs4SYVeUH528 99
quixstreams/sinks/community/file/destinations/azure.py sha256=6mNA2yJtGihweCaDgAe0EMN11COO6M25cSEhPSq0vts 3482
quixstreams/sinks/community/file/destinations/base.py sha256=IIA2phVFEvaKcBpNbv8_WM_rTC23oxH-VRml16fnT_c 3683
quixstreams/sinks/community/file/destinations/local.py sha256=nuFw0HzQ9p843OGfmMHayWQ_9qnmgaZnWxV6BVC5sv4 2788
quixstreams/sinks/community/file/destinations/s3.py sha256=7chXzBWNx09OMWEDsFT2qqUicQUhAtPg5KT28b3SZ-E 3328
quixstreams/sinks/community/file/formats/__init__.py sha256=otiiRpDJNn5qxCbZOyKI9ME8cD-WQLm9V2iRrssz9V4 1238
quixstreams/sinks/community/file/formats/base.py sha256=oCGfp1irQsYw-JRmE3YGGFOQx2RDGcTeTfpx981Ykoc 1163
quixstreams/sinks/community/file/formats/json.py sha256=0necOYTpabdxjl1xpiGrL8SL-uOaBEfzx5Yjen34ghY 2953
quixstreams/sinks/community/file/formats/parquet.py sha256=j54xGpL3UE8RVNAGUpnrZIi7ZQl4oo263dawEoWiae8 2900
quixstreams/sinks/core/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
quixstreams/sinks/core/csv.py sha256=tMPaBHk5vVJCuSOZJ1jIxWd0r79Z6rzNAxou1v6A9AQ 2242
quixstreams/sinks/core/influxdb3.py sha256=f6fRCRyn3ehw78lhfjo61ViLY9l0pvHWkMBH0bX0wh0 8751
quixstreams/sources/__init__.py sha256=c06B9UJ3OCIe6CVzEn-Q9yEivo0l5P911t5JQDiT_bA 443
quixstreams/sources/base/__init__.py sha256=qdTWen6ijiJDEY1OY68WZvtqm0dc7g6nI1DhAyFethE 311
quixstreams/sources/base/exceptions.py sha256=fyNUAP7GokbobhMTC6ouxfI8-4zTF849916AvLqxtbM 659
quixstreams/sources/base/manager.py sha256=uiAvi6qIS7O_CxVwVCjc8V0A0qTr2SBkQ6X3eTjm8oI 9938
quixstreams/sources/base/multiprocessing.py sha256=HS8e4nHG_zbsPh4xX7SVkeOc3tqmI9G01A9Y9OdRV4k 221
quixstreams/sources/base/source.py sha256=23N1I9t9I-G5bqnm_sGFVYKzYXo3GzJgY2HCjrRk7Nw 13980
quixstreams/sources/community/__init__.py sha256=sgDdEDRouTkNHjIuCECSEAEU5wo1GuZWfRzneFP6F4w 104
quixstreams/sources/community/file/__init__.py sha256=Gn9dM0KQDvuEbBek-n7i8yfgI3kFK6-ywqESQdf9MIU 85
quixstreams/sources/community/file/file.py sha256=BCYSGRvL1tJP1kiam8JkqvGKLNiRRsd_87HYMwBCLo8 7133
quixstreams/sources/community/file/compressions/__init__.py sha256=E4cS_HMsyBIgxCnCtTKPO3DieOQYC400f5GnrMQtB-E 151
quixstreams/sources/community/file/compressions/base.py sha256=Epp9NCjf3QNYhxVCuNRR-fiAy_stsfbMKzASLQqRZ_4 281
quixstreams/sources/community/file/compressions/gzip.py sha256=E9FBD0iOwOxemE-tsljWIgnSHwjMLjiuTtWUfe7FqIQ 336
quixstreams/sources/community/file/formats/__init__.py sha256=PmQF0JSuHVBWgy4FXoVZVA7qFnp_BFr6aoMiWgqF8Cs 170
quixstreams/sources/community/file/formats/base.py sha256=NJ5ysNdrSEwWyIgBLg92rZW1piEF-FOWOVor6DL0H80 1883
quixstreams/sources/community/file/formats/json.py sha256=LOc2ZKeGCYHYXxk9S1TkmIcr5g4GPtogbRcDUvf5em4 1140
quixstreams/sources/community/file/formats/parquet.py sha256=3At6ghAEgot8yMX15JtUs7j0pHeYOAEGolTUuxU0Uzw 973
quixstreams/sources/community/file/origins/__init__.py sha256=V3hXOCJPKNiHaLPGYI3fKIs8gTccUtfQIF1Q4j7muK8 79
quixstreams/sources/community/file/origins/azure.py sha256=CUUxzOA7g4NT6SI8O8zW4P5RVMC2QXDryBMm7aHjts4 2273
quixstreams/sources/community/file/origins/base.py sha256=H0ITVXflu3B4HzPgdG1nD2menCOLrObx27KBiKqB7OY 944
quixstreams/sources/community/file/origins/local.py sha256=TjfEhRiudLGKipzWMoKOqawPMBL3-a4UAMKhfL4OJdw 648
quixstreams/sources/community/file/origins/s3.py sha256=yu-PjaaHy6xmGJKbCEpWysFFUHdD0v0nf0bX75lGotQ 3142
quixstreams/sources/community/kinesis/__init__.py sha256=UofukZu7oRRHJIq0-7hjs-bKFtqXiom3WDmAtjev268 42
quixstreams/sources/community/kinesis/consumer.py sha256=Qqtwdjy_1VAO07sybpMdTNG77l9ZYAltspJAA1c7NHo 6997
quixstreams/sources/community/kinesis/kinesis.py sha256=mnTVivNmaTel9LhJopfD84yuy7ZwID7PQqVqlWqBmgE 5231
quixstreams/sources/community/pubsub/__init__.py sha256=sR8g_t2xh2xsh6ESBwKvBjA1Ek9G-4TASyr2U5BkClQ 41
quixstreams/sources/community/pubsub/consumer.py sha256=d3eJa5pSwn7bCSgpMg7iD-HHDKVMUZ3rsWUk2SpJKwc 6873
quixstreams/sources/community/pubsub/pubsub.py sha256=RC3PiCwQWnT8MUJlr8Hncl0t9QzewUGYznHcnRc1aqU 5008
quixstreams/sources/core/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
quixstreams/sources/core/csv.py sha256=nHnEjlnExDe0srxwyT-MoyoguqVJbNymi_K28GbdmSA 3496
quixstreams/sources/core/kafka/__init__.py sha256=WAdGvpSE7zeQ3xSa0SsTA2FAcoysTuFy_OlOvQtZPtY 154
quixstreams/sources/core/kafka/checkpoint.py sha256=ZG02dJ9WR4KpWCMTF1iz7O1BmW6DkwVbgge1vNmH6SM 2829
quixstreams/sources/core/kafka/kafka.py sha256=RMJhDRSXdJb0kuBF57jGUGKLLtzSoe-TmU2cyXuUupM 14063
quixstreams/sources/core/kafka/quix.py sha256=6Wd9kk_Ef7bksG5oYhxl4BBS5bQIMo_erfxuPwM43U8 4041
quixstreams/state/__init__.py sha256=LfkosBE0CSkk6csnoJFJ9Kvo_2S8NKPlB-GClE7EM7g 107
quixstreams/state/exceptions.py sha256=t3Pwhr1EoL6bSdtXJ3TYCHF1mNiJLaXEbw2Zp-c--Ww 721
quixstreams/state/manager.py sha256=VPfzz1LEG2zjMghrFh71-6hT6enG_PgfBa4_qQoGsUE 10748
quixstreams/state/metadata.py sha256=k4Y8XCjNDaRMsv54sPIqGodPKqyQRO_nqRRZggs0spI 275
quixstreams/state/recovery.py sha256=Phd2XMlSUBY4BGzXXZRKi-Fwx4A0oNmL0qZWXWbsnsg 16165
quixstreams/state/serialization.py sha256=YWWv0I_KWAYLNCu8USXKlUBkGaALq5Y738nUrWM99g0 1008
quixstreams/state/types.py sha256=JZ2vMqHn_9_HB6w098KBGZ_YOUyaWtuiEwdMaXLJHDQ 9703
quixstreams/state/base/__init__.py sha256=y4r7sZcc_yw9NENr1r2O3h6DZegX5N4bgV_G00ygZSI 113
quixstreams/state/base/partition.py sha256=JokfD3mF14Tc-2OUKX6LqiCfYnoxroKQ-I_WBlY62wA 5958
quixstreams/state/base/state.py sha256=t173H797ca8-tkRX1EuvkAO0A-K-48zuTOZDeaWhfLY 2961
quixstreams/state/base/store.py sha256=zNtOysgRJHdqBFFBargRyZ8UAgS7Gm7NoY48srTqov4 3779
quixstreams/state/base/transaction.py sha256=SNZ-rH6331WCqNdgBcnPW6Gmaw5x3UvpMmI82onAtak 16781
quixstreams/state/memory/__init__.py sha256=iGQUCPNPFoyT6_hftfEC_ki8BvUahD_REsyPzhERnik 65
quixstreams/state/memory/partition.py sha256=ndMmWgXjwKbQ4lS4M-Q6HcPBsd1P__FBxk_OWAmJLWw 5553
quixstreams/state/memory/store.py sha256=k39_-hODWQdGBxI9cV4J1KT9BHZCSE5fgeauODg3C2A 1421
quixstreams/state/rocksdb/__init__.py sha256=y8BnIBTS6eyXA0KtXBSmI5I0VnwIYTLrRf6hrCGnhMg 135
quixstreams/state/rocksdb/exceptions.py sha256=NZlWOrkQPltD7mKaBVtXTmmNdyxXKkCdMY0MRoZxXZA 145
quixstreams/state/rocksdb/metadata.py sha256=Cr5UbtxB4xJYfkarnTPoDjXxIOyd4ec2y0Kdj0pW6S0 90
quixstreams/state/rocksdb/options.py sha256=0ZPhNggM9jDo0hMM5wasoD2kCCpwh2aDWGKGeX_R_j4 2968
quixstreams/state/rocksdb/partition.py sha256=lmQhrPdZqLmfR1QqUJE_hb2xNdqaLje_XoXNs6esjMM 13638
quixstreams/state/rocksdb/store.py sha256=d9-0eq6xzVcmUD_5wFtLkaoYDcYayZRPhHJBve6VOok 2034
quixstreams/state/rocksdb/types.py sha256=Fo5DpEjrByzPWG9KCJhG7poQmmrpxvq5ViSA5IOWweg 715
quixstreams/state/rocksdb/windowed/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
quixstreams/state/rocksdb/windowed/metadata.py sha256=rzViNDYowsAJQOjuFwkBFJO8xu_0dLQATHHiYIgjCO4 333
quixstreams/state/rocksdb/windowed/partition.py sha256=r5ar22Lj6A4rcgqAKSEjR796lAHP--05DXRti82kqEQ 2368
quixstreams/state/rocksdb/windowed/serialization.py sha256=VmusYEhqJj8iQqNpAs_59jS7_GJd7TQFYopc2J0msms 2022
quixstreams/state/rocksdb/windowed/state.py sha256=qsHG-b72GptS8vVbEWVwy8IWrsmZLhOpjwn7D7Qs1lw 4852
quixstreams/state/rocksdb/windowed/store.py sha256=Yk22D7rFw2NzEDuT42To5xQwwFzOuAsA6-hV7C9_2Gg 1782
quixstreams/state/rocksdb/windowed/transaction.py sha256=eYZeRgr-tI5qtTkL2KhUE9pl_Ek_EEf6_mNzCokfVLM 12904
quixstreams/utils/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
quixstreams/utils/dicts.py sha256=Yc8l-johZzEuWIm7vzmTwYXLj19MoK_0pqWMII_F11U 607
quixstreams/utils/json.py sha256=wBtRWEvo2nVfwFIsZVbNpr2hOoF4TuXnnNdcF24zow0 636
quixstreams/utils/settings.py sha256=OEpKHNp-vYROXV33sEvz-yCaSACJ1D0D76eHklxSk9s 1225
quixstreams-3.5.0.dist-info/LICENSE sha256=P12cSoW9dae7S1OZMTZLKVwDUvS8UYdAnVwSYrUmDRE 11353
quixstreams-3.5.0.dist-info/METADATA sha256=vPoAL5LUk-DfGnJsQk_hAxsbJt1lM5q1SYfjXPy3FFo 23702
quixstreams-3.5.0.dist-info/WHEEL sha256=P9jw-gEje8ByB7_hXoICnHtVCrEwMQh-630tKvQWehc 91
quixstreams-3.5.0.dist-info/top_level.txt sha256=Vk4q2NfXCIP82ZaTX5k5e6e9ao3IEvYPzquAl-1C7vo 12
quixstreams-3.5.0.dist-info/RECORD — —

top_level.txt

quixstreams