[
https://issues.apache.org/jira/browse/FLINK-40186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-40186:
-------------------------------
Assignee: Liu Liu (was: Dian Fu)
> Support the basic functionality of DataFrame API
> ------------------------------------------------
>
> Key: FLINK-40186
> URL: https://issues.apache.org/jira/browse/FLINK-40186
> Project: Flink
> Issue Type: Sub-task
> Reporter: Dian Fu
> Assignee: Liu Liu
> Priority: Major
> Fix For: 2.4.0
>
>
> This JIRA covers the minimum functionality required to construct, transform,
> inspect, and execute a DataFrame. The goal of the first contribution is not
> to provide a feature-complete DataFrame implementation. Instead, it
> establishes the package structure, core abstractions, and a small end-to-end
> workflow on which follow-up contributions can be developed independently.
> Example:
> {code:python}
> import pyflink.dataframe as pf
> df = pf.from_records(
> [
> (1, "Alice", 30),
> (2, "Bob", 17),
> ],
> schema=["id", "name", "age"],
> )
> result = (
> df.filter(pf.col("age") >= 18)
> .with_column("age_next_year", pf.col("age") + 1)
> .select("id", "name", "age_next_year")
> )
> for row in result.collect():
> print(row)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
