Dian Fu created FLINK-40186:
-------------------------------
Summary: 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: Dian Fu
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)
