Wheelodex » Projects » quixstreams

quixstreams

View on PyPI — Reverse Dependencies (5)

3.9.0 quixstreams-3.9.0-py3-none-any.whl

Wheel Details

Project: quixstreams
Version: 3.9.0
Filename: quixstreams-3.9.0-py3-none-any.whl
Download: [link]
Size: 258043
MD5: d38702d6c05d49269b9559fd49ce38cf
SHA256: 6f17bce8e0e925bbe5b5543cbdb78e1081c9424aedd391c05bc7bc651d2abb8b
Uploaded: 2025-02-24 13:45:06 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt

METADATA

Metadata-Version: 2.1
Name: quixstreams
Version: 3.9.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: rich (<14,>=13)
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: neo4j (<6,>=5.27.0); extra == "all"
Requires-Dist: pymongo (<5,>=4.11); extra == "all"
Requires-Dist: pandas (<3.0,>=1.0.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: pymongo (<5,>=4.11); extra == "mongodb"
Requires-Dist: neo4j (<6,>=5.27.0); extra == "neo4j"
Requires-Dist: pandas (<3.0,>=1.0.0); extra == "pandas"
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: mongodb
Provides-Extra: neo4j
Provides-Extra: pandas
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=bjwdQCtqnunl7jth75uK4s0TtetFasodLhTLkEfPJVo 222
quixstreams/app.py sha256=w3icNZqa2a5H5zJD9ENCVUZP5sbz0_njqbNG7Wd_pE8 42877
quixstreams/context.py sha256=fFGdiNMiNpywFzDZOrxfpNMM0LpGoPq6SXD2RHKYdrw 2240
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=ueyY1oTKqsQYbCMa2I7q2jOg9WRyfNL2EMIUZcUt2j4 92
quixstreams/core/stream/exceptions.py sha256=CL8pskURFrL5rjVqrwGceMj7eb4GOvKYExSFWSQbQN0 125
quixstreams/core/stream/stream.py sha256=-ofUjxQ8Tv1gELgY_ENiud7DkkdM0e5iVBde1Q8ACaY 20241
quixstreams/core/stream/functions/__init__.py sha256=enivaV7D2-WNvrRDOCOFWV6FD_qhcgP2f2MeU31KNbs 150
quixstreams/core/stream/functions/apply.py sha256=hMEA37uW5jWFvqaicsqShWqDoAIFF1Hvmv4gk9jeLdk 3872
quixstreams/core/stream/functions/base.py sha256=iByt5WT6ijr4p_46RXH6t0V0C7gSdGn5VtNuNiim6PY 2070
quixstreams/core/stream/functions/filter.py sha256=3jAyfa9i7SmCh8aLDB1VDqM7G8twoag4FUADREYuINQ 2050
quixstreams/core/stream/functions/transform.py sha256=unADrt3OuOusCcYflkPFd8hcN1awQsifoemOiHI9k0M 2389
quixstreams/core/stream/functions/types.py sha256=0QYT2Ch5sCNkPMQKoB7lh80iwYVgOiD1QdtOvdMLcj0 1812
quixstreams/core/stream/functions/update.py sha256=4LVg_PMrbVjE1VImVHzyrpJZlr-IE1oswdaOWNe7HAE 1964
quixstreams/core/stream/functions/utils.py sha256=Z7SW--0aCUZ70zPROsU_vlzzxIG_SjJxRzTXkaJ1c3Q 653
quixstreams/dataframe/__init__.py sha256=75Z9a5Z4UA_6xMp5tbLvPiXMejHrLgu3XoEMVEJYzQ8 555
quixstreams/dataframe/dataframe.py sha256=177oMpnAD8KHhQ1Wgtwb5Ni8iQVBhnhKIqnB0MQOc4Q 61445
quixstreams/dataframe/exceptions.py sha256=47Ztj2mf9r4VkE6U9SMYnC_Rqr8wW_D76qC_J4wFvoQ 527
quixstreams/dataframe/registry.py sha256=i1PUlXkzPudxCqcumOhQfwpJu4x4kD0olOL3wSXuW2k 3345
quixstreams/dataframe/series.py sha256=J6Nkxl_ky6632NtnBaz5GH2wihX0_jpj9S-uQv5wC6g 17944
quixstreams/dataframe/utils.py sha256=6clRYg-QJ6N1R2IDN1TB03ktZbIi6M7cOG38rxMfSCk 754
quixstreams/dataframe/windows/__init__.py sha256=jNY4Y3OdrjRX8gcJkAGZV3sKa0k-fYIZpdBVfbToEIE 513
quixstreams/dataframe/windows/base.py sha256=xcw6B1o3oVZt02ez7onuBo0wjWMgHJdzlO1GPm8R7hg 7464
quixstreams/dataframe/windows/count_based.py sha256=h8VIoWGxfQsq0XQZJuo75DHmI6O-EYwgVuXDw3jG1V4 6152
quixstreams/dataframe/windows/definitions.py sha256=-i4zF2l_pYDyJIs95oa5FbVwuWAnh2Goiemq7V1rOEU 14667
quixstreams/dataframe/windows/sliding.py sha256=NmOPHw2iOgswNTLbD1P3EYyZyKX4CMjX2jKAmhsMr5I 11069
quixstreams/dataframe/windows/time_based.py sha256=qJft11Jy2CR5dJkiMFfVItDEL-QYzTGXMMMf15wuSMk 4883
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=gH2qfj5aK5sDBoYjEqKxGxjW4288PjVAA6uq7atzrSU 23968
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=HUPxdwIgh3aEsFo6w4D9dD44vFmTC0dmtX6uSmQmdvQ 8531
quixstreams/models/topics/exceptions.py sha256=0Y0wYKUPqTPci2ZqdoibWDVtFz9jpIPyEOhrVqQpHVU 346
quixstreams/models/topics/manager.py sha256=sDVluN4GjK8IOxCL_1lxV807367FAigHTFKcmaY2kXs 20040
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=wfYoIF4FhplHiYC_PHGpnVsCaxhDWMBqglTxvrUfQHs 7006
quixstreams/platforms/quix/checks.py sha256=mQvNAcT5I_KwpFFbuMYwuyUHmsb6dP45RmcIF5KmE-c 1711
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=LNRB2Bi-_JMBa3nvi90-yeUGfjrwdEh6oG19smCDDx4 3628
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/mongodb.py sha256=0c1_ThI7EYG-5hvfBBL1P4dJbBsfYbjS-za3YJj1yw4 8033
quixstreams/sinks/community/neo4j.py sha256=2kHl2mLEbvxAhihPUxbXlBW50mIGAURyl8HfbeRq11A 6866
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=y8D0Sk5PQCDYMi9qW8VViUxawTseMnCCCQYNgyj3wyw 11249
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=C0RoN8sbhTSNcKgz6u7nnq0locm9aZQZCOjMqzegT7w 10359
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/pandas.py sha256=X_jMHs-r-S-ZZRehCD1-r0t1qy-1YkCywfBsRv4FRrI 5611
quixstreams/sources/community/file/__init__.py sha256=Gn9dM0KQDvuEbBek-n7i8yfgI3kFK6-ywqESQdf9MIU 85
quixstreams/sources/community/file/file.py sha256=yKBqCN_A6U87P5ZTYT30NHUFMgRHgNvg7vivOh10M2U 9006
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=f3GsVsGZ_yISkcDCKthHUt9Ol7AF7AxvVHie_nIcjNk 14051
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=uSyhRXoj6cE_UxHj3AojyPn-LtN1TIYqyJCi5KSl65k 784
quixstreams/state/manager.py sha256=eyapMZYvlFkbdOCzIUAj-rZ95QaQHoAQ8_bLMppOncI 10768
quixstreams/state/metadata.py sha256=azvz_acUIOxwv65vhrHwVXmxt7337b0FthNxUWSm0fU 268
quixstreams/state/recovery.py sha256=C-PKCcJtJm0gQzJyyz2pCmMWSimgbYFCXb8QiGmNRQ8 17084
quixstreams/state/serialization.py sha256=YWWv0I_KWAYLNCu8USXKlUBkGaALq5Y738nUrWM99g0 1008
quixstreams/state/types.py sha256=hMjmgu-gyqCD8xxIHxCqNd6EKO-MSdfR2KpUh5Tuc1Y 14268
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=-W1L-prj2vIE0rsHzZfJ6KYdOXTu7qG0gV_S6Lbo9pE 16729
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=vMEyXsbTzqphZN73OPrdTpXCpJCCg-TLW4TbCQ0l6tg 580
quixstreams/state/rocksdb/windowed/partition.py sha256=XieSOW5fyz6NpePuPTlL2_FbUut4UUZ33TCIJvUcykI 2625
quixstreams/state/rocksdb/windowed/serialization.py sha256=WNh3vRTHhpz06xG90Z7AHog21-51Spxj79kD29rjSlc 1866
quixstreams/state/rocksdb/windowed/state.py sha256=73orfceq0caIQkNkmw6QrVX6uWkz5Pd0LmUgHuIhnxw 7106
quixstreams/state/rocksdb/windowed/store.py sha256=Yk22D7rFw2NzEDuT42To5xQwwFzOuAsA6-hV7C9_2Gg 1782
quixstreams/state/rocksdb/windowed/transaction.py sha256=iE49VxQEOh1r-6T8dRggX-fJkuUIIvZKbZ0IOOvtfO8 19304
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/printing.py sha256=GG7C5abaL8tK7kvRQuiGLtHA0fVFZM624cvr1r4FKPY 4536
quixstreams/utils/settings.py sha256=OEpKHNp-vYROXV33sEvz-yCaSACJ1D0D76eHklxSk9s 1225
quixstreams-3.9.0.dist-info/LICENSE sha256=P12cSoW9dae7S1OZMTZLKVwDUvS8UYdAnVwSYrUmDRE 11353
quixstreams-3.9.0.dist-info/METADATA sha256=-O2gDOp27E66nQgAYKV_14utZHOk0bUg7-wLSgZfHIE 24113
quixstreams-3.9.0.dist-info/WHEEL sha256=P9jw-gEje8ByB7_hXoICnHtVCrEwMQh-630tKvQWehc 91
quixstreams-3.9.0.dist-info/top_level.txt sha256=Vk4q2NfXCIP82ZaTX5k5e6e9ao3IEvYPzquAl-1C7vo 12
quixstreams-3.9.0.dist-info/RECORD — —

top_level.txt

quixstreams