alibabacloud-flink-python-coding
Alibaba Cloud Flink Python Coding
Apply the DataFrame-first workflow below.
Unless the user explicitly requests a non-DataFrame API or SQL, the main job pipeline must start with import pyflink.dataframe as pf. An implementation written entirely with Table API or SQL is not a DataFrame fallback or Table bridge.
Scenario Description
Develop version-aware Python jobs for Alibaba Cloud Realtime Compute for Apache Flink without inventing target-platform details.
Architecture: local repository + exact ververica-flink API package + VVR DataFrame API + upload-ready project artifacts + Alibaba Cloud Flink workspace + confirmed sources, sinks, connectors, dependencies, and runtime files.
The core scope is code, local validation, and deployment artifact preparation. Do not upload files, mutate a workspace, create/start/stop a deployment, or call Alibaba Cloud APIs unless the user separately requests those operations.
RAM Policy
The core workflow invokes no Alibaba Cloud API. No Alibaba Cloud API authorization is needed.