[
https://issues.apache.org/jira/browse/FLINK-40422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18108664#comment-18108664
]
Hirson Zhang commented on FLINK-40422:
--------------------------------------
Hi [~dianfu] 、[~auroflow] , I'd like to work on this issue as my first Apache
Flink contribution.
My implementation plan is to add lazy DataFrame wrappers for limit(), offset(),
and head() using the existing Table API operations, together with focused unit
and batch integration tests covering validation, zero values, and composed
offset/limit behavior.
Could you please confirm the approach and assign the issue to me if it looks
appropriate? Thank you!
> Add slicing APIs to DataFrame API
> ---------------------------------
>
> Key: FLINK-40422
> URL: https://issues.apache.org/jira/browse/FLINK-40422
> Project: Flink
> Issue Type: Sub-task
> Components: API / Python
> Reporter: Liu Liu
> Priority: Major
>
> Add row-slicing transformations:
> {code:java}
> def limit(self, n: int) -> DataFrame
> def offset(self, n: int) -> DataFrame
> def head(self, n: int) -> DataFrame {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
