Wheelodex » Projects » mx-stream-core

mx-stream-core

View on PyPI — Reverse Dependencies (0)

1.2.7 mx_stream_core-1.2.7-py3-none-any.whl
1.2.6 mx_stream_core-1.2.6-py3-none-any.whl
1.2.5 mx_stream_core-1.2.5-py3-none-any.whl

Wheel Details

Project: mx-stream-core
Version: 1.2.5
Filename: mx_stream_core-1.2.5-py3-none-any.whl
Download: [link]
Size: 22875
MD5: 9a2d004da0a01c23b7e80a1747a748d0
SHA256: e8526c4840dbd857367d114d77925cefa783b55145d502c6a999cad491a7a06b
Uploaded: 2024-12-23 07:32:31 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt

METADATA

Metadata-Version: 2.1
Name: mx-stream-core
Version: 1.2.5
Summary: This is package stream core of mindx
Author: MindX
Author-Email: tech[at]mindx.com.vn
License: LICENSE.txt
Requires-Dist: pyspark (==3.5.1)
Requires-Dist: numpy (==1.26.4)
Requires-Dist: delta-spark (==3.1.0)
Requires-Dist: redis (==5.0.5)
Requires-Dist: pandas (==2.0.3)
Requires-Dist: pyarrow (==17.0.0)
Requires-Dist: esdbclient (==1.0.25)
Requires-Dist: kafka-python (==2.0.2)
License-File: LICENSE.txt
[Description omitted; length: 7 characters]

WHEEL

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

RECORD

Path Digest Size
mx_stream_core/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/config/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/config/app.py sha256=I5JT3NV_N2ISOv81tOWHyHtlZqLeOXcQxWuhU34MuXQ 105
mx_stream_core/config/delta.py sha256=eouiJvRtm89FBINHPZScWeZM-aRUWuHLquAtje3xvkk 566
mx_stream_core/config/event_store.py sha256=VySb1807-oLOpLLdrTulISUg5Ec0mD5H-Xp3sfWCYIk 119
mx_stream_core/config/kafka.py sha256=mdOsKotCCiK7C_hXKHxrADJtzntqGoYzQjB5JCZV-gk 82
mx_stream_core/config/layer_events.py sha256=g8ny-w9KcB9aEBGI5YhdHumqCRt2VJi6oDHAY-GOVBE 180
mx_stream_core/config/s3.py sha256=GRvrPKAw2RMQlNtnzy0Q8GG9DMUiULTzDFVE3App7JU 381
mx_stream_core/config/spark.py sha256=Wic4yZlZ4lRXwDZcGjgptdckISeGOEBq2foBy3-KL4o 706
mx_stream_core/config/streams.py sha256=VkFVKewCdEcLy76BuTTbqqjRn-pculAIr6z52ISNIpk 76
mx_stream_core/data_sinks/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/data_sinks/base.py sha256=_pOweKz6XlTj0OIte4OxWjWkNLKtNdTCKsnblUAgrPg 472
mx_stream_core/data_sinks/delta.py sha256=VFbPZhu02M_5aRF0ENDY-gT9WqTqLHqvfoJ0qz-42N8 1812
mx_stream_core/data_sinks/kafka.py sha256=jpq45RZTU1gMBWXPhVslxHFcKs5JV3KdVueeHNwnmow 481
mx_stream_core/data_sources/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/data_sources/async_query.py sha256=E4KTkb_5-UKl1HTYMGqQcip1q6dhuCtpfuNudHPaspQ 3053
mx_stream_core/data_sources/async_source.py sha256=BzjdgZHnfKdMF_4cmAdD2pKNT855d8eY-3vscWl2mrQ 2130
mx_stream_core/data_sources/base.py sha256=A6XUjUsQjQuPBEz1jh2x6KWe9Cq_0OO4tcbZPjVQmGs 341
mx_stream_core/data_sources/base_query.py sha256=GIVMfEoGCFwMbamNWPismxmd35xDoyHxAulVdOoy9Rk 202
mx_stream_core/data_sources/eventstore.py sha256=Cwx4U-a1VphX9MyCaUL4AosJMGgDsJygVqshlJR5Y2g 3620
mx_stream_core/data_sources/spark_delta.py sha256=khfmfVL41TlboF7sptAw3ENXC8g19NL4s2j033Wngwk 759
mx_stream_core/data_sources/spark_kafka.py sha256=GmSKMdYAZbB8HaW-MlbhaKqXWfIPEU9kxq5Jb-ENpvQ 1268
mx_stream_core/infrastructure/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/infrastructure/delta.py sha256=Q_3c1zAvyfJwMz8jYIOU17NI477S8cyu7j5pEoH6nJA 226
mx_stream_core/infrastructure/event_store.py sha256=UsLDDhuZ7nDb19SWI6Im9ovZkBoYMJPXUoEZtUEaF30 1772
mx_stream_core/infrastructure/kafka.py sha256=WkXhvt0bv1tADA29_09O2i5m5hVj-5rhmLVHEE5-sPA 6140
mx_stream_core/infrastructure/redis.py sha256=uHiUbwJdW09Hdbm3wZLmpEuB1XFnRm67G6weeTVpBeI 1508
mx_stream_core/infrastructure/spark.py sha256=1dSSwjJ8VPdqk6CgtFfWsMxhejLxjskFNUQ6iPHKO0Q 1950
mx_stream_core/schema/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/schema/streaming_query.py sha256=UOhpchVBN1ahMQviqrKG-Ao1XHnhfO4UGCb6GTV9L68 513
mx_stream_core/tests/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/tests/mock_data_sink.py sha256=XkTCIEYuMdyJNMfLeTfaTbz1tIc5LmMxnuJQ_SdW_8w 1586
mx_stream_core/tests/mock_data_source.py sha256=oMLaXuvcpG_UX9yV6AS3Wvcgxgi8hgv_96mg8IUos7w 463
mx_stream_core/tests/mock_event_async_data_source.py sha256=EPWg9jJNC-IGWhgVqxgOdU9LP8UWR9a6khfeyEC3qUI 4793
mx_stream_core/tests/mock_event_source.py sha256=9lvSes5MxsYq9n4fcIlqygueVE5Rg7NxxmLgIDblWyc 654
mx_stream_core/tests/query_listener.py sha256=ccDVoJByVBMRnOmzy89-ZLr219_7fXj_z37fFNWg5xk 959
mx_stream_core/utils/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
mx_stream_core/utils/cmd.py sha256=KHdIjRpWlFO_m8p9zkawoBNOn8mIyZUL4U3fEsKsrCc 334
mx_stream_core/utils/telegram.py sha256=HYu0h--LLtoKS2XV15v4P5gXCY0MLfLFxafoVCq_jRU 825
mx_stream_core-1.2.5.dist-info/LICENSE.txt sha256=uJYBl4BozMVKc1pR4QnsFsJmOId6HEvnVrBlpE0ssAw 1079
mx_stream_core-1.2.5.dist-info/METADATA sha256=pvdnGvy9ELsuUBn-0vryth2CzJIr5-QCfMTh6TAMoPo 516
mx_stream_core-1.2.5.dist-info/WHEEL sha256=G16H4A3IeoQmnOrYV4ueZGKSjhipXx8zc8nu9FGlvMA 92
mx_stream_core-1.2.5.dist-info/top_level.txt sha256=7P7-xBnxxYlylDW1z6XXlCWBZFn_rKCU8ESabosijcw 15
mx_stream_core-1.2.5.dist-info/RECORD — —

top_level.txt

mx_stream_core