Zander Matheson created FLINK-38389:
---------------------------------------
Summary: Add .show(), .head() and .tail() method to PyFlink Table
API
Key: FLINK-38389
URL: https://issues.apache.org/jira/browse/FLINK-38389
Project: Flink
Issue Type: New Feature
Components: Table SQL / API
Reporter: Zander Matheson
Problem Statement:
Today PyFlink has a number of small differences to other dataframe/table type
libraries. One of those is that there is no method to show the data easily.
This is possible in both lazily and non-lazily computed libraries and therefore
should be possible to do in Flink.
To make the Table API feel more friendly to Python developers, we should add
some helper functions for data exploration like those that exist in pandas,
pyspark and other dataframe libraries.
The first of these we could possibly add are show(), head() and tail(). Tail,
might not be so trivial, because we can't override the connector to read from a
certain point.
Show will show a snippet of data up to a number of rows as specified.
All the methods will simply return the data as a pandas dataframe to take
advantage of the print and display capabilities inherent to it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)