confluent-flink-table-api-python-plugin

View on PyPIReverse Dependencies (0)

1.20.50 confluent_flink_table_api_python_plugin-1.20.50-py2.py3-none-any.whl

Wheel Details

Project: confluent-flink-table-api-python-plugin
Version: 1.20.50
Filename: confluent_flink_table_api_python_plugin-1.20.50-py2.py3-none-any.whl
Download: [link]
Size: 382365
MD5: 2867df291b48bf3678b787226f0b6e27
SHA256: 155ffc57a1ce80bd96cd4115140a97af67ead6d2f9b51f272cd1d5914d50c0ad
Uploaded: 2025-01-29 14:52:04 +0000

dist-info

METADATA

Metadata-Version: 2.2
Name: confluent-flink-table-api-python-plugin
Version: 1.20.50
Summary: Confluent Apache Flink Table API Python
Author: Confluent
Author-Email: dev[at]confluent.io
Home-Page: https://confluent.io
License: https://www.apache.org/licenses/LICENSE-2.0
Classifier: Development Status :: 5 - Production/Stable
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Requires-Python: >=3.8
Requires-Dist: py4j (==0.10.9.7)
Requires-Dist: python-dateutil (<3,>=2.8.0)
Requires-Dist: cloudpickle (>=2.2.0)
Requires-Dist: pytz (>=2018.3)
Requires-Dist: requests (>=2.26.0)
Requires-Dist: pemja (==0.4.1); platform_system != "Windows"
Requires-Dist: httplib2 (>=0.19.0)
Requires-Dist: ruamel.yaml (>=0.18.4)
Requires-Dist: confluent-flink-jars (<1.20.51,>=1.20.50)
Description-Content-Type: text/markdown
Dynamic: author
Dynamic: author-email
Dynamic: classifier
Dynamic: description
Dynamic: description-content-type
Dynamic: home-page
Dynamic: license
Dynamic: requires-dist
Dynamic: requires-python
Dynamic: summary
[Description omitted; length: 40 characters]

WHEEL

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

RECORD

Path Digest Size
confluent_flink_table_api_python_plugin-1.20.50.data/scripts/find-flink-home.sh sha256=iI61tUeUhoPuJl35VsNcmWzZw4zKLLMV61KK-W97z8c 1318
confluent_flink_table_api_python_plugin-1.20.50.data/scripts/find_flink_home.py sha256=9egC7j9TpEjruop9T73apvPRgVILGZaIfFitO_8OuoM 3205
confluent_flink_table_api_python_plugin-1.20.50.data/scripts/pyflink-shell.sh sha256=HBNDMZ5hHJfZubFmn4zK8-0g_lBY0w8vtATFigyNftI 2994
pyflink/__init__.py sha256=Q00Fyx3P0vBSDsKG1c8SB4M2TUOj3oWKVcJyQ5wYCic 1969
pyflink/find_flink_home.py sha256=VLY37kGA5Rd3h_DQrtUNWpHdCx1Fbq04IEPxA0LpkyI 3218
pyflink/gen_protos.py sha256=JDQgr9obXhLtT56tE6kMuUiN3boYuxzS-4_nA7q6V8s 9320
pyflink/java_gateway.py sha256=NHYgsSWN_mJ7GXIjTntMLYk50YbtOZgMTAv-dl8g7mE 8330
pyflink/pyflink_callback_server.py sha256=g1qq2GgwPd_C0pz6jC360X9VF2_V-uGvoHaejsi9RDE 1351
pyflink/pyflink_gateway_server.py sha256=CmTF2sSncK74ZiWBN13KllV6iAllvUMb9WIFIgmhMMQ 12380
pyflink/serializers.py sha256=Ogirko8yMFoMIkvbcPY0OyH4noCYLGxO5DvPoI_NCJ0 5422
pyflink/shell.py sha256=ixiI1SN7CM53vIo629OBp3IUfqWl9tQoO71Xii_J2pg 8093
pyflink/version.py sha256=kzUmDVJgZe1CdBNVl7XeA4qNYYe9eensHS-RAQnZwPw 1130
pyflink/bin/find-flink-home.sh sha256=iI61tUeUhoPuJl35VsNcmWzZw4zKLLMV61KK-W97z8c 1318
pyflink/bin/pyflink-shell.sh sha256=HBNDMZ5hHJfZubFmn4zK8-0g_lBY0w8vtATFigyNftI 2994
pyflink/common/__init__.py sha256=K4kkFRrRnCPZAFRdoyKHCuaBuJziqwklAtBTLCWBo2k 5570
pyflink/common/completable_future.py sha256=3jnTY8Ik0Oa6bmVBrIyIp36DP5_BVTEeCDt-sE2mAyg 3240
pyflink/common/config_options.py sha256=S4MW7Jr0KH0O6-J_9bJWIDAq1M7vwAHF7rtzx3YohtA 5257
pyflink/common/configuration.py sha256=DWrXu6j4Lf3fvpSFelciJ7_zf7GHE2jx1e_gA0APvqI 10047
pyflink/common/constants.py sha256=Er6rgJmUUbal109CBr-MjhKFDga-QXBu3uEq4EJ5UHA 1236
pyflink/common/execution_config.py sha256=5676GdL1Vz91VKv-hhUPTUZxOo13zliRZmX9dRTJknU 30841
pyflink/common/execution_mode.py sha256=U3AjVEqY-ByTnYV0kk93W4FwOpb5GdKjgH6OWUvMkxE 3280
pyflink/common/input_dependency_constraint.py sha256=BKv3Mk0sB1aPvPYMbFC5Rpbe35fptsfYyfq24m4YYYU 1867
pyflink/common/io.py sha256=AsNhL82B_vak9XOrIYfaBHzO7ZYLHGqYgT98tmXnD74 1305
pyflink/common/job_client.py sha256=JtMOYTIBiGR95g2OUIyA3WuZvDH4lWv1railmI65V8k 4961
pyflink/common/job_execution_result.py sha256=f4L4npjOeZ-qJFLFFMAahCEhGCl1tGs-nGvpZz65Dmw 3400
pyflink/common/job_id.py sha256=mTezhL_aIsTc-B7fK7AsgqNYR0EVNM8FFcVA_9HjCtg 1538
pyflink/common/job_status.py sha256=QwvBmmtJIFL58LBDLWWi7OuD8rsCqUeHLyx25QTKWgI 3894
pyflink/common/restart_strategy.py sha256=1SmmKyzqleyIs0MeoW85feH017WW9Go4Wd1xlodd3gI 12189
pyflink/common/serialization.py sha256=XGBhSVC39pAAB5VujwMj3Chi4BKngd6rMbe1LzewGq4 4419
pyflink/common/serializer.py sha256=6UmWR1mOnC6M45QBzY_f_rFsIcXYpVDFj3WXwNUmano 2855
pyflink/common/time.py sha256=wak2lqNVygMxD5UFYfEu53R18CuCeFERM8CLIrobqXk 3915
pyflink/common/typeinfo.py sha256=UBhhHu6gHGkbnho6YhYFMabmj9b16-nONyUz3e_SMCw 43933
pyflink/common/types.py sha256=-WptBifq7eBWGQtF1UAPMYRf2u4SlXVQPkDo2KVB7VE 9568
pyflink/common/utils.py sha256=ZdKDZsFMp00l4KfXbBEQbOWhgeiBv3mNOR3dvvNBdOM 1123
pyflink/common/watermark_strategy.py sha256=NaLx4HWTRaKQGvq02WE4IuOIXxAqz_lf6ERrgz66a3o 8606
pyflink/datastream/__init__.py sha256=gvzqj8k-xkTlABsLfAxoM-m8bLJIQllRTsnM0qwqRoQ 18294
pyflink/datastream/checkpoint_config.py sha256=b0MkUSm9JcKv4WeWWVAqPzmtyfIMzYxzh63r0PaS1XU 27648
pyflink/datastream/checkpoint_storage.py sha256=ftwrXyP5uosvRvhN_UhF3p4Phom3efUsXJ3vP_SR3Po 16747
pyflink/datastream/checkpointing_mode.py sha256=ob4Cz8ukAOIXS0rr-rKP3WUYT5MkxVGdXt8YwBslAcA 4576
pyflink/datastream/data_stream.py sha256=HBNYgbbkQdlGld9LQYCAJoPd4Y_-Ub7DVxYQP5b-B9M 137180
pyflink/datastream/execution_mode.py sha256=sp9nMKc9J1jBWSNFPzyYgT4gzGhqY9_MYT3Pl5NbsTk 2550
pyflink/datastream/externalized_checkpoint_retention.py sha256=i9c_lQtmhVcW1qE3jCrfU-LGWBsbiQo505_AsBKPZcQ 2742
pyflink/datastream/functions.py sha256=irB--mL2Zf8ZYe3ZD1dq_Yh1oZrh33jTS7REawdiNIM 59027
pyflink/datastream/output_tag.py sha256=vPLWCnmyJm6YBmB2fIjUt3b-wa7SDPWTWGesvy_ek6Y 2996
pyflink/datastream/slot_sharing_group.py sha256=fVkxcmkILwuH113Cz93MAH55208cj0l8YReueuad6-0 10515
pyflink/datastream/state.py sha256=NzROn9OGylPE7us6SlEqm2KcaxYiLK46TzzEsyrGIFY 39775
pyflink/datastream/state_backend.py sha256=KBp495c4SWgKE7YmgQzYryRQA7_3oz-QfO1iftLoQao 50056
pyflink/datastream/stream_execution_environment.py sha256=AOa4emmVykTop9DS-5b1f40afTdxRJXvzf-3wQMwwvI 53187
pyflink/datastream/time_characteristic.py sha256=Yp47XwEcz51Ehbk51b6H5Qja08D5T6UeUJ26UjNkkfU 5047
pyflink/datastream/time_domain.py sha256=XS5jUDG2QN1d9PcdknnVg1Jn6cUfL0C-v4dzQVZgdms 1321
pyflink/datastream/timerservice.py sha256=WlIgG2LmWLKTQO31ksHyCQOZs2M_rVb_vBZ7gDfm5_w 3384
pyflink/datastream/utils.py sha256=IMhl1YvujeJvOAqDSxY3KyftootJC4d1hZzwA3pDDqg 5238
pyflink/datastream/window.py sha256=-rg4zC0-0e08WmuPdn51C7nN6FLt0c7U3nPgODB0G8Q 65027
pyflink/datastream/connectors/__init__.py sha256=L7gOoTONabvgLIPGepSRmh0egluyP0Og5R9DfCCf3D4 3344
pyflink/datastream/connectors/base.py sha256=J7-WF2CXremaJ9jUzHnLmrF1WDv_yezgmO2Ma9O6eWs 3132
pyflink/datastream/connectors/cassandra.py sha256=vqYyKKgI67gkv4wctbn8lSWPwtD4YpgPF3eY98axpB0 14269
pyflink/datastream/connectors/elasticsearch.py sha256=AUq9VBq5D7K9ZJ9BxGA2nNXIVAsTrjoqwR_RU-Bp0sQ 11926
pyflink/datastream/connectors/file_system.py sha256=9BdYY0HK8V7PwCt_xyHwAMvinVqP_wFKPx9c9gMt-fA 35405
pyflink/datastream/connectors/hybrid_source.py sha256=9cU7p-Z3UpWEV_AUnxfYp_SOGwjG0UEbl0KrGiKtS3s 2846
pyflink/datastream/connectors/jdbc.py sha256=QjcILZqqoWI8a7OX1qW-gx4jUlHll5IyhlJInam7m6A 7203
pyflink/datastream/connectors/kafka.py sha256=kxtIvo8Rg4R_575V2gAcHCadEH1SPseTYsy7qRjcSx8 51643
pyflink/datastream/connectors/kinesis.py sha256=BI0B5C41q9AMPHH2ZujtjlRH_UMDrtRUXFM-7kOZFCQ 25715
pyflink/datastream/connectors/number_seq.py sha256=AKdsAsPbvX88nFulECUhU6GaesIuOa4DMPmUh-Xhepw 2345
pyflink/datastream/connectors/pulsar.py sha256=cC_RgZflSm52zqMs68bWHOz9iFr5iZvZ7RuHP56jglY 34324
pyflink/datastream/connectors/rabbitmq.py sha256=qDU_tYcA-9O7wrKEBfEt-1fIRKDM5eWOkcD6Ewoz3w8 8324
pyflink/datastream/formats/__init__.py sha256=tsdcyN6K1n3apIrknPcNIgJf7Y4IlY4gQZ433ddZZB0 958
pyflink/datastream/formats/avro.py sha256=oNLDhwhBmstboK3DIRqltMxkBxfNcFPaevzOTV6N-pY 10081
pyflink/datastream/formats/csv.py sha256=Lj6lji4G4dNhkrPHdcCXnOY0Y1pCpRwBn9TFVYx0jyo 16754
pyflink/datastream/formats/json.py sha256=_f6dNqx_JQKCFNgIa1rVkgczZyvIdbW3fJEAI-aX5JA 5720
pyflink/datastream/formats/orc.py sha256=aXzPaMOeUReP8XKI8TWxPXbwyzS9RSaywvq74uUq4KQ 4057
pyflink/datastream/formats/parquet.py sha256=hA33mpclJGeRRp39dIqVKeh1gPnJHvulNQa1DckXVdU 9309
pyflink/metrics/__init__.py sha256=3hVB9ZlBk75iz2CJaslS2TCbn6uRrT1wGpOW0SHwXLY 1121
pyflink/metrics/metricbase.py sha256=3kogd4IJeWf6S5YMdpFq5lq8K7y-S1NXuk_7gzm84N8 4317
pyflink/table/__init__.py sha256=m3QC9Jy5UGBLcE_24ErnRqPinRTqVWhb4Ni4O_2_0SM 7396
pyflink/table/catalog.py sha256=NntAFNlTWjgHFSWWd1rBZ2UqtGxAfJmqzLfJuTyPOMI 52458
pyflink/table/changelog_mode.py sha256=-xj2sA04RWbx5Jze58V0-yOl_mmk-qE75Jzf6VnFkCI 1764
pyflink/table/data_view.py sha256=mzdiEDc_kX3OV3ZMaGsaQ18nBB9LTrTKqRw8cRRY494 5967
pyflink/table/descriptors.py sha256=cVRqqSdU9iXIicka5gHnQIauufS8YHXUgEYfhUATEcA 10888
pyflink/table/environment_settings.py sha256=xirTZMkQKuLXiUicU3dCaXT0KfHQPe4-Xr45zUxTpRA 10112
pyflink/table/explain_detail.py sha256=f0jX6Nfi9XWSbxEl3fR50IiR3SZ5r_H3eED6bBAfJPU 1684
pyflink/table/expression.py sha256=y_TCNaGQ10MdWEaM7YpIabZO1DaP3WJKgmcpJSYG15g 71910
pyflink/table/expressions.py sha256=XWcUdS9HtcaWdSecsl4wFJsJC01wLbpYS9DpnozI33w 31803
pyflink/table/functions.py sha256=7_vkI66yTMe1L7Sh-YXqUfK-nRs4dda3HWRsCsxfDOI 25335
pyflink/table/module.py sha256=6CWInJ6joRT4MeIKhTacIlgbiejxkHM-G-08BKNtVm4 2861
pyflink/table/result_kind.py sha256=SX4ho4_HhzIlQHkWR--WEwVQ0L9oK6aPIXuG16S3Pg8 1930
pyflink/table/schema.py sha256=cvI67-aHVnenBLpldG5u7lmC5pv96nR4ZrfAppyL9ZM 12691
pyflink/table/serializers.py sha256=CV8PgAjuK2ClkyJaADN2NXon6Lo5670bwRO6AKu7c5Q 3095
pyflink/table/sinks.py sha256=S03BCJ3Ni8NQiBNs1L70bZbNvdyz6NrB4xMcpTcBxL0 3226
pyflink/table/sources.py sha256=OFcUEWjysMql_v9BSqNbXvR5MUFkvtpS4b3yqKUCBLw 4611
pyflink/table/sql_dialect.py sha256=valTVPIszOzyjQPEuhRuisafE1XvFtnwqbOJ-7X07iA 2623
pyflink/table/statement_set.py sha256=Tjt-3Kt_5LYJ8CP0ETPpnoszdw4RSCFmKdf46_Aki-g 6668
pyflink/table/table.py sha256=Q-SZA_3uEwmglAoWqUn_0VxyNwoBF_KOprT9s4MtaSc 59588
pyflink/table/table_config.py sha256=qlXdTA3-MSNLndmKJN9-iVsxbOOnyKz1EK0yMYV5LgI 15832
pyflink/table/table_descriptor.py sha256=keLkEISSFkp7oxiJADVPc_4PvFjihrIDD0Prg3pzEIY 9313
pyflink/table/table_environment.py sha256=Px87m6AmSftLlQ6RAlEPlDoQH7Sf4PEPR2JGgIcrVjo 94210
pyflink/table/table_result.py sha256=h6olA-Uknv0Bn4B3Me3iI5R_6o-6zM8XI7yJOByUbbU 11783
pyflink/table/table_schema.py sha256=M1KZb_605cpGE9fsIy0GsBOYFCdgczDcnMyL6V7pcwU 5727
pyflink/table/types.py sha256=jFLm0fz8LZQbkduzIAFjAoB3I4RsiH0pA4SeJvy-ojk 110432
pyflink/table/udf.py sha256=y6JzJXjictIbZQoPwTNjHe-Q6Zn1SW6YB4ciqtRazCM 34253
pyflink/table/utils.py sha256=6eu4W53q9krV7TTetslW6phb4L74uuY95Au-HuNaoY8 6154
pyflink/table/window.py sha256=zFsiCRO3C7er2zF8C0DvFtX_XClX8O6R5IwcbUR-Cr4 16326
pyflink/table/confluent/__init__.py sha256=WwJ3hCUwYdv9HzlP6hRAoHzlyqiAsE4Fc3ZDQluNXZM 470
pyflink/table/confluent/confluent_settings.py sha256=AkXykr-vvwwEthY-InJWzXHGq2MNfAAajTQCiNG0Fa0 7586
pyflink/table/confluent/confluent_table_descriptor.py sha256=Oj6dvFN0QVL3G0UWIuV5-gV6iyZeHjToZb3KsMIJxHM 7668
pyflink/table/confluent/confluent_tools.py sha256=KzJMtO05deCRQFNevCBpidc3-qdHoYdvGz-71TdKkLk 7746
pyflink/testing/__init__.py sha256=i4Oy1qDWt9nWHVY7IjWYZvH39eY5Vz5PllgUv_yFsmw 959
pyflink/testing/source_sink_utils.py sha256=OlgRzTkvEQ2NiCvxyGE8mivFUeZv7uF9bAiPyLk0kmY 4814
pyflink/testing/test_case_utils.py sha256=SAteF-uXs0GtETLXaQSo8SE0sIWmPAFos9Fe329Y4d4 13751
pyflink/util/__init__.py sha256=tsdcyN6K1n3apIrknPcNIgJf7Y4IlY4gQZ433ddZZB0 958
pyflink/util/exceptions.py sha256=IkZcXFecPq_lMosSgkMzrzYhFzJ-1iwIPIKIx6WowK4 7051
pyflink/util/java_utils.py sha256=w276qJhATjkIJa7qDxaMEx7rbgGww1KxOzOh_iWeakg 7989
confluent_flink_table_api_python_plugin-1.20.50.dist-info/METADATA sha256=ubE4sshE7ZMcDpf0hQcJQ_e0ZXvf_SR9iCcmQ2ojrRM 1138
confluent_flink_table_api_python_plugin-1.20.50.dist-info/WHEEL sha256=9Hm2OB-j1QcCUq9Jguht7ayGIIZBRTdOXD1qg9cCgPM 109
confluent_flink_table_api_python_plugin-1.20.50.dist-info/top_level.txt sha256=1OGV8dvQrIOQ4LqxzqqAHFd3yhnLnIABWrJURnMCd5U 8
confluent_flink_table_api_python_plugin-1.20.50.dist-info/RECORD

top_level.txt

pyflink